filer: redis default to false for useReadOnly and routeByLatency
This commit is contained in:
@@ -20,8 +20,8 @@ func (store *RedisClusterStore) GetName() string {
|
|||||||
|
|
||||||
func (store *RedisClusterStore) Initialize(configuration util.Configuration, prefix string) (err error) {
|
func (store *RedisClusterStore) Initialize(configuration util.Configuration, prefix string) (err error) {
|
||||||
|
|
||||||
configuration.SetDefault(prefix+"useReadOnly", true)
|
configuration.SetDefault(prefix+"useReadOnly", false)
|
||||||
configuration.SetDefault(prefix+"routeByLatency", true)
|
configuration.SetDefault(prefix+"routeByLatency", false)
|
||||||
|
|
||||||
return store.initialize(
|
return store.initialize(
|
||||||
configuration.GetStringSlice(prefix+"addresses"),
|
configuration.GetStringSlice(prefix+"addresses"),
|
||||||
|
|||||||
@@ -20,8 +20,8 @@ func (store *RedisCluster2Store) GetName() string {
|
|||||||
|
|
||||||
func (store *RedisCluster2Store) Initialize(configuration util.Configuration, prefix string) (err error) {
|
func (store *RedisCluster2Store) Initialize(configuration util.Configuration, prefix string) (err error) {
|
||||||
|
|
||||||
configuration.SetDefault(prefix+"useReadOnly", true)
|
configuration.SetDefault(prefix+"useReadOnly", false)
|
||||||
configuration.SetDefault(prefix+"routeByLatency", true)
|
configuration.SetDefault(prefix+"routeByLatency", false)
|
||||||
|
|
||||||
return store.initialize(
|
return store.initialize(
|
||||||
configuration.GetStringSlice(prefix+"addresses"),
|
configuration.GetStringSlice(prefix+"addresses"),
|
||||||
|
|||||||
Reference in New Issue
Block a user