Versions in this module Expand all Collapse all v2 v2.0.1 Dec 22, 2020 Changes in this version type IncomingEvent + func (i *IncomingEvent) String() string v2.0.0 Oct 6, 2020 Changes in this version + const BackoffAuth + const BackoffSSE + const NonRetriableError + const PublisherAvailable + const PublisherNotPresent + const PushIsDown + const PushIsUp + const Ready + const Reconnect + const StreamingDisabled + const StreamingPaused + const StreamingResumed + const TokenExpiration + type EventHandler struct + func NewEventHandler(keeper *Keeper, parser *NotificationParser, processor *Processor, ...) *EventHandler + func (e *EventHandler) HandleIncomingMessage(event map[string]interface{}) + type IncomingEvent struct + type Keeper struct + func NewKeeper(publishers chan int) *Keeper + func (k *Keeper) LastNotification() (string, int64) + func (k *Keeper) Publishers(manager string) *int + func (k *Keeper) UpdateLastNotification(manager string, timestamp int64) + func (k *Keeper) UpdateManagers(manager string, publishers int) + type Manager interface + IsRunning func() bool + Start func() + StartWorkers func() + Stop func() + StopWorkers func() + func NewPushManager(logger logging.LoggerInterface, ...) (Manager, error) + type Metrics struct + Publishers int + type NotificationParser struct + func NewNotificationParser(logger logging.LoggerInterface) *NotificationParser + func (n *NotificationParser) Parse(event map[string]interface{}) IncomingEvent + type Occupancy struct + Data Metrics + type Processor struct + func NewProcessor(segmentQueue chan dtos.SegmentChangeNotification, ...) (*Processor, error) + func (p *Processor) Process(i dtos.IncomingNotification) error + type PushManager struct + func (p *PushManager) IsRunning() bool + func (p *PushManager) Start() + func (p *PushManager) StartWorkers() + func (p *PushManager) Stop() + func (p *PushManager) StopWorkers() + type SegmentUpdateWorker struct + func NewSegmentUpdateWorker(segmentQueue chan dtos.SegmentChangeNotification, ...) (*SegmentUpdateWorker, error) + func (s *SegmentUpdateWorker) IsRunning() bool + func (s *SegmentUpdateWorker) Start() + func (s *SegmentUpdateWorker) Stop() + type SplitUpdateWorker struct + func NewSplitUpdateWorker(splitQueue chan dtos.SplitChangeNotification, handler func(till *int64) error, ...) (*SplitUpdateWorker, error) + func (s *SplitUpdateWorker) IsRunning() bool + func (s *SplitUpdateWorker) Start() + func (s *SplitUpdateWorker) Stop() 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 github.com/splitio/go-split-commons/v7 github.com/splitio/go-split-commons/v8
Go to main page