multinode

Documentation

Overview

Package multinode is a strategy that obtains beacon block proposals from multiple nodes and selects the best one based on its attestation load.

Index

• type Parameter
  • func WithAggregateAttestationsSubmitters(submitters map[string]eth2client.AggregateAttestationsSubmitter) Parameter
  • func WithAttestationsSubmitters(submitters map[string]eth2client.AttestationsSubmitter) Parameter
  • func WithBeaconCommitteeSubscriptionsSubmitters(submitters map[string]eth2client.BeaconCommitteeSubscriptionsSubmitter) Parameter
  • func WithClientMonitor(clientMonitor metrics.ClientMonitor) Parameter
  • func WithLogLevel(logLevel zerolog.Level) Parameter
  • func WithProcessConcurrency(concurrency int64) Parameter
  • func WithProposalPreparationsSubmitters(submitters map[string]eth2client.ProposalPreparationsSubmitter) Parameter
  • func WithProposalSubmitters(submitters map[string]eth2client.ProposalSubmitter) Parameter
  • func WithSyncCommitteeContributionsSubmitters(submitters map[string]eth2client.SyncCommitteeContributionsSubmitter) Parameter
  • func WithSyncCommitteeMessagesSubmitters(submitters map[string]eth2client.SyncCommitteeMessagesSubmitter) Parameter
  • func WithSyncCommitteeSubscriptionsSubmitters(submitters map[string]eth2client.SyncCommitteeSubscriptionsSubmitter) Parameter
  • func WithTimeout(timeout time.Duration) Parameter
• type Service
  • func New(_ context.Context, params ...Parameter) (*Service, error)
  • func (s *Service) SubmitAggregateAttestations(ctx context.Context, aggregates []*phase0.SignedAggregateAndProof) error
  • func (s *Service) SubmitAttestations(ctx context.Context, attestations []*phase0.Attestation) error
  • func (s *Service) SubmitBeaconCommitteeSubscriptions(ctx context.Context, subscriptions []*api.BeaconCommitteeSubscription) error
  • func (s *Service) SubmitProposal(ctx context.Context, proposal *api.VersionedSignedProposal) error
  • func (s *Service) SubmitProposalPreparations(ctx context.Context, preparations []*api.ProposalPreparation) error
  • func (s *Service) SubmitSyncCommitteeContributions(ctx context.Context, ...) error
  • func (s *Service) SubmitSyncCommitteeMessages(ctx context.Context, messages []*altair.SyncCommitteeMessage) error
  • func (s *Service) SubmitSyncCommitteeSubscriptions(ctx context.Context, subscriptions []*api.SyncCommitteeSubscription) error

Types

type Parameter

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

Parameter is the interface for service parameters.

func WithAggregateAttestationsSubmitters

func WithAggregateAttestationsSubmitters(submitters map[string]eth2client.AggregateAttestationsSubmitter) Parameter

WithAggregateAttestationsSubmitters sets the aggregate attestation submitters.

func WithAttestationsSubmitters

func WithAttestationsSubmitters(submitters map[string]eth2client.AttestationsSubmitter) Parameter

WithAttestationsSubmitters sets the attestation submitters.

func WithBeaconCommitteeSubscriptionsSubmitters

func WithBeaconCommitteeSubscriptionsSubmitters(submitters map[string]eth2client.BeaconCommitteeSubscriptionsSubmitter) Parameter

WithBeaconCommitteeSubscriptionsSubmitters sets the attestation submitters.

func WithClientMonitor

func WithClientMonitor(clientMonitor metrics.ClientMonitor) Parameter

WithClientMonitor sets the client monitor.

func WithLogLevel

func WithLogLevel(logLevel zerolog.Level) Parameter

WithLogLevel sets the log level for the module.

func WithProcessConcurrency

func WithProcessConcurrency(concurrency int64) Parameter

WithProcessConcurrency sets the concurrency for the service.

func WithProposalPreparationsSubmitters

func WithProposalPreparationsSubmitters(submitters map[string]eth2client.ProposalPreparationsSubmitter) Parameter

WithProposalPreparationsSubmitters sets the proposal preparation submitters.

func WithProposalSubmitters

func WithProposalSubmitters(submitters map[string]eth2client.ProposalSubmitter) Parameter

WithProposalSubmitters sets the proposal submitters.

func WithSyncCommitteeContributionsSubmitters

func WithSyncCommitteeContributionsSubmitters(submitters map[string]eth2client.SyncCommitteeContributionsSubmitter) Parameter

WithSyncCommitteeContributionsSubmitters sets the sync committee contributions submitters.

func WithSyncCommitteeMessagesSubmitters

func WithSyncCommitteeMessagesSubmitters(submitters map[string]eth2client.SyncCommitteeMessagesSubmitter) Parameter

WithSyncCommitteeMessagesSubmitters sets the sync committee messages submitters.

func WithSyncCommitteeSubscriptionsSubmitters

func WithSyncCommitteeSubscriptionsSubmitters(submitters map[string]eth2client.SyncCommitteeSubscriptionsSubmitter) Parameter

WithSyncCommitteeSubscriptionsSubmitters sets the sync committee subscriptions submitters.

func WithTimeout

func WithTimeout(timeout time.Duration) Parameter

WithTimeout sets the timeout for calls made by the module.

type Service

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

Service is the provider for a submitter.

func New

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

New creates a new multinode submitter.

func (*Service) SubmitAggregateAttestations

func (s *Service) SubmitAggregateAttestations(ctx context.Context, aggregates []*phase0.SignedAggregateAndProof) error

SubmitAggregateAttestations submits aggregate attestations.

func (*Service) SubmitAttestations

func (s *Service) SubmitAttestations(ctx context.Context, attestations []*phase0.Attestation) error

SubmitAttestations submits a batch of attestations.

func (*Service) SubmitBeaconCommitteeSubscriptions

func (s *Service) SubmitBeaconCommitteeSubscriptions(ctx context.Context, subscriptions []*api.BeaconCommitteeSubscription) error

SubmitBeaconCommitteeSubscriptions submits a batch of beacon committee subscriptions.

func (*Service) SubmitProposal

func (s *Service) SubmitProposal(ctx context.Context, proposal *api.VersionedSignedProposal) error

SubmitProposal submits a proposal.

func (*Service) SubmitProposalPreparations

func (s *Service) SubmitProposalPreparations(ctx context.Context, preparations []*api.ProposalPreparation) error

SubmitProposalPreparations submits proposal preparations.

func (*Service) SubmitSyncCommitteeContributions

func (s *Service) SubmitSyncCommitteeContributions(ctx context.Context, contributionAndProofs []*altair.SignedContributionAndProof) error

SubmitSyncCommitteeContributions submits sync committee contributions.

func (*Service) SubmitSyncCommitteeMessages

func (s *Service) SubmitSyncCommitteeMessages(ctx context.Context, messages []*altair.SyncCommitteeMessage) error

SubmitSyncCommitteeMessages submits sync committee messages.

func (*Service) SubmitSyncCommitteeSubscriptions

func (s *Service) SubmitSyncCommitteeSubscriptions(ctx context.Context, subscriptions []*api.SyncCommitteeSubscription) error

SubmitSyncCommitteeSubscriptions submits a batch of sync committee subscriptions.