scheduler

package

v0.5.0 Latest Latest Go to latest Published: May 26, 2022 License: GPL-3.0 Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

New returns a new scheduler.

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 (s *Scheduler) GetDuty(ctx context.Context, duty core.Duty) (core.FetchArgSet, error)

GetDuty returns the argSet for a duty if resolved already, otherwise an error.

func (s *Scheduler) Run() error

Run blocks and runs the scheduler until Stop is called.

func (s *Scheduler) Stop()

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

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