Versions in this module Expand all Collapse all v8 v8.0.0 Nov 10, 2025 Changes in this version + const StatusDown + const StatusNonRetryableError + const StatusRetryableError + const StatusUp + var ErrAlreadyRunning = errors.New("push manager already running") + var ErrEmptyEvent = errors.New("empty incoming event") + var ErrNotRunning = errors.New("push manager not running") + type DataUtils interface + Decode func(data string) ([]byte, error) + Decompress func(data []byte, compressType int) ([]byte, error) + func NewDataUtilsImpl() DataUtils + type DataUtilsImpl struct + func (d *DataUtilsImpl) Decode(data string) ([]byte, error) + func (d *DataUtilsImpl) Decompress(data []byte, compressType int) ([]byte, error) + type FeedbackLoop = chan<- int64 + type LargeSegment struct + type LargeSegmentUpdateWorker struct + func NewLargeSegmentUpdateWorker(lsQueue chan dtos.LargeSegmentChangeUpdate, synchronizer synchronizerInterface, ...) (*LargeSegmentUpdateWorker, error) + func (s *LargeSegmentUpdateWorker) IsRunning() bool + func (s *LargeSegmentUpdateWorker) Start() + func (s *LargeSegmentUpdateWorker) Stop() + type Manager interface + NextRefresh func() time.Time + Start func() error + StartWorkers func() + Stop func() error + StopWorkers func() + type ManagerImpl struct + func NewManager(logger logging.LoggerInterface, synchronizer synchronizerInterface, ...) (*ManagerImpl, error) + func (m *ManagerImpl) NextRefresh() time.Time + func (m *ManagerImpl) Start() error + func (m *ManagerImpl) StartWorkers() + func (m *ManagerImpl) Stop() error + func (m *ManagerImpl) StopWorkers() + type NotificationParser interface + ParseAndForward func(sse.IncomingMessage) (*int64, error) + type NotificationParserImpl struct + func NewNotificationParserImpl(loggerInterface logging.LoggerInterface, ...) *NotificationParserImpl + func (p *NotificationParserImpl) ParseAndForward(raw sse.IncomingMessage) (*int64, error) + type Processor interface + ProcessLargeSegmentChangeUpdate func(update *dtos.LargeSegmentChangeUpdate) error + ProcessSegmentChangeUpdate func(update *dtos.SegmentChangeUpdate) error + ProcessSplitChangeUpdate func(update *dtos.SplitChangeUpdate) error + ProcessSplitKillUpdate func(update *dtos.SplitKillUpdate) error + StartWorkers func() + StopWorkers func() + type ProcessorImpl struct + func NewProcessor(splitQueueSize int64, segmentQueueSize int64, ...) (*ProcessorImpl, error) + func (p *ProcessorImpl) ProcessLargeSegmentChangeUpdate(update *dtos.LargeSegmentChangeUpdate) error + func (p *ProcessorImpl) ProcessSegmentChangeUpdate(update *dtos.SegmentChangeUpdate) error + func (p *ProcessorImpl) ProcessSplitChangeUpdate(update *dtos.SplitChangeUpdate) error + func (p *ProcessorImpl) ProcessSplitKillUpdate(update *dtos.SplitKillUpdate) error + func (p *ProcessorImpl) StartWorkers() + func (p *ProcessorImpl) StopWorkers() + type SegmentUpdateWorker struct + func NewSegmentUpdateWorker(segmentQueue chan dtos.SegmentChangeUpdate, synchronizer synchronizerInterface, ...) (*SegmentUpdateWorker, error) + func (s *SegmentUpdateWorker) IsRunning() bool + func (s *SegmentUpdateWorker) Start() + func (s *SegmentUpdateWorker) Stop() + type SplitUpdateWorker struct + func NewSplitUpdateWorker(splitQueue chan dtos.SplitChangeUpdate, synchronizer synchronizerInterface, ...) (*SplitUpdateWorker, error) + func (s *SplitUpdateWorker) IsRunning() bool + func (s *SplitUpdateWorker) Start() + func (s *SplitUpdateWorker) Stop() + type StatusTracker interface + HandleAblyError func(*dtos.AblyError) *int64 + HandleControl func(*dtos.ControlUpdate) *int64 + HandleDisconnection func() *int64 + HandleOccupancy func(*dtos.OccupancyMessage) *int64 + NotifySSEShutdownExpected func() + Reset func() + type StatusTrackerImpl struct + func NewStatusTracker(logger logging.LoggerInterface, ...) *StatusTrackerImpl + func (p *StatusTrackerImpl) HandleAblyError(errorEvent *dtos.AblyError) (newStatus *int64) + func (p *StatusTrackerImpl) HandleControl(controlUpdate *dtos.ControlUpdate) *int64 + func (p *StatusTrackerImpl) HandleDisconnection() *int64 + func (p *StatusTrackerImpl) HandleOccupancy(message *dtos.OccupancyMessage) (newStatus *int64) + func (p *StatusTrackerImpl) NotifySSEShutdownExpected() + func (p *StatusTrackerImpl) Reset() 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