attestations

Documentation

Overview

Package attestations defines an attestation pool service implementation which is used to manage the lifecycle of aggregated, unaggregated, and fork-choice attestations.

Index

• func NewPool() *kv.AttCaches
• type Config
• type Pool
• type Service
  • func NewService(ctx context.Context, cfg *Config) (*Service, error)
  • func (s *Service) SetGenesisTime(t uint64)
  • func (s *Service) Start()
  • func (s *Service) Status() error
  • func (s *Service) Stop() error

Functions

func NewPool

func NewPool() *kv.AttCaches

NewPool initializes a new attestation pool.

Types

type Config

type Config struct {
	Pool Pool

	InitialSyncComplete chan struct{}
	// contains filtered or unexported fields
}

Config options for the service.

type Pool

type Pool interface {
	// For Aggregated attestations
	AggregateUnaggregatedAttestations(ctx context.Context) error
	SaveAggregatedAttestation(att ethpb.Att) error
	SaveAggregatedAttestations(atts []ethpb.Att) error
	AggregatedAttestations() []ethpb.Att
	AggregatedAttestationsBySlotIndex(ctx context.Context, slot primitives.Slot, committeeIndex primitives.CommitteeIndex) []*ethpb.Attestation
	AggregatedAttestationsBySlotIndexElectra(ctx context.Context, slot primitives.Slot, committeeIndex primitives.CommitteeIndex) []*ethpb.AttestationElectra
	DeleteAggregatedAttestation(att ethpb.Att) error
	HasAggregatedAttestation(att ethpb.Att) (bool, error)
	AggregatedAttestationCount() int
	// For unaggregated attestations.
	SaveUnaggregatedAttestation(att ethpb.Att) error
	SaveUnaggregatedAttestations(atts []ethpb.Att) error
	UnaggregatedAttestations() ([]ethpb.Att, error)
	UnaggregatedAttestationsBySlotIndex(ctx context.Context, slot primitives.Slot, committeeIndex primitives.CommitteeIndex) []*ethpb.Attestation
	UnaggregatedAttestationsBySlotIndexElectra(ctx context.Context, slot primitives.Slot, committeeIndex primitives.CommitteeIndex) []*ethpb.AttestationElectra
	DeleteUnaggregatedAttestation(att ethpb.Att) error
	DeleteSeenUnaggregatedAttestations() (int, error)
	UnaggregatedAttestationCount() int
	// For attestations that were included in the block.
	SaveBlockAttestation(att ethpb.Att) error
	BlockAttestations() []ethpb.Att
	DeleteBlockAttestation(att ethpb.Att) error
	// For attestations to be passed to fork choice.
	SaveForkchoiceAttestation(att ethpb.Att) error
	SaveForkchoiceAttestations(atts []ethpb.Att) error
	ForkchoiceAttestations() []ethpb.Att
	DeleteForkchoiceAttestation(att ethpb.Att) error
	ForkchoiceAttestationCount() int
}

Pool defines the necessary methods for Prysm attestations pool to serve fork choice and validators. In the current design, aggregated attestations are used by proposer actor. Unaggregated attestations are used by aggregator actor.

type Service

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

Service of attestation pool operations.

func NewService

func NewService(ctx context.Context, cfg *Config) (*Service, error)

NewService instantiates a new attestation pool service instance that will be registered into a running beacon node.

func (*Service) SetGenesisTime

func (s *Service) SetGenesisTime(t uint64)

SetGenesisTime sets genesis time for operation service to use.

func (*Service) Start

func (s *Service) Start()

Start an attestation pool service's main event loop.

func (*Service) Status

func (s *Service) Status() error

Status returns the current service err if there's any.

func (*Service) Stop

func (s *Service) Stop() error

Stop the beacon block attestation pool service's main event loop and associated goroutines.