Version: v1.5.2 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Mar 9, 2021 License: MIT Imports: 34 Imported by: 0




This section is empty.


This section is empty.


This section is empty.


type InitiableScheduler added in v1.1.0

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 added in v1.5.0

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

func (*Scheduler) BootCluster added in v1.3.0

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

func (*Scheduler) BootHttpServer added in v1.5.0

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 added in v1.5.0

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

func (*Scheduler) GetCluster added in v1.3.0

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 added in v1.5.0

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 added in v1.3.0

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

type StartableScheduler

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

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL