standard

Documentation

Index

• type Parameter
  • func WithAggregateAndProofSigner(signer signer.AggregateAndProofSigner) Parameter
  • func WithAggregateAttestationDataProvider(provider eth2client.AggregateAttestationProvider) Parameter
  • func WithAggregateAttestationsSubmitter(submitter submitter.AggregateAttestationsSubmitter) Parameter
  • func WithLogLevel(logLevel zerolog.Level) Parameter
  • func WithMonitor(monitor metrics.AttestationAggregationMonitor) Parameter
  • func WithPrysmAggregateAttestationDataProvider(provider eth2client.PrysmAggregateAttestationProvider) Parameter
  • func WithSlotSelectionSigner(signer signer.SlotSelectionSigner) Parameter
  • func WithSlotsPerEpochProvider(provider eth2client.SlotsPerEpochProvider) Parameter
  • func WithTargetAggregatorsPerCommitteeProvider(provider eth2client.TargetAggregatorsPerCommitteeProvider) Parameter
  • func WithValidatingAccountsProvider(provider accountmanager.ValidatingAccountsProvider) Parameter
• type Service
  • func New(ctx context.Context, params ...Parameter) (*Service, error)
  • func (s *Service) Aggregate(ctx context.Context, data interface{})
  • func (s *Service) IsAggregator(ctx context.Context, validatorIndex spec.ValidatorIndex, ...) (bool, spec.BLSSignature, error)

Types

type Parameter

type Parameter interface {
	// contains filtered or unexported methods
}

Parameter is the interface for service parameters.

func WithAggregateAndProofSigner

func WithAggregateAndProofSigner(signer signer.AggregateAndProofSigner) Parameter

WithAggregateAndProofSigner sets the aggregate and proof submitter.

func WithAggregateAttestationDataProvider

func WithAggregateAttestationDataProvider(provider eth2client.AggregateAttestationProvider) Parameter

WithAggregateAttestationDataProvider sets the aggregate attestation provider.

func WithAggregateAttestationsSubmitter

func WithAggregateAttestationsSubmitter(submitter submitter.AggregateAttestationsSubmitter) Parameter

WithAggregateAttestationsSubmitter sets the aggregate attestation submitter.

func WithLogLevel

func WithLogLevel(logLevel zerolog.Level) Parameter

WithLogLevel sets the log level for the module.

func WithMonitor

func WithMonitor(monitor metrics.AttestationAggregationMonitor) Parameter

WithMonitor sets the monitor for this module.

func WithPrysmAggregateAttestationDataProvider

func WithPrysmAggregateAttestationDataProvider(provider eth2client.PrysmAggregateAttestationProvider) Parameter

WithPrysmAggregateAttestationDataProvider sets the non-spec aggregate attestation provider.

func WithSlotSelectionSigner

func WithSlotSelectionSigner(signer signer.SlotSelectionSigner) Parameter

WithSlotSelectionSigner sets the slot selection submitter.

func WithSlotsPerEpochProvider

func WithSlotsPerEpochProvider(provider eth2client.SlotsPerEpochProvider) Parameter

WithSlotsPerEpochProvider sets the slots per epoch provider.

func WithTargetAggregatorsPerCommitteeProvider

func WithTargetAggregatorsPerCommitteeProvider(provider eth2client.TargetAggregatorsPerCommitteeProvider) Parameter

WithTargetAggregatorsPerCommitteeProvider sets the target aggregators per attestation provider.

func WithValidatingAccountsProvider

func WithValidatingAccountsProvider(provider accountmanager.ValidatingAccountsProvider) Parameter

WithValidatingAccountsProvider sets the account manager.

type Service

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

Service is an attestation aggregator.

func New

func New(ctx context.Context, params ...Parameter) (*Service, error)

New creates a new attestation aggregator.

func (*Service) Aggregate

func (s *Service) Aggregate(ctx context.Context, data interface{})

Aggregate aggregates the attestations for a given slot/committee combination.

func (*Service) IsAggregator

func (s *Service) IsAggregator(ctx context.Context,
	validatorIndex spec.ValidatorIndex,
	committeeIndex spec.CommitteeIndex,
	slot spec.Slot,
	committeeSize uint64,
) (bool, spec.BLSSignature, error)

IsAggregator reports if we are an attestation aggregator for a given validator/committee/slot combination.