Versions in this module Expand all Collapse all v8 v8.0.0 Nov 10, 2025 Changes in this version + const Error + const Polling + const Ready + const Streaming + const StreamingReady + type Local struct + func (s *Local) LocalKill(splitName string, defaultTreatment string, changeNumber int64) + func (s *Local) RefreshRates() (time.Duration, time.Duration) + func (s *Local) StartPeriodicDataRecording() + func (s *Local) StartPeriodicFetching() + func (s *Local) StopPeriodicDataRecording() + func (s *Local) StopPeriodicFetching() + func (s *Local) SyncAll() error + func (s *Local) SynchronizeFeatureFlags(ffChange *dtos.SplitChangeUpdate) error + func (s *Local) SynchronizeLargeSegment(name string, till *int64) error + func (s *Local) SynchronizeLargeSegmentUpdate(lsRFDResponseDTO *dtos.LargeSegmentRFDResponseDTO) error + func (s *Local) SynchronizeSegment(name string, till *int64) error + type LocalConfig struct + FfRulesAccepted []string + FlagSets []string + QueueSize int + RbRulesAccepted []string + RefreshEnabled bool + SegmentDirectory string + SegmentPeriod int + SegmentWorkers int + SplitPeriod int + type Manager interface + IsRunning func() bool + Start func() + StartBGSync func(status chan int, shouldRetry bool, onReady func()) error + Stop func() + func NewSynchronizerManagerRedis(synchronizer Synchronizer, logger logging.LoggerInterface) Manager + type ManagerImpl struct + func NewSynchronizerManager(synchronizer Synchronizer, logger logging.LoggerInterface, ...) (*ManagerImpl, error) + func (m *ManagerImpl) StartBGSync(status chan int, shouldRetry bool, onReady func()) error + func (s *ManagerImpl) IsRunning() bool + func (s *ManagerImpl) Start() + func (s *ManagerImpl) Stop() + type ManagerRedisImpl struct + func (m *ManagerRedisImpl) IsRunning() bool + func (m *ManagerRedisImpl) Start() + func (m *ManagerRedisImpl) StartBGSync(status chan int, shouldRetry bool, onReady func()) error + func (m *ManagerRedisImpl) Stop() + type SplitTasks struct + CleanFilterTask tasks.Task + EventSyncTask tasks.Task + ImpressionSyncTask tasks.Task + ImpressionsCountSyncTask tasks.Task + ImpsCountConsumerTask tasks.Task + LargeSegmentSyncTask *asynctask.AsyncTask + SegmentSyncTask *asynctask.AsyncTask + SplitSyncTask *asynctask.AsyncTask + TelemetrySyncTask tasks.Task + UniqueKeysTask tasks.Task + type Synchronizer interface + LocalKill func(splitName string, defaultTreatment string, changeNumber int64) + RefreshRates func() (splits time.Duration, segments time.Duration) + StartPeriodicDataRecording func() + StartPeriodicFetching func() + StopPeriodicDataRecording func() + StopPeriodicFetching func() + SyncAll func() error + SynchronizeFeatureFlags func(ffChange *dtos.SplitChangeUpdate) error + SynchronizeLargeSegment func(name string, till *int64) error + SynchronizeLargeSegmentUpdate func(lsRFDResponseDTO *dtos.LargeSegmentRFDResponseDTO) error + SynchronizeSegment func(segmentName string, till *int64) error + func NewLocal(cfg *LocalConfig, splitAPI *api.SplitAPI, splitStorage storage.SplitStorage, ...) Synchronizer + func NewSynchronizer(confAdvanced conf.AdvancedConfig, splitTasks SplitTasks, workers Workers, ...) Synchronizer + type SynchronizerImpl struct + func (s *SynchronizerImpl) LocalKill(splitName string, defaultTreatment string, changeNumber int64) + func (s *SynchronizerImpl) RefreshRates() (splits time.Duration, segments time.Duration) + func (s *SynchronizerImpl) StartPeriodicDataRecording() + func (s *SynchronizerImpl) StartPeriodicFetching() + func (s *SynchronizerImpl) StopPeriodicDataRecording() + func (s *SynchronizerImpl) StopPeriodicFetching() + func (s *SynchronizerImpl) SyncAll() error + func (s *SynchronizerImpl) SynchronizeFeatureFlags(ffChange *dtos.SplitChangeUpdate) error + func (s *SynchronizerImpl) SynchronizeLargeSegment(name string, till *int64) error + func (s *SynchronizerImpl) SynchronizeLargeSegmentUpdate(lsRFDResponseDTO *dtos.LargeSegmentRFDResponseDTO) error + func (s *SynchronizerImpl) SynchronizeSegment(name string, till *int64) error + type Workers struct + EventRecorder event.EventRecorder + ImpressionRecorder impression.ImpressionRecorder + ImpressionsCountRecorder impressionscount.ImpressionsCountRecorder + LargeSegmentUpdater largesegment.Updater + SegmentUpdater segment.Updater + SplitUpdater split.Updater + TelemetryRecorder telemetry.TelemetrySynchronizer 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