File tree Expand file tree Collapse file tree 1 file changed +0
-5
lines changed
envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/snapshot Expand file tree Collapse file tree 1 file changed +0
-5
lines changed Original file line number Diff line number Diff line change @@ -4,7 +4,6 @@ import io.envoyproxy.controlplane.cache.SnapshotCache
4
4
import io.envoyproxy.controlplane.cache.v3.Snapshot
5
5
import io.micrometer.core.instrument.MeterRegistry
6
6
import io.micrometer.core.instrument.Tags
7
- import io.micrometer.core.instrument.Timer
8
7
import pl.allegro.tech.servicemesh.envoycontrol.groups.CommunicationMode.ADS
9
8
import pl.allegro.tech.servicemesh.envoycontrol.groups.CommunicationMode.XDS
10
9
import pl.allegro.tech.servicemesh.envoycontrol.groups.Group
@@ -198,13 +197,10 @@ class SnapshotUpdater(
198
197
}
199
198
}
200
199
201
- private val updateSnapshotForGroupsTimer = meterRegistry.timer(" snapshot.update.duration.seconds" )
202
-
203
200
private fun updateSnapshotForGroups (
204
201
groups : Collection <Group >,
205
202
result : UpdateResult
206
203
): Mono <UpdateResult > {
207
- val sample = Timer .start()
208
204
versions.retainGroups(cache.groups())
209
205
val results = Flux .fromIterable(groups)
210
206
.doOnNextScheduledOn(groupSnapshotScheduler) { group ->
@@ -222,7 +218,6 @@ class SnapshotUpdater(
222
218
}
223
219
}
224
220
return results.then(Mono .fromCallable {
225
- sample.stop(updateSnapshotForGroupsTimer)
226
221
result
227
222
})
228
223
}
You can’t perform that action at this time.
0 commit comments