diff --git a/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/resource/endpoints/EnvoyEndpointsFactory.kt b/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/resource/endpoints/EnvoyEndpointsFactory.kt index 6eba4e4c7..e2986d832 100644 --- a/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/resource/endpoints/EnvoyEndpointsFactory.kt +++ b/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/resource/endpoints/EnvoyEndpointsFactory.kt @@ -167,7 +167,7 @@ class EnvoyEndpointsFactory( .setLocality(EnvoyProxyLocality.newBuilder().setZone(zone).build()) .addAllLbEndpoints(serviceInstances?.instances ?.map { - createLbEndpoint(it, serviceInstances.serviceName, locality, priority) + createLbEndpoint(it, serviceInstances.serviceName, locality, priority, zone) } ?: emptyList()) .setPriority(priority) .build() @@ -177,13 +177,14 @@ class EnvoyEndpointsFactory( serviceInstance: ServiceInstance, serviceName: String, locality: Locality, - priority: Int + priority: Int, + zone: String ): LbEndpoint { return LbEndpoint.newBuilder() .setEndpoint( buildEndpoint(serviceInstance) ) - .setMetadata(serviceInstance, serviceName, locality, priority) + .setMetadata(serviceInstance, serviceName, locality, priority, zone) .setLoadBalancingWeightFromInstance(serviceInstance) .build() } @@ -213,7 +214,8 @@ class EnvoyEndpointsFactory( instance: ServiceInstance, serviceName: String, locality: Locality, - priority: Int + priority: Int, + zone: String ): LbEndpoint.Builder { val lbMetadataKeys = Struct.newBuilder() val socketMatchMetadataKeys = Struct.newBuilder() @@ -246,7 +248,8 @@ class EnvoyEndpointsFactory( logger.info( "Resolved metadata locality to $calcLocality with " + "currentZone=$currentZone, locality: $locality priority $priority " + - "props=${properties.loadBalancing.priorities.zonePriorities}, serviceName: $serviceName" + ", serviceName: $serviceName, zone: $zone" + + "props=${properties.loadBalancing.priorities.zonePriorities}" ) } lbMetadataKeys.putFields(