diff --git a/splitio/producer/conf/sections.go b/splitio/producer/conf/sections.go index d6b16349..ba26d57e 100644 --- a/splitio/producer/conf/sections.go +++ b/splitio/producer/conf/sections.go @@ -103,7 +103,6 @@ type Redis struct { TLSSkipNameValidation bool `json:"tlsSkipNameValidation" s-cli:"redis-tls-skip-name-validation" s-def:"false" s-desc:"Blindly accept server's public key."` TLSClientCertificate string `json:"tlsClientCertificate" s-cli:"redis-tls-client-certificate" s-def:"" s-desc:"Client certificate signed by a known CA"` TLSClientKey string `json:"tlsClientKey" s-cli:"redis-tls-client-key" s-def:"" s-desc:"Client private key matching the certificate."` - ScanCount int `json:"scanCount" s-cli:"redis-scan-count" s-def:"10" s-desc:"It is the number of keys to search through at a time per cursor iteration, we use it to read feature flag names and flag set names."` } // Healthcheck configuration options diff --git a/splitio/producer/util.go b/splitio/producer/util.go index d992e0be..bd151e01 100644 --- a/splitio/producer/util.go +++ b/splitio/producer/util.go @@ -30,6 +30,7 @@ import ( const ( impressionsCountPeriodTaskInMemory = 1800 // 30 min impressionObserverSize = 500 + ScanCount = 10 ) func parseTLSConfig(opt *conf.Redis) (*tls.Config, error) { @@ -99,7 +100,7 @@ func parseRedisOptions(cfg *conf.Redis) (*config.RedisConfig, error) { WriteTimeout: cfg.WriteTimeout, PoolSize: cfg.PoolSize, TLSConfig: tlsCfg, - ScanCount: cfg.ScanCount, + ScanCount: ScanCount, } if cfg.SentinelReplication {