synchronizer

package

Go to main page

Versions in this module

v6

v6.1.0

Jan 14, 2025

v6.0.2

Dec 2, 2024

Changes in this version

type Local

+ func (s *Local) SynchronizeLargeSegment(name string, till *int64) error

+ func (s *Local) SynchronizeLargeSegmentUpdate(lsRFDResponseDTO *dtos.LargeSegmentRFDResponseDTO) error

type SplitTasks

+ LargeSegmentSyncTask *asynctask.AsyncTask

type Synchronizer

+ SynchronizeLargeSegment func(name string, till *int64) error

+ SynchronizeLargeSegmentUpdate func(lsRFDResponseDTO *dtos.LargeSegmentRFDResponseDTO) error

type SynchronizerImpl

+ func (s *SynchronizerImpl) SynchronizeLargeSegment(name string, till *int64) error

+ func (s *SynchronizerImpl) SynchronizeLargeSegmentUpdate(lsRFDResponseDTO *dtos.LargeSegmentRFDResponseDTO) error

type Workers

+ LargeSegmentUpdater largesegment.Updater

v6.0.1

Sep 12, 2024

v6.0.0

May 14, 2024

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) SynchronizeSegment(name string, till *int64) error

+ type LocalConfig struct

+ FlagSets []string

+ QueueSize int

+ RefreshEnabled bool

+ SegmentDirectory string

+ SegmentPeriod int

+ SegmentWorkers int

+ SplitPeriod int

+ type Manager interface

+ IsRunning func() bool

+ Start func()

+ Stop func()

+ func NewSynchronizerManagerRedis(synchronizer Synchronizer, logger logging.LoggerInterface) Manager

+ type ManagerImpl struct

+ func NewSynchronizerManager(synchronizer Synchronizer, logger logging.LoggerInterface, ...) (*ManagerImpl, 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) Stop()

+ type SplitTasks struct

+ CleanFilterTask tasks.Task

+ EventSyncTask tasks.Task

+ ImpressionSyncTask tasks.Task

+ ImpressionsCountSyncTask tasks.Task

+ ImpsCountConsumerTask tasks.Task

+ 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

+ 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) SynchronizeSegment(name string, till *int64) error

+ type Workers struct

+ EventRecorder event.EventRecorder

+ ImpressionRecorder impression.ImpressionRecorder

+ ImpressionsCountRecorder impressionscount.ImpressionsCountRecorder

+ 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

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