Uses of Interface
io.split.telemetry.storage.TelemetryRuntimeProducer
-
-
Uses of TelemetryRuntimeProducer in io.split.client
Methods in io.split.client with parameters of type TelemetryRuntimeProducer Modifier and Type Method Description static HttpSegmentChangeFetcherHttpSegmentChangeFetcher. create(org.apache.hc.client5.http.impl.classic.CloseableHttpClient client, URI root, TelemetryRuntimeProducer telemetryRuntimeProducer)static HttpSplitChangeFetcherHttpSplitChangeFetcher. create(org.apache.hc.client5.http.impl.classic.CloseableHttpClient client, URI root, TelemetryRuntimeProducer telemetryRuntimeProducer) -
Uses of TelemetryRuntimeProducer in io.split.client.events
Methods in io.split.client.events with parameters of type TelemetryRuntimeProducer Modifier and Type Method Description static EventsSenderEventsSender. create(org.apache.hc.client5.http.impl.classic.CloseableHttpClient httpclient, URI eventsTarget, TelemetryRuntimeProducer telemetryRuntimeProducer)Constructors in io.split.client.events with parameters of type TelemetryRuntimeProducer Constructor Description InMemoryEventsStorage(int maxQueueSize, TelemetryRuntimeProducer telemetryRuntimeProducer) -
Uses of TelemetryRuntimeProducer in io.split.client.impressions
Methods in io.split.client.impressions with parameters of type TelemetryRuntimeProducer Modifier and Type Method Description static HttpImpressionsSenderHttpImpressionsSender. create(org.apache.hc.client5.http.impl.classic.CloseableHttpClient client, URI eventsRootEndpoint, ImpressionsManager.Mode mode, TelemetryRuntimeProducer telemetryRuntimeProducer)static ImpressionsManagerImplImpressionsManagerImpl. instance(SplitClientConfig config, TelemetryRuntimeProducer telemetryRuntimeProducer, ImpressionsStorageConsumer impressionsStorageConsumer, ImpressionsStorageProducer impressionsStorageProducer, ImpressionsSender impressionsSender, ProcessImpressionStrategy processImpressionStrategy, ImpressionCounter counter, ImpressionListener listener)static ImpressionsManagerImplImpressionsManagerImpl. instanceForTest(SplitClientConfig config, ImpressionsSender impressionsSender, TelemetryRuntimeProducer telemetryRuntimeProducer, ImpressionsStorageConsumer impressionsStorageConsumer, ImpressionsStorageProducer impressionsStorageProducer, ProcessImpressionStrategy processImpressionStrategy, ImpressionCounter counter, ImpressionListener listener) -
Uses of TelemetryRuntimeProducer in io.split.client.impressions.strategy
Constructors in io.split.client.impressions.strategy with parameters of type TelemetryRuntimeProducer Constructor Description ProcessImpressionOptimized(boolean listenerEnabled, ImpressionObserver impressionObserver, ImpressionCounter impressionCounter, TelemetryRuntimeProducer telemetryRuntimeProducer) -
Uses of TelemetryRuntimeProducer in io.split.engine.common
Methods in io.split.engine.common with parameters of type TelemetryRuntimeProducer Modifier and Type Method Description static PushManagerImpPushManagerImp. build(Synchronizer synchronizer, String streamingUrl, String authUrl, SplitAPI splitAPI, LinkedBlockingQueue<PushManager.Status> statusMessages, TelemetryRuntimeProducer telemetryRuntimeProducer, ThreadFactory threadFactory)static SyncManagerImpSyncManagerImp. build(SplitTasks splitTasks, SplitFetcher splitFetcher, SplitCacheProducer splitCacheProducer, SplitAPI splitAPI, SegmentCacheProducer segmentCacheProducer, SDKReadinessGates gates, TelemetryRuntimeProducer telemetryRuntimeProducer, TelemetrySynchronizer telemetrySynchronizer, SplitClientConfig config) -
Uses of TelemetryRuntimeProducer in io.split.engine.experiments
Constructors in io.split.engine.experiments with parameters of type TelemetryRuntimeProducer Constructor Description SplitFetcherImp(SplitChangeFetcher splitChangeFetcher, SplitParser parser, SplitCacheConsumer splitCacheConsumer, SplitCacheProducer splitCacheProducer, TelemetryRuntimeProducer telemetryRuntimeProducer)Contains all the traffic types that are currently being used by the splits and also the count For example if there are three splits, one of traffic type "account" and two of traffic type "user", this multiset will contain [{"user", 2}, {"account", 1}] The count is used to maintain how many splits are using a traffic type, so when an ARCHIVED split is received, we know if we need to remove a traffic type from the multiset. -
Uses of TelemetryRuntimeProducer in io.split.engine.segments
Constructors in io.split.engine.segments with parameters of type TelemetryRuntimeProducer Constructor Description SegmentFetcherImp(String segmentName, SegmentChangeFetcher segmentChangeFetcher, SegmentCacheProducer segmentCacheProducer, TelemetryRuntimeProducer telemetryRuntimeProducer)SegmentSynchronizationTaskImp(SegmentChangeFetcher segmentChangeFetcher, long refreshEveryNSeconds, int numThreads, SegmentCacheProducer segmentCacheProducer, TelemetryRuntimeProducer telemetryRuntimeProducer, SplitCacheConsumer splitCacheConsumer, ThreadFactory threadFactory) -
Uses of TelemetryRuntimeProducer in io.split.engine.sse
Methods in io.split.engine.sse with parameters of type TelemetryRuntimeProducer Modifier and Type Method Description static EventSourceClientImpEventSourceClientImp. build(String baseStreamingUrl, SplitsWorker splitsWorker, Worker<SegmentQueueDto> segmentWorker, PushStatusTracker pushStatusTracker, org.apache.hc.client5.http.impl.classic.CloseableHttpClient sseHttpClient, TelemetryRuntimeProducer telemetryRuntimeProducer, ThreadFactory threadFactory)Constructors in io.split.engine.sse with parameters of type TelemetryRuntimeProducer Constructor Description AuthApiClientImp(String url, org.apache.hc.client5.http.impl.classic.CloseableHttpClient httpClient, TelemetryRuntimeProducer telemetryRuntimeProducer)PushStatusTrackerImp(LinkedBlockingQueue<PushManager.Status> statusMessages, TelemetryRuntimeProducer telemetryRuntimeProducer) -
Uses of TelemetryRuntimeProducer in io.split.engine.sse.client
Constructors in io.split.engine.sse.client with parameters of type TelemetryRuntimeProducer Constructor Description SSEClient(Function<RawEvent,Void> eventCallback, Function<SSEClient.StatusMessage,Void> statusCallback, org.apache.hc.client5.http.impl.classic.CloseableHttpClient client, TelemetryRuntimeProducer telemetryRuntimeProducer, ThreadFactory threadFactory) -
Uses of TelemetryRuntimeProducer in io.split.service
Constructors in io.split.service with parameters of type TelemetryRuntimeProducer Constructor Description HttpPostImp(org.apache.hc.client5.http.impl.classic.CloseableHttpClient client, TelemetryRuntimeProducer telemetryRuntimeProducer) -
Uses of TelemetryRuntimeProducer in io.split.storages.pluggable.adapters
Classes in io.split.storages.pluggable.adapters that implement TelemetryRuntimeProducer Modifier and Type Class Description classUserCustomTelemetryAdapterProducer -
Uses of TelemetryRuntimeProducer in io.split.telemetry.storage
Subinterfaces of TelemetryRuntimeProducer in io.split.telemetry.storage Modifier and Type Interface Description interfaceTelemetryStorageinterfaceTelemetryStorageProducerClasses in io.split.telemetry.storage that implement TelemetryRuntimeProducer Modifier and Type Class Description classInMemoryTelemetryStorageclassNoopTelemetryStorage -
Uses of TelemetryRuntimeProducer in io.split.telemetry.synchronizer
Methods in io.split.telemetry.synchronizer with parameters of type TelemetryRuntimeProducer Modifier and Type Method Description static HttpTelemetryMemorySenderHttpTelemetryMemorySender. create(org.apache.hc.client5.http.impl.classic.CloseableHttpClient client, URI telemetryRootEndpoint, TelemetryRuntimeProducer telemetryRuntimeProducer)Constructors in io.split.telemetry.synchronizer with parameters of type TelemetryRuntimeProducer Constructor Description TelemetryInMemorySubmitter(org.apache.hc.client5.http.impl.classic.CloseableHttpClient client, URI telemetryRootEndpoint, TelemetryStorageConsumer telemetryStorageConsumer, SplitCacheConsumer splitCacheConsumer, SegmentCacheConsumer segmentCacheConsumer, TelemetryRuntimeProducer telemetryRuntimeProducer, long initStartTime)
-