standard

Documentation

Index

• type Parameter
  • func WithAggregateAndProofSigner(signer signer.AggregateAndProofSigner) Parameter
  • func WithAggregateAttestationProvider(provider eth2client.AggregateAttestationProvider) Parameter
  • func WithAggregateAttestationsSubmitter(submitter submitter.AggregateAttestationsSubmitter) Parameter
  • func WithChainTime(service chaintime.Service) Parameter
  • func WithLogLevel(logLevel zerolog.Level) Parameter
  • func WithMonitor(monitor metrics.Service) Parameter
  • func WithSlotSelectionSigner(signer signer.SlotSelectionSigner) Parameter
  • func WithSpecProvider(provider eth2client.SpecProvider) 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, duty *attestationaggregator.Duty)
  • 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 WithChainTime

func WithChainTime(service chaintime.Service) Parameter

WithChainTime sets the chain time service.

func WithLogLevel

func WithLogLevel(logLevel zerolog.Level) Parameter

WithLogLevel sets the log level for the module.

func WithMonitor

func WithMonitor(monitor metrics.Service) Parameter

WithMonitor sets the monitor for this module.

func WithSlotSelectionSigner

func WithSlotSelectionSigner(signer signer.SlotSelectionSigner) Parameter

WithSlotSelectionSigner sets the slot selection submitter.

func WithSpecProvider

func WithSpecProvider(provider eth2client.SpecProvider) Parameter

WithSpecProvider sets the specification 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, duty *attestationaggregator.Duty)

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.