standard

Documentation

Index

• type 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 WithBeaconChainHeadUpdatedSource(source eth2client.BeaconChainHeadUpdatedSource) Parameter
  • func WithBeaconCommitteeSubscriber(subscriber beaconcommitteesubscriber.Service) Parameter
  • func WithChainTimeService(service chaintime.Service) Parameter
  • func WithLogLevel(logLevel zerolog.Level) Parameter
  • func WithMonitor(monitor metrics.ControllerMonitor) Parameter
  • func WithProposerDutiesProvider(provider eth2client.ProposerDutiesProvider) Parameter
  • func WithScheduler(scheduler scheduler.Service) Parameter
  • func WithSlotDurationProvider(provider eth2client.SlotDurationProvider) Parameter
  • func WithSlotsPerEpochProvider(provider eth2client.SlotsPerEpochProvider) 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) OnBeaconChainHeadUpdated(ctx context.Context, slot uint64, stateRoot []byte, bodyRoot []byte, ...)

Types

type Parameter

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

Parameter is the interface for service parameters.

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 WithBeaconChainHeadUpdatedSource

func WithBeaconChainHeadUpdatedSource(source eth2client.BeaconChainHeadUpdatedSource) Parameter

WithBeaconChainHeadUpdatedSource sets the source for an OnBeaconChainHeadUpdated request

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 WithLogLevel

func WithLogLevel(logLevel zerolog.Level) Parameter

WithLogLevel sets the log level for the module.

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 WithScheduler

func WithScheduler(scheduler scheduler.Service) Parameter

WithScheduler sets the scheduler.

func WithSlotDurationProvider

func WithSlotDurationProvider(provider eth2client.SlotDurationProvider) Parameter

WithSlotDurationProvider sets the slot duration provider.

func WithSlotsPerEpochProvider

func WithSlotsPerEpochProvider(provider eth2client.SlotsPerEpochProvider) Parameter

WithSlotsPerEpochProvider sets the slots per epoch provider.

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

func (s *Service) OnBeaconChainHeadUpdated(ctx context.Context, slot uint64, stateRoot []byte, bodyRoot []byte, epochTransitioni bool)

OnBeaconChainHeadUpdated runs attestations for a slot immediately, if the update is for the current slot.