committee_subscription

Documentation

Index

• Variables
• type CommitteeSubscribe
• type CommitteeSubscribeMgmt
  • func NewCommitteeSubscribeManagement(ctx context.Context, indiciesDB kv.RoDB, ...) *CommitteeSubscribeMgmt
  • func (c *CommitteeSubscribeMgmt) AddAttestationSubscription(ctx context.Context, p *cltypes.BeaconCommitteeSubscription) error
  • func (c *CommitteeSubscribeMgmt) AggregateAttestation(att *solid.Attestation) error
  • func (c *CommitteeSubscribeMgmt) NeedToAggregate(att *solid.Attestation) bool

Variables

var (
	ErrIgnore                   = errors.New("ignore")
	ErrCommitteeIndexOutOfRange = errors.New("committee index out of range")
	ErrWrongSubnet              = errors.New("attestation is for the wrong subnet")
	ErrNotInPropagationRange    = fmt.Errorf("attestation is not in propagation range. %w", ErrIgnore)
	ErrEpochMismatch            = errors.New("epoch mismatch")
	ErrExactlyOneBitSet         = errors.New("exactly one aggregation bit should be set")
	ErrAggregationBitsMismatch  = errors.New("aggregation bits mismatch committee size")
)

Types

type CommitteeSubscribe

type CommitteeSubscribe interface {
	AddAttestationSubscription(ctx context.Context, p *cltypes.BeaconCommitteeSubscription) error
	AggregateAttestation(att *solid.Attestation) error
	NeedToAggregate(att *solid.Attestation) bool
}

type CommitteeSubscribeMgmt

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

func NewCommitteeSubscribeManagement

func NewCommitteeSubscribeManagement(
	ctx context.Context,
	indiciesDB kv.RoDB,
	beaconConfig *clparams.BeaconChainConfig,
	netConfig *clparams.NetworkConfig,
	ethClock eth_clock.EthereumClock,
	sentinel sentinel.SentinelClient,
	state *state.CachingBeaconState,
	aggregationPool aggregation.AggregationPool,
	syncedData *synced_data.SyncedDataManager,
) *CommitteeSubscribeMgmt

func (*CommitteeSubscribeMgmt) AddAttestationSubscription

func (c *CommitteeSubscribeMgmt) AddAttestationSubscription(ctx context.Context, p *cltypes.BeaconCommitteeSubscription) error

func (*CommitteeSubscribeMgmt) AggregateAttestation

func (c *CommitteeSubscribeMgmt) AggregateAttestation(att *solid.Attestation) error

func (*CommitteeSubscribeMgmt) NeedToAggregate

func (c *CommitteeSubscribeMgmt) NeedToAggregate(att *solid.Attestation) bool