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

fixing review comments 

Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
This commit is contained in:
akhilac1 2022-09-20 15:30:54 +05:30
parent 6ddc42d3bd
commit 367ed0fb89
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
configuration/postgres/metadata.go
View File

@ -16,7 +16,7 @@ package postgres
import "time"
type metadata struct {
maxIdleTime time.Duration
maxIdleTimeout time.Duration
connectionString string
configTable string
}

6
configuration/postgres/postgres.go
View File

@ -87,9 +87,9 @@ 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.maxIdleTime)
ctx, cancel := context.WithTimeout(context.Background(), p.metadata.maxIdleTimeout)
defer cancel()
client, err := Connect(ctx, p.metadata.connectionString, p.metadata.maxIdleTime)
client, err := Connect(ctx, p.metadata.connectionString, p.metadata.maxIdleTimeout)
if err != nil {
return fmt.Errorf("error connecting to configuration store: '%s'", err)
}
@ -293,7 +293,7 @@ func parseMetadata(cmetadata configuration.Metadata) (metadata, error) {
// configure maxTimeout if provided
if mxTimeout, ok := cmetadata.Properties[connMaxIdleTimeKey]; ok && mxTimeout != "" {
if t, err := time.ParseDuration(mxTimeout); err == nil {
m.maxIdleTime = t
m.maxIdleTimeout = t
} else {
return m, fmt.Errorf(ErrorMissingMaxTimeout)
}