diff --git a/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/server/CachedProtoResourcesSerializer.kt b/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/server/CachedProtoResourcesSerializer.kt index e11b58eca..125a98c87 100644 --- a/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/server/CachedProtoResourcesSerializer.kt +++ b/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/server/CachedProtoResourcesSerializer.kt @@ -39,13 +39,13 @@ internal class CachedProtoResourcesSerializer( } override fun serialize( - resources: MutableCollection, - apiVersion: Resources.ApiVersion + resources: MutableCollection, + apiVersion: Resources.ApiVersion ): MutableCollection = serializeTimer.record(Supplier { getResources(resources, apiVersion) }) private fun getResources( - resources: MutableCollection, - apiVersion: Resources.ApiVersion + resources: MutableCollection, + apiVersion: Resources.ApiVersion ): MutableCollection { return cache.get(resources) { resources.asSequence() diff --git a/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/resource/listeners/EnvoyListenersFactory.kt b/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/resource/listeners/EnvoyListenersFactory.kt index ef2e5dc90..2434ce2dd 100644 --- a/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/resource/listeners/EnvoyListenersFactory.kt +++ b/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot/resource/listeners/EnvoyListenersFactory.kt @@ -12,7 +12,6 @@ import io.envoyproxy.envoy.config.accesslog.v3.StatusCodeFilter import io.envoyproxy.envoy.config.core.v3.Address import io.envoyproxy.envoy.config.core.v3.AggregatedConfigSource import io.envoyproxy.envoy.config.core.v3.ApiConfigSource -import io.envoyproxy.envoy.config.core.v3.ApiVersion import io.envoyproxy.envoy.config.core.v3.ConfigSource import io.envoyproxy.envoy.config.core.v3.GrpcService import io.envoyproxy.envoy.config.core.v3.Http1ProtocolOptions @@ -255,7 +254,6 @@ class EnvoyListenersFactory( private fun egressRds(communicationMode: CommunicationMode): Rds { val configSource = ConfigSource.newBuilder() - .setResourceApiVersion(ApiVersion.V3) .setInitialFetchTimeout(egressRdsInitialFetchTimeout) when (communicationMode) { @@ -309,7 +307,6 @@ class EnvoyListenersFactory( private fun ingressRds(communicationMode: CommunicationMode): Rds { val configSource = ConfigSource.newBuilder() - .setResourceApiVersion(ApiVersion.V3) .setInitialFetchTimeout(ingressRdsInitialFetchTimeout) when (communicationMode) {