sigagg

Documentation

Overview

Package sigagg provides the sigagg core workflow component that aggregates *threshold* partial signed duty data objects into an aggregated signed duty data object ready to be broadcasted to the beacon chain.

Index

• type Aggregator
  • func New(threshold int) *Aggregator
  • func (a *Aggregator) Aggregate(ctx context.Context, duty core.Duty, pubkey core.PubKey, ...) error
  • func (a *Aggregator) Subscribe(fn func(context.Context, core.Duty, core.PubKey, core.SignedData) error)

Types

type Aggregator

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

Aggregator aggregates *threshold* partial signed duty data objects into an aggregated signed duty data object ready to be broadcasted.

func New

func New(threshold int) *Aggregator

New returns a new aggregator instance.

func (*Aggregator) Aggregate

func (a *Aggregator) Aggregate(ctx context.Context, duty core.Duty, pubkey core.PubKey, parSigs []core.ParSignedData) error

Aggregate aggregates the partially signed duty data for the DV.

func (*Aggregator) Subscribe

func (a *Aggregator) Subscribe(fn func(context.Context, core.Duty, core.PubKey, core.SignedData) error)

Subscribe registers a callback for aggregated signed duty data.