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) CheckAggregateAttestation(att *solid.Attestation) error

Variables

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

Types

type CommitteeSubscribe

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

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) CheckAggregateAttestation

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