multinode

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 24, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

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

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v1.0.0 

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

WithAttestationsSubmitters sets the attestation submitters.

func WithBeaconBlockSubmitters 

func WithBeaconBlockSubmitters(submitters map[string]eth2client.BeaconBlockSubmitter) Parameter

WithBeaconBlockSubmitters sets the beacon block submitters.

func WithBeaconCommitteeSubscriptionsSubmitters 

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

WithBeaconCommitteeSubscriptionsSubmitters sets the attestation submitters.

func WithClientMonitor added in v0.9.0 

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 added in v1.5.0 

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

WithProposalPreparationsSubmitters sets the proposal preparation submitters.

func WithSyncCommitteeContributionsSubmitters added in v1.2.0 

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

WithSyncCommitteeContributionsSubmitters sets the sync committee contributions submitters.

func WithSyncCommitteeMessagesSubmitters added in v1.2.0 

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

WithSyncCommitteeMessagesSubmitters sets the sync committee messages submitters.

func WithSyncCommitteeSubscriptionsSubmitters added in v1.2.0 

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

WithSyncCommitteeSubscriptionsSubmitters sets the sync committee subscriptions submitters.

func WithTimeout added in v1.4.0 

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 beacon block proposals.

func New 

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

New creates a new beacon block propsal strategy.

func (*Service) SubmitAggregateAttestations added in v0.6.1 

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

SubmitAggregateAttestations submits aggregate attestations.

func (*Service) SubmitAttestations added in v1.0.0 

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

SubmitAttestations submits a batch of attestations.

func (*Service) SubmitBeaconBlock 

func (s *Service) SubmitBeaconBlock(ctx context.Context, block *spec.VersionedSignedBeaconBlock) error

SubmitBeaconBlock submits a beacon block.

func (*Service) SubmitBeaconCommitteeSubscriptions 

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

SubmitBeaconCommitteeSubscriptions submits a batch of beacon committee subscriptions.

func (*Service) SubmitProposalPreparations added in v1.5.0 

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

SubmitProposalPreparations submits proposal preparations.

func (*Service) SubmitSyncCommitteeContributions added in v1.2.0 

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

SubmitSyncCommitteeContributions submits sync committee contributions.

func (*Service) SubmitSyncCommitteeMessages added in v1.2.0 

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

SubmitSyncCommitteeMessages submits sync committee messages.

func (*Service) SubmitSyncCommitteeSubscriptions added in v1.2.0 

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

SubmitSyncCommitteeSubscriptions submits a batch of sync committee subscriptions.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.