Skip to content

Commit

Permalink
feat(redis): Added availability to set max_retries attribute (#756)
Browse files Browse the repository at this point in the history
  • Loading branch information
kissken authored Jun 30, 2022
1 parent b4b49bc commit 3fba8fc
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 0 deletions.
1 change: 1 addition & 0 deletions cmd/api/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -87,6 +87,7 @@ func getDefault() config {
Addrs: "localhost:6379",
MetricsTTL: "1h",
DialTimeout: "500ms",
MaxRetries: 3,
},
Logger: cmd.LoggerConfig{
LogFile: "stdout",
Expand Down
3 changes: 3 additions & 0 deletions cmd/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,8 @@ type RedisConfig struct {
ReadTimeout string `yaml:"read_timeout"`
// Write-operation timeout. Default is ReadTimeout seconds.
WriteTimeout string `yaml:"write_timeout"`
// MaxRetries count of retries.
MaxRetries int `yaml:"max_retries"`
}

// GetSettings returns redis config parsed from moira config files
Expand All @@ -47,6 +49,7 @@ func (config *RedisConfig) GetSettings() redis.Config {
Addrs: strings.Split(config.Addrs, ","),
Username: config.Username,
Password: config.Password,
MaxRetries: config.MaxRetries,
MetricsTTL: to.Duration(config.MetricsTTL),
DialTimeout: to.Duration(config.DialTimeout),
ReadTimeout: to.Duration(config.ReadTimeout),
Expand Down
1 change: 1 addition & 0 deletions database/redis/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,4 +12,5 @@ type Config struct {
DialTimeout time.Duration
ReadTimeout time.Duration
WriteTimeout time.Duration
MaxRetries int
}
1 change: 1 addition & 0 deletions database/redis/database.go
Original file line number Diff line number Diff line change
Expand Up @@ -63,6 +63,7 @@ func NewDatabase(logger moira.Logger, config Config, source DBSource) *DbConnect
DialTimeout: config.DialTimeout,
ReadTimeout: config.ReadTimeout,
WriteTimeout: config.WriteTimeout,
MaxRetries: config.MaxRetries,
})

ctx := context.Background()
Expand Down

0 comments on commit 3fba8fc

Please sign in to comment.