scheduler

Documentation

Index

• type Scheduler
  • func New(pubkeys []core.PubKey, eth2Cl eth2wrap.Client, builderAPI bool) (*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) SubscribeDuties(fn func(context.Context, core.Duty, core.DutyDefinitionSet) error)
  • func (s *Scheduler) SubscribeSlots(fn func(context.Context, core.Slot) error)

Types

type Scheduler

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

func New

func New(pubkeys []core.PubKey, eth2Cl eth2wrap.Client, builderAPI bool) (*Scheduler, error)

New returns a new scheduler.

func NewForT

func NewForT(t *testing.T, clock clockwork.Clock, delayFunc delayFunc, pubkeys []core.PubKey,
	eth2Cl eth2wrap.Client, builderAPI bool,
) *Scheduler

NewForT returns a new scheduler for testing using 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 or core.ErrNotFound if no definitions exist for a resolved epoch or another 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) SubscribeDuties

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

SubscribeDuties subscribes a callback function for triggered duties. Note this should be called *before* Start.

func (*Scheduler) SubscribeSlots

func (s *Scheduler) SubscribeSlots(fn func(context.Context, core.Slot) error)

SubscribeSlots subscribes a callback function for triggered slots. Note this should be called *before* Start.