standard

package
v1.9.0-alpha.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 12, 2024 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

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 WithAccountsRefresher added in v1.0.0 

func WithAccountsRefresher(refresher accountmanager.Refresher) Parameter

WithAccountsRefresher sets the account refresher.

func WithAttestationAggregationDelay added in v1.3.0 

func WithAttestationAggregationDelay(delay time.Duration) Parameter

WithAttestationAggregationDelay sets the delay before aggregating attestations.

func WithAttestationAggregator 

func WithAttestationAggregator(aggregator attestationaggregator.Service) Parameter

WithAttestationAggregator sets the attestation aggregator.

func WithAttester 

func WithAttester(attester attester.Service) Parameter

WithAttester sets the attester.

func WithAttesterDutiesProvider 

func WithAttesterDutiesProvider(provider eth2client.AttesterDutiesProvider) Parameter

WithAttesterDutiesProvider sets the attester duties provider.

func WithBeaconBlockHeadersProvider added in v1.3.1 

func WithBeaconBlockHeadersProvider(provider eth2client.BeaconBlockHeadersProvider) Parameter

WithBeaconBlockHeadersProvider sets the beacon block headers provider.

func WithBeaconBlockProposer 

func WithBeaconBlockProposer(proposer beaconblockproposer.Service) Parameter

WithBeaconBlockProposer sets the beacon block propser.

func WithBeaconCommitteeSubscriber 

func WithBeaconCommitteeSubscriber(subscriber beaconcommitteesubscriber.Service) Parameter

WithBeaconCommitteeSubscriber sets the beacon committee subscriber.

func WithBlockToSlotSetter added in v1.7.0 

func WithBlockToSlotSetter(setter cache.BlockRootToSlotSetter) Parameter

WithBlockToSlotSetter sets the setter for the block to slot cache.

func WithChainTimeService 

func WithChainTimeService(service chaintime.Service) Parameter

WithChainTimeService sets the chain time service.

func WithEventsProvider added in v0.9.0 

func WithEventsProvider(provider eth2client.EventsProvider) Parameter

WithEventsProvider sets the events provider.

func WithFastTrackAttestations added in v1.9.0 

func WithFastTrackAttestations(fastTrack bool) Parameter

WithFastTrackAttestations sets the fast track flag, attesting as soon as possible.

func WithFastTrackGrace added in v1.9.0 

func WithFastTrackGrace(grace time.Duration) Parameter

WithFastTrackGrace sets the grace period before initiating fast track operations.

func WithFastTrackSyncCommittees added in v1.9.0 

func WithFastTrackSyncCommittees(fastTrack bool) Parameter

WithFastTrackSyncCommittees sets the fast track flag, generating sync committee messages as soon as possible.

func WithLogLevel 

func WithLogLevel(logLevel zerolog.Level) Parameter

WithLogLevel sets the log level for the module.

func WithMaxAttestationDelay added in v1.2.0 

func WithMaxAttestationDelay(delay time.Duration) Parameter

WithMaxAttestationDelay sets the maximum delay before attesting.

func WithMaxProposalDelay added in v1.3.1 

func WithMaxProposalDelay(delay time.Duration) Parameter

WithMaxProposalDelay sets the maximum delay before proposing.

func WithMaxSyncCommitteeMessageDelay added in v1.2.0 

func WithMaxSyncCommitteeMessageDelay(delay time.Duration) Parameter

WithMaxSyncCommitteeMessageDelay sets the maximum delay before generating sync committee messages.

func WithMonitor 

func WithMonitor(monitor metrics.ControllerMonitor) Parameter

WithMonitor sets the monitor for the module.

func WithProposalsPreparer added in v1.5.0 

func WithProposalsPreparer(provider proposalpreparer.Service) Parameter

WithProposalsPreparer sets the proposals preparer.

func WithProposerDutiesProvider 

func WithProposerDutiesProvider(provider eth2client.ProposerDutiesProvider) Parameter

WithProposerDutiesProvider sets the proposer duties provider.

func WithScheduler 

func WithScheduler(scheduler scheduler.Service) Parameter

WithScheduler sets the scheduler.

func WithSignedBeaconBlockProvider added in v1.3.1 

func WithSignedBeaconBlockProvider(provider eth2client.SignedBeaconBlockProvider) Parameter

WithSignedBeaconBlockProvider sets the signed beacon block provider.

func WithSpecProvider added in v1.2.0 

func WithSpecProvider(provider eth2client.SpecProvider) Parameter

WithSpecProvider sets the spec provider.

func WithSyncCommitteeAggregationDelay added in v1.3.0 

func WithSyncCommitteeAggregationDelay(delay time.Duration) Parameter

WithSyncCommitteeAggregationDelay sets the delay before aggregating sync committee messages.

func WithSyncCommitteeAggregator added in v1.2.0 

func WithSyncCommitteeAggregator(aggregator synccommitteeaggregator.Service) Parameter

WithSyncCommitteeAggregator sets the sync committee aggregator.

func WithSyncCommitteeDutiesProvider added in v1.2.0 

func WithSyncCommitteeDutiesProvider(provider eth2client.SyncCommitteeDutiesProvider) Parameter

WithSyncCommitteeDutiesProvider sets the sync committee duties provider.

func WithSyncCommitteeMessenger added in v1.2.0 

func WithSyncCommitteeMessenger(messenger synccommitteemessenger.Service) Parameter

WithSyncCommitteeMessenger sets the sync committee messenger.

func WithSyncCommitteeSubscriber added in v1.2.0 

func WithSyncCommitteeSubscriber(subscriber synccommitteesubscriber.Service) Parameter

WithSyncCommitteeSubscriber sets the sync committee subscriber.

func WithValidatingAccountsProvider 

func WithValidatingAccountsProvider(provider accountmanager.ValidatingAccountsProvider) Parameter

WithValidatingAccountsProvider sets the validating accounts provider.

func WithVerifySyncCommitteeInclusion added in v1.9.0 

func WithVerifySyncCommitteeInclusion(shouldVerify bool) Parameter

WithVerifySyncCommitteeInclusion sets the flag for whether we should verify sync committee inclusion in SyncAggregate.

func WithWaitedForGenesis added in v1.7.0 

func WithWaitedForGenesis(waitedForGenesis bool) Parameter

WithWaitedForGenesis is true if we waited for genesis.

type Service 

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

Service is the co-ordination system for vouch. It runs purely against clock events, setting up jobs for the validator's processes of block proposal, attestation creation and attestation aggregation.

func New 

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

New creates a new controller.

func (*Service) AttestAndScheduleAggregate 

func (s *Service) AttestAndScheduleAggregate(ctx context.Context, data interface{})

AttestAndScheduleAggregate attests, then schedules aggregation jobs as required.

func (*Service) HandleBlockEvent added in v1.7.0 

func (s *Service) HandleBlockEvent(event *apiv1.Event)

HandleBlockEvent handles the "block" events from the beacon node.

func (*Service) HandleHeadEvent added in v0.9.0 

func (s *Service) HandleHeadEvent(event *apiv1.Event)

HandleHeadEvent handles the "head" events from the beacon node.

func (*Service) HasPendingAttestations added in v1.5.0 

func (s *Service) HasPendingAttestations(_ context.Context,
	slot phase0.Slot,
) bool

HasPendingAttestations returns true if there are pending attestations for the given slot.

func (*Service) VerifySyncCommitteeMessages added in v1.9.0 

func (s *Service) VerifySyncCommitteeMessages(ctx context.Context, data any)

VerifySyncCommitteeMessages handles the "head" events from the beacon node for sync committee verification.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.