dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

updated timeout 

Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
This commit is contained in:
akhilac1 2022-09-22 20:17:41 +05:30
parent f13fcf1ef3
commit 925e8f32a0
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
configuration/postgres/postgres.go
View File

@ -94,9 +94,10 @@ func (p *ConfigurationStore) Init(metadata configuration.Metadata) error {
p.metadata = m
}
p.ActiveSubscriptions = make(map[string]*subscription)
ctx, cancel := context.WithTimeout(context.Background(), p.metadata.maxIdleTimeout)
ctx, cancel := context.WithTimeout(context.Background(), defaultMaxConnIdleTime)
defer cancel()
client, err := Connect(ctx, p.metadata.connectionString, p.metadata.maxIdleTimeout)
// ctx := context.Background()
client, err := Connect(ctx, p.metadata.connectionString)
if err != nil {
return fmt.Errorf("error connecting to configuration store: '%s'", err)
}
@ -309,7 +310,7 @@ func parseMetadata(cmetadata configuration.Metadata) (metadata, error) {
return m, nil
}
func Connect(ctx context.Context, conn string, maxTimeout time.Duration) (*pgxpool.Pool, error) {
func Connect(ctx context.Context, conn string) (*pgxpool.Pool, error) {
config, err := pgxpool.ParseConfig(conn)
if err != nil {
return nil, fmt.Errorf("postgres configuration store connection error : %s", err)