scheduler

Documentation

Index

• type BootableScheduler
• type Scheduler
  • 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

Types

type BootableScheduler

type BootableScheduler interface {
	BootProcessor()
	BootPrioritizer()
	BootListener()
	BootPublisher()
}

type Scheduler

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

func NewScheduler

func NewScheduler(config config.Config) *Scheduler

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

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

func (*Scheduler) GetDataStorage

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

func (*Scheduler) GetInboundPool

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

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

type StartableScheduler

type StartableScheduler interface {
	Run() error
}