Implemented locality weighted load balancing (added locality log)

allegro · Jan 22, 2024 · 017413d · 017413d
1 parent 4785a11
commit 017413d
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/...llegro/tech/servicemesh/envoycontrol/snapshot/resource/endpoints/EnvoyEndpointsFactory.kt b/...llegro/tech/servicemesh/envoycontrol/snapshot/resource/endpoints/EnvoyEndpointsFactory.kt
@@ -240,6 +240,15 @@ class EnvoyEndpointsFactory(
             )
         }
         val calcLocality = if (priority == 0) Locality.LOCAL.name else locality.name
+        if (serviceName == "service-mesh-service-first" ||
+            serviceName == "service-mesh-service-second"
+        ) {
+            logger.info(
+                "Resolved metadata locality to $calcLocality with " +
+                    "currentZone=$currentZone, locality: $locality priority $priority " +
+                    "props=${properties.loadBalancing.priorities.zonePriorities}, serviceName: $serviceName"
+            )
+        }
         lbMetadataKeys.putFields(
             properties.loadBalancing.localityMetadataKey,
             Value.newBuilder().setStringValue(calcLocality).build()