bcast

Documentation

Overview

Package bcast provides the core workflow's broadcaster component that broadcasts/submits aggregated signed duty data to the beacon node.

Index

• type Broadcaster
  • func New(ctx context.Context, eth2Cl eth2wrap.Client) (Broadcaster, error)
  • func (b Broadcaster) Broadcast(ctx context.Context, duty core.Duty, pubkey core.PubKey, ...) (err error)
• type Recaster
  • func NewRecaster() *Recaster
  • func (r *Recaster) SlotTicked(ctx context.Context, slot core.Slot) error
  • func (r *Recaster) Store(_ context.Context, duty core.Duty, pubkey core.PubKey, aggData core.SignedData) error
  • func (r *Recaster) Subscribe(sub func(context.Context, core.Duty, core.PubKey, core.SignedData) error)

Types

type Broadcaster

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

func New

func New(ctx context.Context, eth2Cl eth2wrap.Client) (Broadcaster, error)

New returns a new broadcaster instance.

func (Broadcaster) Broadcast

func (b Broadcaster) Broadcast(ctx context.Context, duty core.Duty, pubkey core.PubKey, aggData core.SignedData) (err error)

Broadcast broadcasts the aggregated signed duty data object to the beacon-node.

type Recaster

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

Recaster rebroadcasts core.DutyBuilderRegistration aggregate signatures every epoch.

func NewRecaster

func NewRecaster() *Recaster

NewRecaster returns a new recaster.

func (*Recaster) SlotTicked

func (r *Recaster) SlotTicked(ctx context.Context, slot core.Slot) error

SlotTicked is called when new slots tick.

func (*Recaster) Store

func (r *Recaster) Store(_ context.Context, duty core.Duty,
	pubkey core.PubKey, aggData core.SignedData,
) error

Store stores aggregate signed duty registrations for rebroadcasting.

func (*Recaster) Subscribe

func (r *Recaster) Subscribe(sub func(context.Context, core.Duty, core.PubKey, core.SignedData) error)

Subscribe subscribes to rebroadcasted duties.