redis upgrade test

Author: AmitFRSH

common/src/main/java/com/netflix/conductor/common/config/ConductorRedisPropLogger.java

@@ -0,0 +1,47 @@
+package com.netflix.conductor.common.config;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.boot.context.event.ApplicationReadyEvent;
+import org.springframework.context.event.EventListener;
+import org.springframework.core.env.Environment;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConductorRedisPropLogger {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(ConductorRedisPropLogger.class);
+    
+    private final Environment env;
+
+    public ConductorRedisPropLogger(Environment env) {
+        this.env = env;
+    }
+
+    @EventListener(ApplicationReadyEvent.class)
+    public void loggerResolvedRedisProps() {
+        // QUEUE (Orkes RedisQueueConfiguration)
+        LOGGER.info("[CONDUCTOR_REDIS_UPGRADE] ==== QUEUE_CFG (Orkes queues) ====");
+        loggerKey("conductor.queue.type");
+        // common keys for Orkes redis queues:
+        loggerKey("conductor.redis.hosts");
+        loggerKey("conductor.redis.ssl");
+        loggerKey("conductor.redis.workflowNamespacePrefix");
+        loggerKey("conductor.redis.queueNamespacePrefix");
+        LOGGER.info("[CONDUCTOR_REDIS_UPGRADE] ==================================");
+
+        // LOCK (Netflix RedisLockConfiguration)
+        LOGGER.info("[CONDUCTOR_REDIS_UPGRADE] ==== LOCK_CFG (Execution lock) ====");
+        loggerKey("conductor.workflow-scylla-execution-lock.enabled");
+        loggerKey("conductor.redis-lock.serverType");
+        loggerKey("conductor.redis-lock.serverAddress");
+        loggerKey("conductor.redis-lock.serverPassword");
+        loggerKey("conductor.redis-lock.namespace");
+        LOGGER.info("[CONDUCTOR_REDIS_UPGRADE] ==================================");
+    }
+
+    private void loggerKey(String key) {
+        String val = env.getProperty(key);
+        LOGGER.info("[CONDUCTOR_REDIS_UPGRADE] [{}] {}", key, val == null ? "<unset>" : val);
+    }
+}

docker/server/config/config-conductor-server.properties

@@ -2,7 +2,7 @@
 conductor.grpc-server.enabled=false
 
 conductor.queue.type=redis_standalone
-conductor.redis.hosts=${REDIS_HOST}:${REDIS_PORT}:${REDIS_RACK_HOSTED_ZONE}:${REDIS_PASSWORD}
+conductor.redis.hosts=fs-microservice-caas-migration-testing.redis.apps-us-east-1:30140:${REDIS_RACK_HOSTED_ZONE}:8z6USHwP3Ib09efAlcjjq7F9NQO8dcaM
 conductor.redis.workflowNamespacePrefix=${REDIS_WORKFLOW_NS_PREFIX}
 conductor.redis.queueNamespacePrefix=${REDIS_QUEUE_NS_PREFIX}
 
@@ -30,8 +30,8 @@ conductor.workflow-monitor.stats.initial-delay=${WORKFLOW_MONITOR_STATS_INITIAL_
 conductor.workflow-monitor.stats.delay=${WORKFLOW_MONITOR_STATS_FIXED_DELAY}
 conductor.workflow-repair-service.enabled=true
 conductor.workflow-scylla-execution-lock.enabled=true
-conductor.redis-lock.serverAddress=redis://${REDIS_HOST}:${REDIS_PORT}
-conductor.redis-lock.serverPassword=${REDIS_PASSWORD}
+conductor.redis-lock.serverAddress=redis://fs-microservice-caas-migration-testing.redis.apps-us-east-1:30140
+conductor.redis-lock.serverPassword=8z6USHwP3Ib09efAlcjjq7F9NQO8dcaM
 conductor.redis-lock.namespace=${REDIS_LOCK_NS_PREFIX}
 
 # Pushing Prom Metrics

redis-lock/src/main/java/com/netflix/conductor/redislock/config/RedisLockConfiguration.java

@@ -58,6 +58,12 @@ public Redisson getRedisson(RedisLockProperties properties) {
         }
 
         int connectionTimeout = 10000;
+        LOGGER.info("[CONDUCTOR_REDIS_UPGRADE] type={}, address={}, pass?={}, masterName={}, nettyThreads={}",
+                redisServerType,
+                redisServerAddress,
+                (redisServerPassword != null && !redisServerPassword.isEmpty()),
+                masterName,
+                properties.getNumNettyThreads());
         switch (redisServerType) {
             case SINGLE:
                 LOGGER.info("Setting up Redis Single Server for RedisLockConfiguration");