KNOX-2959 - Auto discovery to support scaling scenarios

apache · Sep 28, 2023 · 6a2c7c6 · 6a2c7c6
1 parent 3579cfc
commit 6a2c7c6
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 41 deletions.
diff --git a/...rg/apache/knox/gateway/topology/discovery/cm/ClouderaManagerServiceDiscoveryMessages.java b/...rg/apache/knox/gateway/topology/discovery/cm/ClouderaManagerServiceDiscoveryMessages.java
@@ -201,8 +201,8 @@ void queryingConfigActivationEventsFromCluster(String clusterName,
   @Message(level = MessageLevel.DEBUG, text = "Activation event relevance: {0} = {1} ({2} / {3} / {4} / {5})")
   void activationEventRelevance(String eventId, String relevance, String command, String status, String serviceType, boolean serviceModelGeneratorExists);
 
-  @Message(level = MessageLevel.DEBUG, text = "Deactivation event relevance: {0} = {1} ({2} / {3} / {4})")
-  void deactivationEventRelevance(String eventId, String relevance, String eventCode, String serviceType, boolean serviceModelGeneratorExists);
+  @Message(level = MessageLevel.DEBUG, text = "Scale event relevance: {0} = {1} ({2} / {3} / {4})")
+  void scaleEventRelevance(String eventId, String relevance, String eventCode, String serviceType, boolean serviceModelGeneratorExists);
 
   @Message(level = MessageLevel.DEBUG, text = "Activation event - {0} - has already been processed, skipping ...")
   void activationEventAlreadyProcessed(String eventId);

diff --git a/...a/org/apache/knox/gateway/topology/discovery/cm/monitor/PollingConfigurationAnalyzer.java b/...a/org/apache/knox/gateway/topology/discovery/cm/monitor/PollingConfigurationAnalyzer.java
@@ -511,7 +511,7 @@ private boolean isScaleEvent(ApiEvent event) {
     final boolean serviceModelGeneratorExists = serviceModelGeneratorsHolder.getServiceModelGenerators(serviceType) != null;
     final boolean relevant = serviceModelGeneratorExists &&
             (CREATED_EVENT_CODES.contains(eventCode) || DELETED_EVENT_CODES.contains(eventCode));
-    log.deactivationEventRelevance(event.getId(), String.valueOf(relevant), eventCode, serviceType, relevant);
+    log.scaleEventRelevance(event.getId(), String.valueOf(relevant), eventCode, serviceType, relevant);
     return relevant;
   }
 

diff --git a/...cm/src/main/java/org/apache/knox/gateway/topology/discovery/cm/monitor/RoleHostCache.java b/...cm/src/main/java/org/apache/knox/gateway/topology/discovery/cm/monitor/RoleHostCache.java