Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

synchronizer

package

Go to main page

Versions in this module

v3

v3.1.0

Apr 14, 2021

v3.0.2-rc2

Sep 20, 2021

v3.0.2-rc1

Sep 17, 2021

v3.0.1

Jun 28, 2021

v3.0.0

Feb 25, 2021

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) StartPeriodicDataRecording()

+ func (s *Local) StartPeriodicFetching()

+ func (s *Local) StopPeriodicDataRecording()

+ func (s *Local) StopPeriodicFetching()

+ func (s *Local) SyncAll(requestNoCache bool) error

+ func (s *Local) SynchronizeSegment(name string, till *int64, _ bool) error

+ func (s *Local) SynchronizeSplits(till *int64, requestNoCache bool) error

+ type Manager interface

+ IsRunning func() bool

+ Start func()

+ Stop func()

+ 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 SplitTasks struct

+ EventSyncTask tasks.Task

+ ImpressionSyncTask tasks.Task

+ ImpressionsCountSyncTask *asynctask.AsyncTask

+ SegmentSyncTask *asynctask.AsyncTask

+ SplitSyncTask *asynctask.AsyncTask

+ TelemetrySyncTask *asynctask.AsyncTask

+ type Synchronizer interface

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

+ StartPeriodicDataRecording func()

+ StartPeriodicFetching func()

+ StopPeriodicDataRecording func()

+ StopPeriodicFetching func()

+ SyncAll func(requestNoCache bool) error

+ SynchronizeSegment func(segmentName string, till *int64, requestNoCache bool) error

+ SynchronizeSplits func(till *int64, requestNoCache bool) error

+ func NewLocal(period int, splitAPI *service.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) StartPeriodicDataRecording()

+ func (s *SynchronizerImpl) StartPeriodicFetching()

+ func (s *SynchronizerImpl) StopPeriodicDataRecording()

+ func (s *SynchronizerImpl) StopPeriodicFetching()

+ func (s *SynchronizerImpl) SyncAll(requestNoCache bool) error

+ func (s *SynchronizerImpl) SynchronizeSegment(name string, till *int64, requstNoCache bool) error

+ func (s *SynchronizerImpl) SynchronizeSplits(till *int64, requstNoCache bool) error

+ type Workers struct

+ EventRecorder event.EventRecorder

+ ImpressionRecorder impression.ImpressionRecorder

+ ImpressionsCountRecorder impressionscount.ImpressionsCountRecorder

+ SegmentFetcher segment.Updater

+ SplitFetcher split.Updater

+ TelemetryRecorder metric.MetricRecorder

Other modules containing this package

github.com/splitio/go-split-commons/v2

github.com/splitio/go-split-commons/v4

github.com/splitio/go-split-commons/v5

github.com/splitio/go-split-commons/v6