Versions in this module Expand all Collapse all v7 v7.0.0 Sep 26, 2025 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 ImpressionsModeNone + const ImpressionsModeOptimized + const ImpressionsQueued + const LatencyBucketCount + const MaxStreamingEvents + const MaxTags + const Memory + const NonRequested + const Polling + const Producer + const Redis + const Requested + const SegmentSync + const SplitSync + const SplitUpdate + const Standalone + const Streaming + const StreamingDisabled + const StreamingEnabled + const StreamingPaused + const TelemetrySync + const TokenSync + const Track + const Treatment + const TreatmentWithConfig + const Treatments + const TreatmentsByFlagSet + const TreatmentsByFlagSets + const TreatmentsWithConfig + const TreatmentsWithConfigByFlagSet + const TreatmentsWithConfigByFlagSets + func Bucket(latency int64) int + func GetStreamingEvent(eventType int, data int64) *dtos.StreamingEvent + func IsMethodValid(method *string) bool + func ParseMethodFromRedisHash(method string) (normalized string, ok bool) + type InitConfig struct + AdvancedConfig conf.AdvancedConfig + FlagSetsInvalid int64 + FlagSetsTotal int64 + ImpressionsMode string + ListenerEnabled bool + TaskPeriods conf.TaskPeriods + type NoOp struct + func (n *NoOp) SynchronizeConfig(cfg InitConfig, timedUntilReady int64, factoryInstances map[string]int64, ...) + func (n *NoOp) SynchronizeStats() error + func (n *NoOp) SynchronizeUniqueKeys(uniques dtos.Uniques) error + type RecorderSingle struct + func (e *RecorderSingle) SynchronizeConfig(cfg InitConfig, timedUntilReady int64, factoryInstances map[string]int64, ...) + func (e *RecorderSingle) SynchronizeStats() error + func (e *RecorderSingle) SynchronizeUniqueKeys(uniques dtos.Uniques) error + type SynchronizerRedis struct + func (r *SynchronizerRedis) SynchronizeConfig(cfg InitConfig, timedUntilReady int64, factoryInstances map[string]int64, ...) + func (r *SynchronizerRedis) SynchronizeStats() error + func (r *SynchronizerRedis) SynchronizeUniqueKeys(uniques dtos.Uniques) error + type TelemetrySynchronizer interface + SynchronizeConfig func(cfg InitConfig, timedUntilReady int64, factoryInstances map[string]int64, ...) + SynchronizeStats func() error + SynchronizeUniqueKeys func(uniques dtos.Uniques) 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/v3 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/v8
Go to main page