standard

Documentation

Index

• type Parameter
  • func WithBeaconBlockRootProvider(provider eth2client.BeaconBlockRootProvider) Parameter
  • func WithChainTimeService(service chaintime.Service) Parameter
  • func WithLogLevel(logLevel zerolog.Level) Parameter
  • func WithMonitor(monitor metrics.Service) Parameter
  • func WithProcessConcurrency(concurrency int64) Parameter
  • func WithSpecProvider(provider eth2client.SpecProvider) Parameter
  • func WithSyncCommitteeAggregator(aggregator synccommitteeaggregator.Service) Parameter
  • func WithSyncCommitteeMessagesSubmitter(submitter submitter.SyncCommitteeMessagesSubmitter) Parameter
  • func WithSyncCommitteeRootSigner(signer signer.SyncCommitteeRootSigner) Parameter
  • func WithSyncCommitteeSelectionSigner(signer signer.SyncCommitteeSelectionSigner) Parameter
  • func WithSyncCommitteeSubscriptionsSubmitter(submitter submitter.SyncCommitteeSubscriptionsSubmitter) Parameter
  • func WithValidatingAccountsProvider(provider accountmanager.ValidatingAccountsProvider) Parameter
• type Service
  • func New(ctx context.Context, params ...Parameter) (*Service, error)
  • func (s *Service) GetDataUsedForSlot(slot phase0.Slot) (synccommitteemessenger.SlotData, bool)
  • func (s *Service) Message(ctx context.Context, duty *synccommitteemessenger.Duty) ([]*altair.SyncCommitteeMessage, error)
  • func (s *Service) Prepare(ctx context.Context, duty *synccommitteemessenger.Duty) error
  • func (s *Service) RemoveHistoricDataUsedForSlotVerification(currentSlot phase0.Slot)
  • func (s *Service) UpdateSyncCommitteeDataRecord(slot phase0.Slot, root phase0.Root, ...)

Types

type Parameter

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

Parameter is the interface for service parameters.

func WithBeaconBlockRootProvider

func WithBeaconBlockRootProvider(provider eth2client.BeaconBlockRootProvider) Parameter

WithBeaconBlockRootProvider sets the beacon block root provider.

func WithChainTimeService

func WithChainTimeService(service chaintime.Service) Parameter

WithChainTimeService sets the chaintime service.

func WithLogLevel

func WithLogLevel(logLevel zerolog.Level) Parameter

WithLogLevel sets the log level for the module.

func WithMonitor

func WithMonitor(monitor metrics.Service) Parameter

WithMonitor sets the monitor for this module.

func WithProcessConcurrency

func WithProcessConcurrency(concurrency int64) Parameter

WithProcessConcurrency sets the concurrency for the service.

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 WithSyncCommitteeMessagesSubmitter

func WithSyncCommitteeMessagesSubmitter(submitter submitter.SyncCommitteeMessagesSubmitter) Parameter

WithSyncCommitteeMessagesSubmitter sets the sync committee messages submitter.

func WithSyncCommitteeRootSigner

func WithSyncCommitteeRootSigner(signer signer.SyncCommitteeRootSigner) Parameter

WithSyncCommitteeRootSigner sets the sync committee root signer.

func WithSyncCommitteeSelectionSigner

func WithSyncCommitteeSelectionSigner(signer signer.SyncCommitteeSelectionSigner) Parameter

WithSyncCommitteeSelectionSigner sets the sync committee selection signer.

func WithSyncCommitteeSubscriptionsSubmitter

func WithSyncCommitteeSubscriptionsSubmitter(submitter submitter.SyncCommitteeSubscriptionsSubmitter) Parameter

WithSyncCommitteeSubscriptionsSubmitter sets the sync committee subscriptions submitter.

func WithValidatingAccountsProvider

func WithValidatingAccountsProvider(provider accountmanager.ValidatingAccountsProvider) Parameter

WithValidatingAccountsProvider sets the account manager.

type Service

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

Service is a sync committee messenger.

func New

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

New creates a new sync committee messenger.

func (*Service) GetDataUsedForSlot

func (s *Service) GetDataUsedForSlot(slot phase0.Slot) (synccommitteemessenger.SlotData, bool)

GetDataUsedForSlot returns slot data recorded for the sync committee message for a given slot.

func (*Service) Message

func (s *Service) Message(ctx context.Context, duty *synccommitteemessenger.Duty) ([]*altair.SyncCommitteeMessage, error)

Message generates and broadcasts sync committee messages for a slot. It returns a list of messages made.

func (*Service) Prepare

func (s *Service) Prepare(ctx context.Context, duty *synccommitteemessenger.Duty) error

Prepare prepares in advance of a sync committee message.

func (*Service) RemoveHistoricDataUsedForSlotVerification

func (s *Service) RemoveHistoricDataUsedForSlotVerification(currentSlot phase0.Slot)

RemoveHistoricDataUsedForSlotVerification goes through the sync committee data stored for each slot and removes old slots.

func (*Service) UpdateSyncCommitteeDataRecord

func (s *Service) UpdateSyncCommitteeDataRecord(
	slot phase0.Slot,
	root phase0.Root,
	validatorToCommitteeIndex map[phase0.ValidatorIndex][]phase0.CommitteeIndex,
)

UpdateSyncCommitteeDataRecord updates the internal map of slot to slot data used for the sync committee message.