Package io.split.telemetry.synchronizer
Class TelemetryInMemorySubmitter
- java.lang.Object
-
- io.split.telemetry.synchronizer.TelemetryInMemorySubmitter
-
- All Implemented Interfaces:
TelemetrySynchronizer
public class TelemetryInMemorySubmitter extends Object implements TelemetrySynchronizer
-
-
Constructor Summary
Constructors Constructor Description TelemetryInMemorySubmitter(SplitHttpClient client, URI telemetryRootEndpoint, TelemetryStorageConsumer telemetryStorageConsumer, SplitCacheConsumer splitCacheConsumer, SegmentCacheConsumer segmentCacheConsumer, TelemetryRuntimeProducer telemetryRuntimeProducer, long initStartTime)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidfinalSynchronization()voidsynchronizeConfig(SplitClientConfig config, long readyTimeStamp, Map<String,Long> factoryInstances, List<String> tags)voidsynchronizeStats()voidsynchronizeUniqueKeys(UniqueKeys uniqueKeys)
-
-
-
Constructor Detail
-
TelemetryInMemorySubmitter
public TelemetryInMemorySubmitter(SplitHttpClient client, URI telemetryRootEndpoint, TelemetryStorageConsumer telemetryStorageConsumer, SplitCacheConsumer splitCacheConsumer, SegmentCacheConsumer segmentCacheConsumer, TelemetryRuntimeProducer telemetryRuntimeProducer, long initStartTime) throws URISyntaxException
- Throws:
URISyntaxException
-
-
Method Detail
-
synchronizeConfig
public void synchronizeConfig(SplitClientConfig config, long readyTimeStamp, Map<String,Long> factoryInstances, List<String> tags)
- Specified by:
synchronizeConfigin interfaceTelemetrySynchronizer
-
synchronizeStats
public void synchronizeStats() throws Exception- Specified by:
synchronizeStatsin interfaceTelemetrySynchronizer- Throws:
Exception
-
synchronizeUniqueKeys
public void synchronizeUniqueKeys(UniqueKeys uniqueKeys)
- Specified by:
synchronizeUniqueKeysin interfaceTelemetrySynchronizer
-
finalSynchronization
public void finalSynchronization() throws Exception- Specified by:
finalSynchronizationin interfaceTelemetrySynchronizer- Throws:
Exception
-
-