standard

Documentation

Index

• type Parameter
  • func WithBeaconBlockRootProvider(provider eth2client.BeaconBlockRootProvider) Parameter
  • func WithContributionAndProofSigner(signer signer.ContributionAndProofSigner) Parameter
  • func WithLogLevel(logLevel zerolog.Level) Parameter
  • func WithMonitor(monitor metrics.SyncCommitteeAggregationMonitor) Parameter
  • func WithSpecProvider(provider eth2client.SpecProvider) Parameter
  • func WithSyncCommitteeContributionProvider(provider eth2client.SyncCommitteeContributionProvider) Parameter
  • func WithSyncCommitteeContributionsSubmitter(submitter submitter.SyncCommitteeContributionsSubmitter) 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) SetBeaconBlockRoot(slot phase0.Slot, root phase0.Root)

Types

type Parameter

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

Parameter is the interface for service parameters.

func WithBeaconBlockRootProvider

func WithBeaconBlockRootProvider(provider eth2client.BeaconBlockRootProvider) Parameter

WithBeaconBlockRootProvider sets the beacon block root provider.

func WithContributionAndProofSigner

func WithContributionAndProofSigner(signer signer.ContributionAndProofSigner) Parameter

WithContributionAndProofSigner sets the contribution and proof submitter.

func WithLogLevel

func WithLogLevel(logLevel zerolog.Level) Parameter

WithLogLevel sets the log level for the module.

func WithMonitor

func WithMonitor(monitor metrics.SyncCommitteeAggregationMonitor) Parameter

WithMonitor sets the monitor for this module.

func WithSpecProvider

func WithSpecProvider(provider eth2client.SpecProvider) Parameter

WithSpecProvider sets the spec provider.

func WithSyncCommitteeContributionProvider

func WithSyncCommitteeContributionProvider(provider eth2client.SyncCommitteeContributionProvider) Parameter

WithSyncCommitteeContributionProvider sets the sync committee contribution provider.

func WithSyncCommitteeContributionsSubmitter

func WithSyncCommitteeContributionsSubmitter(submitter submitter.SyncCommitteeContributionsSubmitter) Parameter

WithSyncCommitteeContributionsSubmitter sets the sync committee contributions submitter.

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 a sync committee aggregator.

func New

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

New creates a new sync committee 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) SetBeaconBlockRoot

func (s *Service) SetBeaconBlockRoot(slot phase0.Slot, root phase0.Root)

SetBeaconBlockRoot sets the beacon block root used for a given slot. Set by the sync committee messenger when it is creating the messages for the slot.