scheduler

Documentation

Index

• Variables
• type DiskManager
• type GamePlayer
• type PlayerCreator
• type Scheduler
  • func NewScheduler(logger log.Logger, m SchedulerMetricer, disk DiskManager, maxConcurrency uint, ...) *Scheduler
  • func (s *Scheduler) Close() error
  • func (s *Scheduler) Schedule(games []common.Address) error
  • func (s *Scheduler) Start(ctx context.Context)
  • func (s *Scheduler) ThreadActive()
  • func (s *Scheduler) ThreadIdle()
• type SchedulerMetricer

Variables

var ErrBusy = errors.New("busy scheduling previous update")

Types

type DiskManager

type DiskManager interface {
	DirForGame(addr common.Address) string
	RemoveAllExcept(addrs []common.Address) error
}

type GamePlayer

type GamePlayer interface {
	ProgressGame(ctx context.Context) types.GameStatus
	Status() types.GameStatus
}

type PlayerCreator

type PlayerCreator func(address common.Address, dir string) (GamePlayer, error)

type Scheduler

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

func NewScheduler

func NewScheduler(logger log.Logger, m SchedulerMetricer, disk DiskManager, maxConcurrency uint, createPlayer PlayerCreator) *Scheduler

func (*Scheduler) Close

func (s *Scheduler) Close() error

func (*Scheduler) Schedule

func (s *Scheduler) Schedule(games []common.Address) error

func (*Scheduler) Start

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

func (*Scheduler) ThreadActive

func (s *Scheduler) ThreadActive()

func (*Scheduler) ThreadIdle

func (s *Scheduler) ThreadIdle()

type SchedulerMetricer

type SchedulerMetricer interface {
	RecordGamesStatus(inProgress, defenderWon, challengerWon int)
	RecordGameUpdateScheduled()
	RecordGameUpdateCompleted()
	IncActiveExecutors()
	DecActiveExecutors()
	IncIdleExecutors()
	DecIdleExecutors()
}