scheduler

Documentation

Index

• type Scheduler
  • func New(ctx context.Context, stream *response.Stream) *Scheduler
  • func (s *Scheduler) FinalStoreMap(exclusiveEndBlock uint64) (store.Map, error)
  • func (s *Scheduler) Init() loop.Cmd
  • func (s *Scheduler) Update(msg loop.Msg) loop.Cmd

Types

type Scheduler

type Scheduler struct {
	loop.EventLoop

	Stages        *stage.Stages
	WorkerPool    *work.WorkerPool
	ExecOutWalker *execout.Walker
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, stream *response.Stream) *Scheduler

func (*Scheduler) FinalStoreMap

func (s *Scheduler) FinalStoreMap(exclusiveEndBlock uint64) (store.Map, error)

func (*Scheduler) Init

func (s *Scheduler) Init() loop.Cmd

func (*Scheduler) Update

func (s *Scheduler) Update(msg loop.Msg) loop.Cmd