Package io.split.telemetry.storage

Class InMemoryTelemetryStorage

java.lang.Object

io.split.telemetry.storage.InMemoryTelemetryStorage

All Implemented Interfaces:

TelemetryConfigConsumer, TelemetryConfigProducer, TelemetryEvaluationConsumer, TelemetryEvaluationProducer, TelemetryRuntimeConsumer, TelemetryRuntimeProducer, TelemetryStorage, TelemetryStorageConsumer, TelemetryStorageProducer

public class InMemoryTelemetryStorage
extends Object
implements TelemetryStorage

Field Summary

Fields

Modifier and Type	Field	Description
static int	MAX_LATENCY_BUCKET_COUNT
static int	MAX_STREAMING_EVENTS
static int	MAX_TAGS

Constructor Summary

Constructors

Constructor	Description
InMemoryTelemetryStorage()

Method Summary

Modifier and Type	Method	Description
void	addTag(String tag)
long	getBURTimeouts()
long	getEventStats(EventsDataRecordsEnum dataType)
long	getImpressionsStats(ImpressionsDataTypeEnum dataType)
LastSynchronization	getLastSynchronization()
long	getNonReadyUsages()
long	getSessionLength()
long	popAuthRejections()
MethodExceptions	popExceptions()
HTTPErrors	popHTTPErrors()
HTTPLatencies	popHTTPLatencies()
MethodLatencies	popLatencies()
List<StreamingEvent>	popStreamingEvents()
List<String>	popTags()
long	popTokenRefreshes()
UpdatesFromSSE	popUpdatesFromSSE()
void	recordAuthRejections()
void	recordBURTimeout()
void	recordEventStats(EventsDataRecordsEnum dataType, long count)
void	recordException(MethodEnum method)
void	recordImpressionStats(ImpressionsDataTypeEnum dataType, long count)
void	recordLatency(MethodEnum method, long latency)
void	recordNonReadyUsage()
void	recordSessionLength(long sessionLength)
void	recordStreamingEvents(StreamingEvent streamingEvent)
void	recordSuccessfulSync(LastSynchronizationRecordsEnum resource, long time)
void	recordSyncError(ResourceEnum resource, int status)
void	recordSyncLatency(HTTPLatenciesEnum resource, long latency)
void	recordTokenRefreshes()
void	recordUpdatesFromSSE(UpdatesFromSSEEnum updatesFromSSEEnum)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_LATENCY_BUCKET_COUNT

public static final int MAX_LATENCY_BUCKET_COUNT

See Also:

Constant Field Values

MAX_STREAMING_EVENTS

public static final int MAX_STREAMING_EVENTS

See Also:

Constant Field Values

MAX_TAGS

public static final int MAX_TAGS

See Also:

Constant Field Values

Constructor Detail

InMemoryTelemetryStorage

public InMemoryTelemetryStorage()

Method Detail

getBURTimeouts

public long getBURTimeouts()

Specified by:

getBURTimeouts in interface TelemetryConfigConsumer

getNonReadyUsages

public long getNonReadyUsages()

Specified by:

getNonReadyUsages in interface TelemetryConfigConsumer

popExceptions

public MethodExceptions popExceptions()

Specified by:

popExceptions in interface TelemetryEvaluationConsumer

popLatencies

public MethodLatencies popLatencies()

Specified by:

popLatencies in interface TelemetryEvaluationConsumer

recordNonReadyUsage

public void recordNonReadyUsage()

Specified by:

recordNonReadyUsage in interface TelemetryConfigProducer

recordBURTimeout

public void recordBURTimeout()

Specified by:

recordBURTimeout in interface TelemetryConfigProducer

recordLatency

public void recordLatency(MethodEnum method,
                          long latency)

Specified by:

recordLatency in interface TelemetryEvaluationProducer

recordException

public void recordException(MethodEnum method)

Specified by:

recordException in interface TelemetryEvaluationProducer

getImpressionsStats

public long getImpressionsStats(ImpressionsDataTypeEnum dataType)

Specified by:

getImpressionsStats in interface TelemetryRuntimeConsumer

getEventStats

public long getEventStats(EventsDataRecordsEnum dataType)

Specified by:

getEventStats in interface TelemetryRuntimeConsumer

getLastSynchronization

public LastSynchronization getLastSynchronization()

Specified by:

getLastSynchronization in interface TelemetryRuntimeConsumer

popHTTPErrors

public HTTPErrors popHTTPErrors()

Specified by:

popHTTPErrors in interface TelemetryRuntimeConsumer

popHTTPLatencies

public HTTPLatencies popHTTPLatencies()

Specified by:

popHTTPLatencies in interface TelemetryRuntimeConsumer

popAuthRejections

public long popAuthRejections()

Specified by:

popAuthRejections in interface TelemetryRuntimeConsumer

popTokenRefreshes

public long popTokenRefreshes()

Specified by:

popTokenRefreshes in interface TelemetryRuntimeConsumer

popStreamingEvents

public List<StreamingEvent> popStreamingEvents()

Specified by:

popStreamingEvents in interface TelemetryRuntimeConsumer

popTags

public List<String> popTags()

Specified by:

popTags in interface TelemetryRuntimeConsumer

getSessionLength

public long getSessionLength()

Specified by:

getSessionLength in interface TelemetryRuntimeConsumer

popUpdatesFromSSE

public UpdatesFromSSE popUpdatesFromSSE()

Specified by:

popUpdatesFromSSE in interface TelemetryRuntimeConsumer

addTag

public void addTag(String tag)

Specified by:

addTag in interface TelemetryRuntimeProducer

recordImpressionStats

public void recordImpressionStats(ImpressionsDataTypeEnum dataType,
                                  long count)

Specified by:

recordImpressionStats in interface TelemetryRuntimeProducer

recordEventStats

public void recordEventStats(EventsDataRecordsEnum dataType,
                             long count)

Specified by:

recordEventStats in interface TelemetryRuntimeProducer

recordSuccessfulSync

public void recordSuccessfulSync(LastSynchronizationRecordsEnum resource,
                                 long time)

Specified by:

recordSuccessfulSync in interface TelemetryRuntimeProducer

recordSyncError

public void recordSyncError(ResourceEnum resource,
                            int status)

Specified by:

recordSyncError in interface TelemetryRuntimeProducer

recordSyncLatency

public void recordSyncLatency(HTTPLatenciesEnum resource,
                              long latency)

Specified by:

recordSyncLatency in interface TelemetryRuntimeProducer

recordAuthRejections

public void recordAuthRejections()

Specified by:

recordAuthRejections in interface TelemetryRuntimeProducer

recordTokenRefreshes

public void recordTokenRefreshes()

Specified by:

recordTokenRefreshes in interface TelemetryRuntimeProducer

recordStreamingEvents

public void recordStreamingEvents(StreamingEvent streamingEvent)

Specified by:

recordStreamingEvents in interface TelemetryRuntimeProducer

recordSessionLength

public void recordSessionLength(long sessionLength)

Specified by:

recordSessionLength in interface TelemetryRuntimeProducer

recordUpdatesFromSSE

public void recordUpdatesFromSSE(UpdatesFromSSEEnum updatesFromSSEEnum)

Specified by:

recordUpdatesFromSSE in interface TelemetryRuntimeProducer