Implemented possibility for configuring traffic splitting, and fallback using aggregate cluster #292

Author: nastassia-dailidava

envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/resource/clusters/EnvoyClustersFactory.kt

@@ -267,7 +267,8 @@ class EnvoyClustersFactory(
         return cluster?.let {
             if (enableTrafficSplitting(serviceName, cluster.name, dependencies, clusterLoadAssignment)) {
                 logger.debug(
-                    "Creating traffic splitting egress cluster config for ${cluster.name}, service: $serviceName")
+                    "Creating traffic splitting egress cluster config for ${cluster.name}, service: $serviceName"
+                )
                 createSetOfClustersForGroup(dependencySettings, cluster)
             } else {
                 listOf(createClusterForGroup(dependencySettings, cluster))

envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/resource/endpoints/EnvoyEndpointsFactory.kt

@@ -82,7 +82,7 @@ class EnvoyEndpointsFactory(
     ): List<ClusterLoadAssignment> {
         return egressRouteSpecifications
             .filter { it.clusterWeights.isNotEmpty() }
-            .onEach { logger.debug("Traffic splitting is enabled for cluster: ${it.clusterName}")  }
+            .onEach { logger.debug("Traffic splitting is enabled for cluster: ${it.clusterName}") }
             .mapNotNull { routeSpec ->
                 clusterLoadAssignments[routeSpec.clusterName]?.let {
                     ClusterLoadAssignment.newBuilder(it)

envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ClusterNames.kt

@@ -4,13 +4,14 @@ import pl.allegro.tech.servicemesh.envoycontrol.utils.ClusterNames.AGGREGATE_CLU
 import pl.allegro.tech.servicemesh.envoycontrol.utils.ClusterNames.SECONDARY_CLUSTER_POSTFIX
 
 object ClusterNames {
-    const val SECONDARY_CLUSTER_POSTFIX= "secondary"
-    const val AGGREGATE_CLUSTER_POSTFIX= "aggregate"
+    const val SECONDARY_CLUSTER_POSTFIX = "secondary"
+    const val AGGREGATE_CLUSTER_POSTFIX = "aggregate"
 }
-fun getSecondaryClusterName(serviceName: String) :String {
+
+fun getSecondaryClusterName(serviceName: String): String {
     return "$serviceName-$SECONDARY_CLUSTER_POSTFIX"
 }
 
-fun getAggregateClusterName(serviceName: String) :String {
+fun getAggregateClusterName(serviceName: String): String {
     return "$serviceName-$AGGREGATE_CLUSTER_POSTFIX"
 }