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

v2

v2.0.1

Dec 22, 2020

v2.0.0

Oct 6, 2020

Changes in this version

+ const Error

+ const Idle

+ const Polling

+ const Ready

+ const Streaming

+ const StreamingReady

+ type Local struct

+ func (s *Local) StartPeriodicDataRecording()

+ func (s *Local) StartPeriodicFetching()

+ func (s *Local) StopPeriodicDataRecording()

+ func (s *Local) StopPeriodicFetching()

+ func (s *Local) SyncAll() error

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

+ func (s *Local) SynchronizeSplits(till *int64) error

+ type Manager struct

+ func NewSynchronizerManager(synchronizer Synchronizer, logger logging.LoggerInterface, ...) (*Manager, error)

+ func (s *Manager) IsRunning() bool

+ func (s *Manager) Start()

+ func (s *Manager) 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

+ StartPeriodicDataRecording func()

+ StartPeriodicFetching func()

+ StopPeriodicDataRecording func()

+ StopPeriodicFetching func()

+ SyncAll func() error

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

+ SynchronizeSplits func(till *int64) 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) StartPeriodicDataRecording()

+ func (s *SynchronizerImpl) StartPeriodicFetching()

+ func (s *SynchronizerImpl) StopPeriodicDataRecording()

+ func (s *SynchronizerImpl) StopPeriodicFetching()

+ func (s *SynchronizerImpl) SyncAll() error

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

+ func (s *SynchronizerImpl) SynchronizeSplits(till *int64) error

+ type Workers struct

+ EventRecorder event.EventRecorder

+ ImpressionRecorder impression.ImpressionRecorder

+ ImpressionsCountRecorder impressionscount.ImpressionsCountRecorder

+ SegmentFetcher segment.SegmentFetcher

+ SplitFetcher split.SplitFetcher

+ TelemetryRecorder metric.MetricRecorder

v2.0.0-rc1

Sep 21, 2020

Other modules containing this package

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