storage

package

Go to main page

Versions in this module

v5

v5.2.1

Jan 25, 2024

v5.2.0

Jan 10, 2024

retracted

Changes in this version

type SplitStorage

+ GetAllFlagSetNames func() []string

type SplitStorageConsumer

+ GetAllFlagSetNames func() []string

v5.1.1

Dec 21, 2023

v5.1.0

Nov 29, 2023

Changes in this version

type SplitStorage

+ GetNamesByFlagSets func(sets []string) map[string][]string

type SplitStorageConsumer

+ GetNamesByFlagSets func(sets []string) map[string][]string

v5.0.0

Jul 18, 2023

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 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

+ KillLocally func(splitName string, defaultTreatment string, changeNumber int64)

+ 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

+ 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)

+ 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/v6

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL