scheduler

Documentation

Index

• type InitiableScheduler
• type Scheduler
  • func NewScheduler(ctx context.Context, config config.Config) *Scheduler
  • func (s *Scheduler) BootChannelManager(ctx context.Context)
  • func (s *Scheduler) BootCluster(ctx context.Context)
  • func (s *Scheduler) BootHttpServer(ctx context.Context)
  • func (s *Scheduler) BootListener(ctx context.Context, channel channel.Channel) error
  • func (s *Scheduler) BootPrioritizer(ctx context.Context)
  • func (s *Scheduler) BootProcessor(ctx context.Context, channel channel.Channel)
  • func (s *Scheduler) BootRaftManager(ctx context.Context)
  • func (s *Scheduler) GetCluster() *raft.Raft
  • func (s *Scheduler) GetConfig() config.Config
  • func (s *Scheduler) GetDataStorage() *storage.PqStorage
  • func (s *Scheduler) GetDispatcher() *dispatcher.Dispatcher
  • func (s *Scheduler) GetOutboundPool() *goconcurrentqueue.FIFO
  • func (s *Scheduler) Run(ctx context.Context) error
  • func (s *Scheduler) WatchCluster(ctx context.Context)
• type StartableScheduler

Types

type InitiableScheduler

type InitiableScheduler interface {
	BootHttpServer(ctx context.Context)
	BootCluster(ctx context.Context)
	BootProcessor(ctx context.Context, c channel.Channel)
	BootPrioritizer(ctx context.Context)
	BootListener(ctx context.Context, c channel.Channel) error
	BootRaftManager(ctx context.Context)
	BootChannelManager(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) BootChannelManager

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

func (*Scheduler) BootCluster

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

func (*Scheduler) BootHttpServer

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

func (*Scheduler) BootListener

func (s *Scheduler) BootListener(ctx context.Context, channel channel.Channel) error

func (*Scheduler) BootPrioritizer

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

func (*Scheduler) BootProcessor

func (s *Scheduler) BootProcessor(ctx context.Context, channel channel.Channel)

func (*Scheduler) BootRaftManager

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

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) GetDispatcher

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

func (*Scheduler) GetOutboundPool

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

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
}