standard

Documentation

Index

• type Parameter
  • func WithAggregateAndProofSigner(signer signer.AggregateAndProofSigner) Parameter
  • func WithAggregateAttestationProvider(provider eth2client.AggregateAttestationProvider) Parameter
  • func WithAggregateAttestationsSubmitter(submitter submitter.AggregateAttestationsSubmitter) Parameter
  • func WithLogLevel(logLevel zerolog.Level) Parameter
  • func WithMonitor(monitor metrics.AttestationAggregationMonitor) 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 phase0.ValidatorIndex, slot phase0.Slot, ...) (bool, phase0.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 WithAggregateAttestationProvider

func WithAggregateAttestationProvider(provider eth2client.AggregateAttestationProvider) Parameter

WithAggregateAttestationProvider 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 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 phase0.ValidatorIndex,
	slot phase0.Slot,
	committeeSize uint64,
) (bool, phase0.BLSSignature, error)

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