Versions in this module Expand all Collapse all v8 v8.0.0 Nov 10, 2025 Changes in this version + type DataDropper interface + Drop func(size int64) error + type EventMultiSdkConsumer interface + Count func() int64 + PopNRaw func(int64) ([]string, int64, error) + PopNWithMetadata func(n int64) ([]dtos.QueueStoredEventDTO, error) + type EventStorageConsumer interface + Empty func() bool + PopN func(n int64) ([]dtos.EventDTO, error) + type EventStorageProducer interface + Push func(event dtos.EventDTO, size int) error + type EventsStorage interface + type Filter interface + Add func(data string) + Clear func() + Contains func(data string) bool + type ImpressionMultiSdkConsumer interface + Count func() int64 + PopNRaw func(int64) ([]string, int64, error) + PopNWithMetadata func(n int64) ([]dtos.ImpressionQueueObject, error) + type ImpressionStorage interface + type ImpressionStorageConsumer interface + Empty func() bool + PopN func(n int64) ([]dtos.Impression, error) + type ImpressionStorageProducer interface + LogImpressions func(impressions []dtos.Impression) error + type ImpressionsCountConsumer interface + GetImpressionsCount func() (*dtos.ImpressionsCountDTO, error) + type ImpressionsCountProducer interface + RecordImpressionsCount func(impressions dtos.ImpressionsCountDTO) error + type ImpressionsCountStorage interface + type LargeSegmentStorageConsumer interface + ChangeNumber func(name string) int64 + Count func() int + IsInLargeSegment func(name string, key string) (bool, error) + LargeSegmentsForUser func(userKey string) []string + TotalKeys func(name string) int + type LargeSegmentStorageProducer interface + SetChangeNumber func(name string, till int64) + Update func(name string, userKeys []string, till int64) + type LargeSegmentsStorage interface + type RuleBasedSegmentStorageConsumer interface + All func() []dtos.RuleBasedSegmentDTO + ChangeNumber func() (int64, error) + Contains func(ruleBasedSegmentNames []string) bool + FetchMany func(rbsNames []string) map[string]*dtos.RuleBasedSegmentDTO + GetRuleBasedSegmentByName func(name string) (*dtos.RuleBasedSegmentDTO, error) + LargeSegments func() *set.ThreadUnsafeSet + RuleBasedSegmentNames func() ([]string, error) + Segments func() *set.ThreadUnsafeSet + type RuleBasedSegmentStorageProducer interface + ReplaceAll func(toAdd []dtos.RuleBasedSegmentDTO, changeNumber int64) error + SetChangeNumber func(till int64) error + Update func(toAdd []dtos.RuleBasedSegmentDTO, toRemove []dtos.RuleBasedSegmentDTO, ...) error + type RuleBasedSegmentsStorage interface + type SegmentStorage interface + type SegmentStorageConsumer interface + ChangeNumber func(segmentName string) (int64, error) + Keys func(segmentName string) *set.ThreadUnsafeSet + SegmentContainsKey func(segmentName string, key string) (bool, error) + SegmentKeysCount func() int64 + type SegmentStorageProducer interface + SetChangeNumber func(segmentName string, till int64) error + Update func(name string, toAdd *set.ThreadUnsafeSet, toRemove *set.ThreadUnsafeSet, ...) error + type SplitStorage interface + All func() []dtos.SplitDTO + ChangeNumber func() (int64, error) + FetchMany func(splitNames []string) map[string]*dtos.SplitDTO + GetAllFlagSetNames func() []string + GetNamesByFlagSets func(sets []string) map[string][]string + KillLocally func(splitName string, defaultTreatment string, changeNumber int64) + LargeSegmentNames func() *set.ThreadUnsafeSet + ReplaceAll func(toAdd []dtos.SplitDTO, changeNumber int64) error + RuleBasedSegmentNames func() *set.ThreadUnsafeSet + SegmentNames func() *set.ThreadUnsafeSet + SetChangeNumber func(changeNumber int64) error + Split func(splitName string) *dtos.SplitDTO + SplitNames func() []string + TrafficTypeExists func(trafficType string) bool + Update func(toAdd []dtos.SplitDTO, toRemove []dtos.SplitDTO, changeNumber int64) + type SplitStorageConsumer interface + All func() []dtos.SplitDTO + ChangeNumber func() (int64, error) + FetchMany func(splitNames []string) map[string]*dtos.SplitDTO + GetAllFlagSetNames func() []string + GetNamesByFlagSets func(sets []string) map[string][]string + LargeSegmentNames func() *set.ThreadUnsafeSet + RuleBasedSegmentNames func() *set.ThreadUnsafeSet + SegmentNames func() *set.ThreadUnsafeSet + Split func(splitName string) *dtos.SplitDTO + SplitNames func() []string + TrafficTypeExists func(trafficType string) bool + type SplitStorageProducer interface + ChangeNumber func() (int64, error) + KillLocally func(splitName string, defaultTreatment string, changeNumber int64) + ReplaceAll func(toAdd []dtos.SplitDTO, changeNumber int64) error + SetChangeNumber func(changeNumber int64) error + Update func(toAdd []dtos.SplitDTO, toRemove []dtos.SplitDTO, changeNumber int64) + type TelemetryConfigConsumer interface + GetBURTimeouts func() int64 + GetNonReadyUsages func() int64 + type TelemetryConfigProducer interface + RecordBURTimeout func() + RecordConfigData func(configData dtos.Config) error + RecordNonReadyUsage func() + RecordUniqueKeys func(uniques dtos.Uniques) error + type TelemetryEvaluationConsumer interface + PopExceptions func() dtos.MethodExceptions + PopLatencies func() dtos.MethodLatencies + type TelemetryEvaluationProducer interface + RecordException func(method string) + RecordLatency func(method string, latency time.Duration) + type TelemetryPeeker interface + PeekHTTPErrors func(resource int) map[int]int + PeekHTTPLatencies func(resource int) []int64 + type TelemetryRedisProducer interface + type TelemetryRuntimeConsumer interface + GetEventsStats func(dataType int) int64 + GetImpressionsStats func(dataType int) int64 + GetLastSynchronization func() dtos.LastSynchronization + GetSessionLength func() int64 + PopAuthRejections func() int64 + PopHTTPErrors func() dtos.HTTPErrors + PopHTTPLatencies func() dtos.HTTPLatencies + PopStreamingEvents func() []dtos.StreamingEvent + PopTags func() []string + PopTokenRefreshes func() int64 + PopUpdatesFromSSE func() dtos.UpdatesFromSSE + type TelemetryRuntimeProducer interface + AddTag func(tag string) + RecordAuthRejections func() + RecordEventsStats func(dataType int, count int64) + RecordImpressionsStats func(dataType int, count int64) + RecordSessionLength func(session int64) + RecordStreamingEvent func(streamingEvent *dtos.StreamingEvent) + RecordSuccessfulSync func(resource int, when time.Time) + RecordSyncError func(resource int, status int) + RecordSyncLatency func(resource int, latency time.Duration) + RecordTokenRefreshes func() + RecordUpdatesFromSSE func(updateType int) + type TelemetryStorage interface + type TelemetryStorageConsumer interface + type TelemetryStorageProducer interface + type UniqueKeysMultiSdkConsumer interface + Count func() int64 + PopNRaw func(int64) ([]string, int64, error) Other modules containing this package github.com/splitio/go-split-commons/v2 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/v7
Go to main page