tracker

Documentation

Index

• func NewInclDelayFunc(eth2Cl eth2wrap.Client, dutiesFunc dutiesFunc) func(context.Context, core.Slot) error
• 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

Functions

func NewInclDelayFunc

func NewInclDelayFunc(eth2Cl eth2wrap.Client, dutiesFunc dutiesFunc) func(context.Context, core.Slot) error

NewInclDelayFunc returns a function that calculates attestation inclusion delay for a block.

Inclusion delay is the average of the distance between the slot a validator’s attestation is expected by the network and the slot the attestation is actually included on-chain. See https://rated.gitbook.io/rated-documentation/rating-methodologies/ethereum-beacon-chain/network-explorer-definitions/top-screener#inclusion-delay.

Types

type Tracker

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

Tracker represents the step that listens to events from core workflow steps. 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, fromSlot int64) *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 step.

func (*Tracker) FetcherEvent

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

FetcherEvent inputs event from core.Fetcher step.

func (*Tracker) ParSigDBInternalEvent

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

ParSigDBInternalEvent inputs events from core.ParSigDB step event for local VC submitted parsigs.

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 step for threshold emitted parsigs.

func (*Tracker) ParSigExEvent

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

ParSigExEvent inputs event from core.ParSigEx step event for other VC submitted parsigs.

func (*Tracker) Run

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

Run blocks and registers events from each step 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 step.

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 step.

func (*Tracker) ValidatorAPIEvent

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

ValidatorAPIEvent inputs events from core.ValidatorAPI step.