runner

Documentation

Index

• Variables
• func InitRunner(lc fx.Lifecycle, runner *Runner)
• type Runner
  • func NewRunner(db *gorm.DB, q queue.WorkerQueue, r *util.Store, ...) *Runner
  • func (d *Runner) MasterRunner() (err error)
  • func (d Runner) Score(timeout time.Duration, rnd *round.Round)

Variables

var ErrPanic = errors.New("panic")

var ErrUnknownPanic = errors.New("unknown panic")

Functions

func InitRunner

func InitRunner(lc fx.Lifecycle, runner *Runner)

Types

type Runner

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

func NewRunner

func NewRunner(db *gorm.DB, q queue.WorkerQueue, r *util.Store, staticConfig config.StaticConfig) *Runner

func (*Runner) MasterRunner

func (d *Runner) MasterRunner() (err error)

func (Runner) Score

func (d Runner) Score(timeout time.Duration, rnd *round.Round)