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

Modifier and Type	Method	Description
void	finalSynchronization()
void	synchronizeConfig(SplitClientConfig config, long readyTimeStamp, Map<String,Long> factoryInstances, List<String> tags)
void	synchronizeStats()
void	synchronizeUniqueKeys(UniqueKeys uniqueKeys)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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:

synchronizeConfig in interface TelemetrySynchronizer

synchronizeStats

public void synchronizeStats()
                      throws Exception

Specified by:

synchronizeStats in interface TelemetrySynchronizer

Throws:

Exception

synchronizeUniqueKeys

public void synchronizeUniqueKeys(UniqueKeys uniqueKeys)

Specified by:

synchronizeUniqueKeys in interface TelemetrySynchronizer

finalSynchronization

public void finalSynchronization()
                          throws Exception

Specified by:

finalSynchronization in interface TelemetrySynchronizer

Throws:

Exception