Versions in this module Expand all Collapse all v3 v3.1.0 Apr 14, 2021 Changes in this version + const Consumer + const EventSync + const EventTypeAblyError + const EventTypeConnectionError + const EventTypeOccupancyPri + const EventTypeOccupancySec + const EventTypeSSEConnectionEstablished + const EventTypeStreamingStatus + const EventTypeSyncMode + const EventTypeTokenRefresh + const EventsDropped + const EventsQueued + const ImpressionCountSync + const ImpressionSync + const ImpressionsDeduped + const ImpressionsDropped + const ImpressionsModeDebug + const ImpressionsModeOptimized + const ImpressionsQueued + const LatencyBucketCount + const MaxStreamingEvents + const MaxTags + const Memory + const NonRequested + const Polling + const Redis + const Requested + const SegmentSync + const SplitSync + const Standalone + const Streaming + const StreamingDisabled + const StreamingEnabled + const StreamingPaused + const TelemetrySync + const TokenSync + const Track + const Treatment + const TreatmentWithConfig + const Treatments + const TreatmentsWithConfig + func Bucket(latency int64) int + func GetStreamingEvent(eventType int, data int64) *dtos.StreamingEvent + type InitConfig struct + AdvancedConfig conf.AdvancedConfig + ManagerConfig conf.ManagerConfig + TaskPeriods conf.TaskPeriods + type RecorderSingle struct + func (e *RecorderSingle) SynchronizeConfig(cfg InitConfig, timedUntilReady int64, factoryInstances map[string]int64, ...) + func (e *RecorderSingle) SynchronizeStats() error + type SynchronizerRedis struct + func (r *SynchronizerRedis) SynchronizeConfig(cfg InitConfig, timedUntilReady int64, factoryInstances map[string]int64, ...) + func (r *SynchronizerRedis) SynchronizeStats() error + type TelemetrySynchronizer interface + SynchronizeConfig func(cfg InitConfig, timedUntilReady int64, factoryInstances map[string]int64, ...) + SynchronizeStats func() error + func NewSynchronizerRedis(storage storage.TelemetryConfigProducer, logger logging.LoggerInterface) TelemetrySynchronizer + func NewTelemetrySynchronizer(telemetryStorage storage.TelemetryStorageConsumer, ...) TelemetrySynchronizer Other modules containing this package github.com/splitio/go-split-commons/v4 github.com/splitio/go-split-commons/v5 github.com/splitio/go-split-commons/v6 github.com/splitio/go-split-commons/v7 github.com/splitio/go-split-commons/v8
Go to main page