standard

Documentation

Index

• type Parameter
  • func WithAccountsRefresher(refresher accountmanager.Refresher) Parameter
  • func WithAttestationAggregator(aggregator attestationaggregator.Service) Parameter
  • func WithAttester(attester attester.Service) Parameter
  • func WithAttesterDutiesProvider(provider eth2client.AttesterDutiesProvider) Parameter
  • func WithBeaconBlockProposer(proposer beaconblockproposer.Service) Parameter
  • func WithBeaconCommitteeSubscriber(subscriber beaconcommitteesubscriber.Service) Parameter
  • func WithChainTimeService(service chaintime.Service) Parameter
  • func WithEventsProvider(provider eth2client.EventsProvider) Parameter
  • func WithForkScheduleProvider(provider eth2client.ForkScheduleProvider) Parameter
  • func WithLogLevel(logLevel zerolog.Level) Parameter
  • func WithMaxAttestationDelay(delay time.Duration) Parameter
  • func WithMaxSyncCommitteeMessageDelay(delay time.Duration) Parameter
  • func WithMonitor(monitor metrics.ControllerMonitor) Parameter
  • func WithProposerDutiesProvider(provider eth2client.ProposerDutiesProvider) Parameter
  • func WithReorgs(reorgs bool) Parameter
  • func WithScheduler(scheduler scheduler.Service) Parameter
  • func WithSpecProvider(provider eth2client.SpecProvider) Parameter
  • func WithSyncCommitteeAggregator(aggregator synccommitteeaggregator.Service) Parameter
  • func WithSyncCommitteeDutiesProvider(provider eth2client.SyncCommitteeDutiesProvider) Parameter
  • func WithSyncCommitteeMessenger(messenger synccommitteemessenger.Service) Parameter
  • func WithSyncCommitteeSubscriber(subscriber synccommitteesubscriber.Service) Parameter
  • func WithValidatingAccountsProvider(provider accountmanager.ValidatingAccountsProvider) Parameter
• type Service
  • func New(ctx context.Context, params ...Parameter) (*Service, error)
  • func (s *Service) AttestAndScheduleAggregate(ctx context.Context, data interface{})
  • func (s *Service) HandleHeadEvent(event *api.Event)

Types

type Parameter

type Parameter interface {
	// contains filtered or unexported methods
}

Parameter is the interface for service parameters.

func WithAccountsRefresher

func WithAccountsRefresher(refresher accountmanager.Refresher) Parameter

WithAccountsRefresher sets the account refresher.

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

func WithEventsProvider(provider eth2client.EventsProvider) Parameter

WithEventsProvider sets the events provider.

func WithForkScheduleProvider

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

func WithMaxAttestationDelay(delay time.Duration) Parameter

WithMaxAttestationDelay sets the maximum delay before attesting.

func WithMaxSyncCommitteeMessageDelay

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 WithProposerDutiesProvider

func WithProposerDutiesProvider(provider eth2client.ProposerDutiesProvider) Parameter

WithProposerDutiesProvider sets the proposer duties provider.

func WithReorgs

func WithReorgs(reorgs bool) Parameter

WithReorgs sets or unsets reorgs.

func WithScheduler

func WithScheduler(scheduler scheduler.Service) Parameter

WithScheduler sets the scheduler.

func WithSpecProvider

func WithSpecProvider(provider eth2client.SpecProvider) Parameter

WithSpecProvider sets the spec provider.

func WithSyncCommitteeAggregator

func WithSyncCommitteeAggregator(aggregator synccommitteeaggregator.Service) Parameter

WithSyncCommitteeAggregator sets the sync committee aggregator.

func WithSyncCommitteeDutiesProvider

func WithSyncCommitteeDutiesProvider(provider eth2client.SyncCommitteeDutiesProvider) Parameter

WithSyncCommitteeDutiesProvider sets the sync committee duties provider.

func WithSyncCommitteeMessenger

func WithSyncCommitteeMessenger(messenger synccommitteemessenger.Service) Parameter

WithSyncCommitteeMessenger sets the sync committee messenger.

func WithSyncCommitteeSubscriber

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

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

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