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 WithBeaconCommitteeSubscriptionsSubmitter(submitter eth2client.BeaconCommitteeSubscriptionsSubmitter) Parameter
  • func WithClientMonitor(clientMonitor metrics.ClientMonitor) Parameter
  • func WithLogLevel(logLevel zerolog.Level) Parameter
  • func WithProposalPreparationsSubmitter(submitter eth2client.ProposalPreparationsSubmitter) Parameter
  • func WithProposalSubmitter(submitter eth2client.ProposalSubmitter) 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) SubmitBeaconCommitteeSubscriptions(ctx context.Context, subscriptions []*apiv1.BeaconCommitteeSubscription) error
  • func (s *Service) SubmitProposal(ctx context.Context, proposal *api.VersionedSignedProposal) 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 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 WithProposalSubmitter

func WithProposalSubmitter(submitter eth2client.ProposalSubmitter) Parameter

WithProposalSubmitter sets the proposal 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) SubmitBeaconCommitteeSubscriptions

func (s *Service) SubmitBeaconCommitteeSubscriptions(ctx context.Context, subscriptions []*apiv1.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 []*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.