diff --git a/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/EnvoySnapshotFactory.kt b/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/EnvoySnapshotFactory.kt index 135b9e787..04809c8c4 100644 --- a/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/EnvoySnapshotFactory.kt +++ b/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/EnvoySnapshotFactory.kt @@ -113,6 +113,7 @@ class EnvoySnapshotFactory( val removedClusters = previous - current.keys current + removedClusters } + false -> current } } @@ -198,6 +199,7 @@ class EnvoySnapshotFactory( is ServicesGroup -> { definedServicesRoutes } + is AllServicesGroup -> { val servicesNames = group.proxySettings.outgoing.getServiceDependencies().map { it.service }.toSet() val allServicesRoutes = globalSnapshot.allServicesNames.subtract(servicesNames).map { @@ -226,6 +228,10 @@ class EnvoySnapshotFactory( val enabledForDependency = globalSnapshot.endpoints[clusterName]?.endpointsList ?.any { e -> trafficSplitting.zoneName == e.locality.zone } ?: false + logger.debug( + "Traffic splitting route spec, enabled: $trafficSplitting, " + + "weights: $weights, enabledForDependency: $enabledForDependency" + ) return if (weights != null && enabledForDependency) { WeightRouteSpecification( clusterName,