+
+func TestClientStandaloneRedisLegacyEnv(t *testing.T) {
+ rcls, dbs := setupEnv(
+ "service-ricplt-dbaas-tcp-cluster-0.ricplt", "6376", "", "", "",
+ )
+ assert.Equal(t, 1, len(rcls))
+ assert.Equal(t, 1, len(dbs))
+
+ expectedKeysAndValues := []interface{}{"key1", "value1"}
+ rcls[0].On("MSet", expectedKeysAndValues).Return(redis.NewStatusResult("OK", nil))
+ err := dbs[0].MSet("key1", "value1")
+ assert.Nil(t, err)
+ rcls[0].AssertExpectations(t)
+}
+
+func TestClientSentinelRedisLegacyEnv(t *testing.T) {
+ rcls, dbs := setupEnv(
+ "service-ricplt-dbaas-tcp-cluster-0.ricplt", "6376", "dbaasmaster", "26376", "",
+ )
+ assert.Equal(t, 1, len(rcls))
+ assert.Equal(t, 1, len(dbs))
+
+ expectedKeysAndValues := []interface{}{"key1", "value1"}
+ rcls[0].On("MSet", expectedKeysAndValues).Return(redis.NewStatusResult("OK", nil))
+ err := dbs[0].MSet("key1", "value1")
+ assert.Nil(t, err)
+ rcls[0].AssertExpectations(t)
+}
+
+func TestClientTwoStandaloneRedisEnvs(t *testing.T) {
+ rcls, dbs := setupEnv(
+ "service-ricplt-dbaas-tcp-cluster-0.ricplt", "6376", "", "",
+ "service-ricplt-dbaas-tcp-cluster-0.ricplt,service-ricplt-dbaas-tcp-cluster-1.ricplt",
+ )
+ assert.Equal(t, 2, len(rcls))
+ assert.Equal(t, 2, len(dbs))
+
+ expectedKeysAndValues := []interface{}{"key1", "value1"}
+ rcls[0].On("MSet", expectedKeysAndValues).Return(redis.NewStatusResult("OK", nil))
+ err := dbs[0].MSet("key1", "value1")
+ assert.Nil(t, err)
+ rcls[0].AssertExpectations(t)
+
+ expectedKeysAndValues = []interface{}{"key2", "value2"}
+ rcls[1].On("MSet", expectedKeysAndValues).Return(redis.NewStatusResult("OK", nil))
+ err = dbs[1].MSet("key2", "value2")
+ assert.Nil(t, err)
+ rcls[0].AssertExpectations(t)
+ rcls[1].AssertExpectations(t)
+}
+
+func TestClientTwoSentinelRedisEnvs(t *testing.T) {
+ rcls, dbs := setupEnv(
+ "service-ricplt-dbaas-tcp-cluster-0.ricplt", "6376", "dbaasmaster", "26376",
+ "service-ricplt-dbaas-tcp-cluster-0.ricplt,service-ricplt-dbaas-tcp-cluster-1.ricplt",
+ )
+ assert.Equal(t, 2, len(rcls))
+ assert.Equal(t, 2, len(dbs))
+
+ expectedKeysAndValues := []interface{}{"key1", "value1"}
+ rcls[0].On("MSet", expectedKeysAndValues).Return(redis.NewStatusResult("OK", nil))
+ err := dbs[0].MSet("key1", "value1")
+ assert.Nil(t, err)
+ rcls[0].AssertExpectations(t)
+
+ expectedKeysAndValues = []interface{}{"key2", "value2"}
+ rcls[1].On("MSet", expectedKeysAndValues).Return(redis.NewStatusResult("OK", nil))
+ err = dbs[1].MSet("key2", "value2")
+ assert.Nil(t, err)
+ rcls[0].AssertExpectations(t)
+ rcls[1].AssertExpectations(t)
+}