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 WithBeaconCommitteeSubscriber(subscriber beaconcommitteesubscriber.Service) Parameter
  • func WithChainTimeService(service chaintime.Service) Parameter
  • func WithEventsProvider(provider eth2client.EventsProvider) 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) HandleHeadEvent(event *api.Event)

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

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

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