immediate

Documentation

Overview

Package immediate is a submitter that immediately submits requests received.

Index

• type Parameter
  • func WithAggregateAttestationsSubmitter(submitter eth2client.AggregateAttestationsSubmitter) Parameter
  • func WithAttestationSubmitter(submitter eth2client.AttestationSubmitter) 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
• 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) SubmitAttestation(ctx context.Context, attestation *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 WithAggregateAttestationsSubmitter

func WithAggregateAttestationsSubmitter(submitter eth2client.AggregateAttestationsSubmitter) Parameter

WithAggregateAttestationsSubmitter sets the aggregate attestation submitter

func WithAttestationSubmitter

func WithAttestationSubmitter(submitter eth2client.AttestationSubmitter) Parameter

WithAttestationSubmitter 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.

type Service

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

Service is the submitter for signed items.

func New

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

New creates a new submitter.

func (*Service) SubmitAggregateAttestations

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

SubmitAggregateAttestations submits aggregate attestations.

func (*Service) SubmitAttestation

func (s *Service) SubmitAttestation(ctx context.Context, attestation *spec.Attestation) error

SubmitAttestation submits an attestation.

func (*Service) SubmitBeaconBlock

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

SubmitBeaconBlock submits a block.

func (*Service) SubmitBeaconCommitteeSubscriptions

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

SubmitBeaconCommitteeSubscriptions submits a batch of beacon committee subscriptions.