immediate

package

v1.8.1 Latest Latest Go to latest Published: Mar 18, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/attestantio/vouch

Links

Open Source Insights

Documentation ¶

Overview ¶

Package immediate is a submitter that immediately submits requests received.

Index ¶

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

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 WithAggregateAttestationsSubmitter ¶

func WithAggregateAttestationsSubmitter(submitter eth2client.AggregateAttestationsSubmitter) Parameter

WithAggregateAttestationsSubmitter sets the aggregate attestation submitter.

func WithAttestationsSubmitter ¶ added in v1.0.0

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

func WithProposalPreparationsSubmitter(submitter eth2client.ProposalPreparationsSubmitter) Parameter

WithProposalPreparationsSubmitter sets the proposal preparations submitter.

func WithProposalSubmitter ¶ added in v1.8.0

func WithProposalSubmitter(submitter eth2client.ProposalSubmitter) Parameter

WithProposalSubmitter sets the proposal submitter.

func WithSyncCommitteeContributionsSubmitter ¶ added in v1.2.0

func WithSyncCommitteeContributionsSubmitter(submitter eth2client.SyncCommitteeContributionsSubmitter) Parameter

WithSyncCommitteeContributionsSubmitter sets the sync committee contributions submitter.

func WithSyncCommitteeMessagesSubmitter ¶ added in v1.2.0

func WithSyncCommitteeMessagesSubmitter(submitter eth2client.SyncCommitteeMessagesSubmitter) Parameter

WithSyncCommitteeMessagesSubmitter sets the sync committee messages submitter.

func WithSyncCommitteeSubscriptionsSubmitter ¶ added in v1.2.0

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

func (s *Service) SubmitProposal(ctx context.Context, proposal *api.VersionedSignedProposal) error

SubmitProposal submits a proposal.

func (*Service) SubmitProposalPreparations ¶ added in v1.5.0

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

SubmitSyncCommitteeSubscriptions submits a batch of beacon committee subscriptions.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL