scheduler

Documentation

Index

• type Scheduler
  • func New(pubkeys []core.PubKey, eth2Svc eth2client.Service) (*Scheduler, error)
  • func NewForT(t *testing.T, clock clockwork.Clock, delayFunc delayFunc, ...) *Scheduler
  • func (s *Scheduler) GetDutyDefinition(ctx context.Context, duty core.Duty) (core.DutyDefinitionSet, error)
  • func (s *Scheduler) Run() error
  • func (s *Scheduler) Stop()
  • func (s *Scheduler) Subscribe(fn func(context.Context, core.Duty, core.DutyDefinitionSet) error)

Types

type Scheduler

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

func New

func New(pubkeys []core.PubKey, eth2Svc eth2client.Service) (*Scheduler, error)

New returns a new scheduler.

func NewForT

func NewForT(t *testing.T, clock clockwork.Clock, delayFunc delayFunc, pubkeys []core.PubKey, eth2Svc eth2client.Service) *Scheduler

NewForT returns a new scheduler for testing supporting a fake clock.

func (*Scheduler) GetDutyDefinition

func (s *Scheduler) GetDutyDefinition(ctx context.Context, duty core.Duty) (core.DutyDefinitionSet, error)

GetDutyDefinition returns the definition for a duty if resolved already, otherwise an error.

func (*Scheduler) Run

func (s *Scheduler) Run() error

Run blocks and runs the scheduler until Stop is called.

func (*Scheduler) Stop

func (s *Scheduler) Stop()

func (*Scheduler) Subscribe

func (s *Scheduler) Subscribe(fn func(context.Context, core.Duty, core.DutyDefinitionSet) error)

Subscribe registers a callback for triggering a duty. Note this should be called *before* Start.