scheduler

Documentation

Index

• type InitiableScheduler
• type Scheduler
  • func NewScheduler(ctx context.Context, config config.Config) *Scheduler
  • func (s *Scheduler) BootCluster(ctx context.Context)
  • 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) ClusterLeaderChangeCallback(ctx context.Context, isLeader bool)
  • func (s *Scheduler) GetCluster() *raft.Raft
  • func (s *Scheduler) GetConfig() config.Config
  • func (s *Scheduler) GetDataStorage() *storage.PqStorage
  • func (s *Scheduler) GetListener() *listener.Listener
  • func (s *Scheduler) GetOutboundPool() *goconcurrentqueue.FIFO
  • func (s *Scheduler) GetPublisher() *publisher.Publisher
  • func (s *Scheduler) Run(ctx context.Context) error
  • func (s *Scheduler) WatchCluster(ctx context.Context)
• type StartableScheduler

Types

type InitiableScheduler

type InitiableScheduler interface {
	BootProcessor(ctx context.Context)
	BootPrioritizer(ctx context.Context)
	BootListener(ctx context.Context)
	BootPublisher(ctx context.Context)
}

type Scheduler

type Scheduler struct {
	// contains filtered or unexported fields
}

func NewScheduler

func NewScheduler(ctx context.Context, config config.Config) *Scheduler

func (*Scheduler) BootCluster

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

func (*Scheduler) BootListener

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

func (*Scheduler) BootPrioritizer

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

func (*Scheduler) BootProcessor

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

func (*Scheduler) BootPublisher

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

func (*Scheduler) ClusterLeaderChangeCallback

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

func (*Scheduler) GetCluster

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

func (*Scheduler) GetConfig

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

func (*Scheduler) GetDataStorage

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

func (*Scheduler) GetListener

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

func (*Scheduler) GetOutboundPool

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

func (*Scheduler) GetPublisher

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

func (*Scheduler) Run

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

func (*Scheduler) WatchCluster

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

type StartableScheduler

type StartableScheduler interface {
	Run(ctx context.Context) error
}