Adding Redis db index to not have default db index of 0 always and username for ACL.

Author: anupVMware

redis-persistence/src/main/java/com/netflix/conductor/redis/config/RedisProperties.java

@@ -108,6 +108,10 @@ public RedisProperties(ConductorProperties conductorProperties) {
 
     private int numTestsPerEvictionRun = 3;
 
+    private int database = 0;
+
+    private String username = null;
+
     public int getNumTestsPerEvictionRun() {
         return numTestsPerEvictionRun;
     }
@@ -283,4 +287,20 @@ public RetryPolicyFactory getConnectionRetryPolicy() {
             return () -> new RetryNTimes(maxRetryAttempts, false);
         }
     }
+
+    public int getDatabase() {
+        return database;
+    }
+
+    public void setDatabase(int database) {
+        this.database = database;
+    }
+
+    public String getUsername() {
+        return username;
+    }
+
+    public void setUsername(String username) {
+        this.username = username;
+    }
 }

redis-persistence/src/main/java/com/netflix/conductor/redis/config/RedisSentinelConfiguration.java

@@ -63,16 +63,33 @@ protected JedisCommands createJedisCommands(
         }
         // We use the password of the first sentinel host as password and sentinelPassword
         String password = getPassword(hostSupplier.getHosts());
-        if (password != null) {
+        if (properties.getUsername() != null && password != null) {
             return new JedisSentinel(
                     new JedisSentinelPool(
                             properties.getClusterName(),
                             sentinels,
                             genericObjectPoolConfig,
                             Protocol.DEFAULT_TIMEOUT,
                             Protocol.DEFAULT_TIMEOUT,
+                            properties.getUsername(),
                             password,
-                            Protocol.DEFAULT_DATABASE,
+                            properties.getDatabase(),
+                            null,
+                            Protocol.DEFAULT_TIMEOUT,
+                            Protocol.DEFAULT_TIMEOUT,
+                            properties.getUsername(),
+                            password,
+                            null));
+        } else if (password != null) {
+            return new JedisSentinel(
+                    new JedisSentinelPool(
+                            properties.getClusterName(),
+                            sentinels,
+                            genericObjectPoolConfig,
+                            Protocol.DEFAULT_TIMEOUT,
+                            Protocol.DEFAULT_TIMEOUT,
+                            password,
+                            properties.getDatabase(),
                             null,
                             Protocol.DEFAULT_TIMEOUT,
                             Protocol.DEFAULT_TIMEOUT,

redis-persistence/src/main/java/com/netflix/conductor/redis/config/RedisStandaloneConfiguration.java

@@ -45,18 +45,29 @@ protected JedisCommands createJedisCommands(
         config.setMaxTotal(properties.getMaxConnectionsPerHost());
         log.info("Starting conductor server using redis_standalone.");
         Host host = hostSupplier.getHosts().get(0);
-        return new JedisStandalone(getJedisPool(config, host));
+        return new JedisStandalone(getJedisPool(config, host, properties));
     }
 
-    private JedisPool getJedisPool(JedisPoolConfig config, Host host) {
-        if (host.getPassword() != null) {
+    private JedisPool getJedisPool(JedisPoolConfig config, Host host, RedisProperties properties) {
+        if (properties.getUsername() != null && host.getPassword() != null) {
             log.info("Connecting to Redis Standalone with AUTH");
             return new JedisPool(
                     config,
                     host.getHostName(),
                     host.getPort(),
                     Protocol.DEFAULT_TIMEOUT,
-                    host.getPassword());
+                    properties.getUsername(),
+                    host.getPassword(),
+                    properties.getDatabase());
+        } else if (host.getPassword() != null) {
+            log.info("Connecting to Redis Standalone with AUTH");
+            return new JedisPool(
+                    config,
+                    host.getHostName(),
+                    host.getPort(),
+                    Protocol.DEFAULT_TIMEOUT,
+                    host.getPassword(),
+                    properties.getDatabase());
         } else {
             return new JedisPool(config, host.getHostName(), host.getPort());
         }