scheduler

Mar 2, 2021

Changes in this version

type InitiableScheduler

+ BootChannelManager func(ctx context.Context)

+ BootCluster func(ctx context.Context)

+ BootHttpServer func(ctx context.Context)

+ BootRaftManager func(ctx context.Context)

type Scheduler

+ func (s *Scheduler) BootChannelManager(ctx context.Context)

+ func (s *Scheduler) BootHttpServer(ctx context.Context)

+ func (s *Scheduler) BootRaftManager(ctx context.Context)

+ func (s *Scheduler) GetDispatcher() *dispatcher.Dispatcher

Feb 8, 2021

Changes in this version

type Scheduler

+ func (s *Scheduler) BootCluster(ctx context.Context)

+ func (s *Scheduler) ClusterLeaderChangeCallback(ctx context.Context, isLeader bool)

+ func (s *Scheduler) GetCluster() *raft.Raft

+ func (s *Scheduler) GetListener() *listener.Listener

+ func (s *Scheduler) WatchCluster(ctx context.Context)

Jan 22, 2021

Changes in this version

+ type InitiableScheduler interface

+ BootListener func(ctx context.Context)

+ BootPrioritizer func(ctx context.Context)

+ BootProcessor func(ctx context.Context)

+ BootPublisher func(ctx context.Context)

Dec 31, 2020

Changes in this version

+ type BootableScheduler interface

+ BootListener func()

+ BootPrioritizer func()

+ BootProcessor func()

+ BootPublisher func()

+ type Scheduler struct

+ func NewScheduler(config config.Config) *Scheduler

+ func (s *Scheduler) BootListener(ctx context.Context)

+ func (s *Scheduler) BootPrioritizer(ctx context.Context)

+ func (s *Scheduler) BootProcessor(ctx context.Context)

+ func (s *Scheduler) BootPublisher(ctx context.Context)

+ func (s *Scheduler) GetConfig() config.Config

+ func (s *Scheduler) GetDataStorage() *storage.PqStorage

+ func (s *Scheduler) GetInboundPool() *goconcurrentqueue.FIFO

+ func (s *Scheduler) GetOutboundPool() *goconcurrentqueue.FIFO

+ func (s *Scheduler) GetPublisher() *publisher.Publisher

+ func (s *Scheduler) Run(ctx context.Context) error

+ type StartableScheduler interface

+ Run func() error