tracker

Documentation

Index

• type Tracker
  • func New(analyser core.Deadliner, deleter core.Deadliner, peers []p2p.Peer) *Tracker
  • func (t *Tracker) ConsensusEvent(ctx context.Context, duty core.Duty, data core.UnsignedDataSet) error
  • func (t *Tracker) FetcherEvent(ctx context.Context, duty core.Duty, data core.UnsignedDataSet) error
  • func (t *Tracker) ParSigDBInternalEvent(ctx context.Context, duty core.Duty, data core.ParSignedDataSet) error
  • func (t *Tracker) ParSigDBThresholdEvent(ctx context.Context, duty core.Duty, pubkey core.PubKey, ...) error
  • func (t *Tracker) ParSigExEvent(ctx context.Context, duty core.Duty, data core.ParSignedDataSet) error
  • func (t *Tracker) Run(ctx context.Context) error
  • func (t *Tracker) SchedulerEvent(ctx context.Context, duty core.Duty, defSet core.DutyDefinitionSet) error
  • func (t *Tracker) SigAggEvent(ctx context.Context, duty core.Duty, pubkey core.PubKey, _ core.SignedData) error
  • func (t *Tracker) ValidatorAPIEvent(ctx context.Context, duty core.Duty, data core.ParSignedDataSet) error

Types

type Tracker

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

Tracker represents the component that listens to events from core workflow components. It identifies where a duty gets stuck in the course of its execution.

func New

func New(analyser core.Deadliner, deleter core.Deadliner, peers []p2p.Peer) *Tracker

New returns a new Tracker. The deleter deadliner must return well after analyser deadliner since duties of the same slot are often analysed together.

func (*Tracker) ConsensusEvent

func (t *Tracker) ConsensusEvent(ctx context.Context, duty core.Duty, data core.UnsignedDataSet) error

ConsensusEvent inputs event from core.Consensus component.

func (*Tracker) FetcherEvent

func (t *Tracker) FetcherEvent(ctx context.Context, duty core.Duty, data core.UnsignedDataSet) error

FetcherEvent inputs event from core.Fetcher component.

func (*Tracker) ParSigDBInternalEvent

func (t *Tracker) ParSigDBInternalEvent(ctx context.Context, duty core.Duty, data core.ParSignedDataSet) error

ParSigDBInternalEvent inputs events from core.ParSigDB component for internal store event.

func (*Tracker) ParSigDBThresholdEvent

func (t *Tracker) ParSigDBThresholdEvent(ctx context.Context, duty core.Duty, pubkey core.PubKey, _ []core.ParSignedData) error

ParSigDBThresholdEvent inputs event from core.ParSigDB component for threshold event.

func (*Tracker) ParSigExEvent

func (t *Tracker) ParSigExEvent(ctx context.Context, duty core.Duty, data core.ParSignedDataSet) error

ParSigExEvent inputs event from core.ParSigEx component.

func (*Tracker) Run

func (t *Tracker) Run(ctx context.Context) error

Run blocks and registers events from each component in tracker's input channel. It also analyses and reports the duties whose deadline gets crossed.

func (*Tracker) SchedulerEvent

func (t *Tracker) SchedulerEvent(ctx context.Context, duty core.Duty, defSet core.DutyDefinitionSet) error

SchedulerEvent inputs event from core.Scheduler component.

func (*Tracker) SigAggEvent

func (t *Tracker) SigAggEvent(ctx context.Context, duty core.Duty, pubkey core.PubKey, _ core.SignedData) error

SigAggEvent inputs event from core.SigAgg component.

func (*Tracker) ValidatorAPIEvent

func (t *Tracker) ValidatorAPIEvent(ctx context.Context, duty core.Duty, data core.ParSignedDataSet) error

ValidatorAPIEvent inputs events from core.ValidatorAPI component.