immediate

Documentation

Overview

Package immediate is a submitter that immediately submits requests received.

Index

• type Parameter
  • func WithAggregateAttestationsSubmitter(submitter eth2client.AggregateAttestationsSubmitter) Parameter
  • func WithAttestationsSubmitter(submitter eth2client.AttestationsSubmitter) Parameter
  • func WithBeaconBlockSubmitter(submitter eth2client.BeaconBlockSubmitter) Parameter
  • func WithBeaconCommitteeSubscriptionsSubmitter(submitter eth2client.BeaconCommitteeSubscriptionsSubmitter) Parameter
  • func WithClientMonitor(clientMonitor metrics.ClientMonitor) Parameter
  • func WithLogLevel(logLevel zerolog.Level) Parameter
  • func WithProposalPreparationsSubmitter(submitter eth2client.ProposalPreparationsSubmitter) Parameter
  • func WithSyncCommitteeContributionsSubmitter(submitter eth2client.SyncCommitteeContributionsSubmitter) Parameter
  • func WithSyncCommitteeMessagesSubmitter(submitter eth2client.SyncCommitteeMessagesSubmitter) Parameter
  • func WithSyncCommitteeSubscriptionsSubmitter(submitter eth2client.SyncCommitteeSubscriptionsSubmitter) 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) SubmitBeaconBlock(ctx context.Context, block *spec.VersionedSignedBeaconBlock) error
  • func (s *Service) SubmitBeaconCommitteeSubscriptions(ctx context.Context, subscriptions []*apiv1.BeaconCommitteeSubscription) error
  • func (s *Service) SubmitProposalPreparations(ctx context.Context, preparations []*apiv1.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 []*apiv1.SyncCommitteeSubscription) error

Types

type Parameter

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

Parameter is the interface for service parameters.

func WithAggregateAttestationsSubmitter

func WithAggregateAttestationsSubmitter(submitter eth2client.AggregateAttestationsSubmitter) Parameter

WithAggregateAttestationsSubmitter sets the aggregate attestation submitter

func WithAttestationsSubmitter

func WithAttestationsSubmitter(submitter eth2client.AttestationsSubmitter) Parameter

WithAttestationsSubmitter sets the attestation submitter.

func WithBeaconBlockSubmitter

func WithBeaconBlockSubmitter(submitter eth2client.BeaconBlockSubmitter) Parameter

WithBeaconBlockSubmitter sets the beacon block submitter.

func WithBeaconCommitteeSubscriptionsSubmitter

func WithBeaconCommitteeSubscriptionsSubmitter(submitter eth2client.BeaconCommitteeSubscriptionsSubmitter) Parameter

WithBeaconCommitteeSubscriptionsSubmitter sets the attestation subnet subscriptions submitter

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 WithProposalPreparationsSubmitter

func WithProposalPreparationsSubmitter(submitter eth2client.ProposalPreparationsSubmitter) Parameter

WithProposalPreparationsSubmitter sets the proposal preparations submitter.

func WithSyncCommitteeContributionsSubmitter

func WithSyncCommitteeContributionsSubmitter(submitter eth2client.SyncCommitteeContributionsSubmitter) Parameter

WithSyncCommitteeContributionsSubmitter sets the sync committee contributions submitter

func WithSyncCommitteeMessagesSubmitter

func WithSyncCommitteeMessagesSubmitter(submitter eth2client.SyncCommitteeMessagesSubmitter) Parameter

WithSyncCommitteeMessagesSubmitter sets the sync committee messages submitter.

func WithSyncCommitteeSubscriptionsSubmitter

func WithSyncCommitteeSubscriptionsSubmitter(submitter eth2client.SyncCommitteeSubscriptionsSubmitter) Parameter

WithSyncCommitteeSubscriptionsSubmitter sets the sync committee subscriptions submitter

type Service

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

Service is the submitter for signed items.

func New

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

New creates a new 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 multiple attestations.

func (*Service) SubmitBeaconBlock

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

SubmitBeaconBlock submits a block.

func (*Service) SubmitBeaconCommitteeSubscriptions

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

SubmitBeaconCommitteeSubscriptions submits a batch of beacon committee subscriptions.

func (*Service) SubmitProposalPreparations

func (s *Service) SubmitProposalPreparations(ctx context.Context, preparations []*apiv1.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 []*apiv1.SyncCommitteeSubscription) error

SubmitSyncCommitteeSubscriptions submits a batch of beacon committee subscriptions.