state

Documentation

Index

• type Coordinator
  • func New(ctx context.Context, conf *settings.Configuration) (handler *Coordinator)
  • func (h *Coordinator) NextTask() *tasks.MinerTask
  • func (h *Coordinator) RunUsing(shardsBlockCandidates <-chan events.ShardBlockCandidate, ...)

Types

type Coordinator

type Coordinator struct {
	utils.StoppableMixin
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, conf *settings.Configuration) (handler *Coordinator)

func (*Coordinator) NextTask

func (h *Coordinator) NextTask() *tasks.MinerTask

func (*Coordinator) RunUsing

func (h *Coordinator) RunUsing(
	shardsBlockCandidates <-chan events.ShardBlockCandidate,
	beaconBlockCandidates <-chan events.BeaconBlockCandidate,
	bitcoinBlockCandidates <-chan events.BitcoinBlockCandidate)