standard

package
v1.5.0-rc7 Latest Latest
Warning

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

 Go to latest Published: Jun 26, 2022 License: Apache-2.0 Imports: 24 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 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 WithForkScheduleProvider added in v1.2.0 

func WithForkScheduleProvider(provider eth2client.ForkScheduleProvider) Parameter

WithForkScheduleProvider sets the fork schedule provider.

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 WithReorgs added in v1.2.0 

func WithReorgs(reorgs bool) Parameter

WithReorgs sets or unsets reorgs.

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.

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) HandleHeadEvent added in v0.9.0 

func (s *Service) HandleHeadEvent(event *api.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.

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.