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 WithBeaconBlockSubmitters(submitters map[string]eth2client.BeaconBlockSubmitter) 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
• type Service
  • func New(ctx context.Context, params ...Parameter) (*Service, error)
  • func (s *Service) SubmitAggregateAttestations(ctx context.Context, aggregates []*spec.SignedAggregateAndProof) error
  • func (s *Service) SubmitAttestations(ctx context.Context, attestations []*spec.Attestation) error
  • func (s *Service) SubmitBeaconBlock(ctx context.Context, block *spec.SignedBeaconBlock) error
  • func (s *Service) SubmitBeaconCommitteeSubscriptions(ctx context.Context, subscriptions []*api.BeaconCommitteeSubscription) 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 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

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.

type Service

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

Service is the provider for beacon block proposals.

func New

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

New creates a new beacon block propsal strategy.

func (*Service) SubmitAggregateAttestations

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

SubmitAggregateAttestations submits aggregate attestations.

func (*Service) SubmitAttestations

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

SubmitAttestations submits a batch of attestations.

func (*Service) SubmitBeaconBlock

func (s *Service) SubmitBeaconBlock(ctx context.Context, block *spec.SignedBeaconBlock) 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.