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.SyncCommitteeMessageMonitor) 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) Message(ctx context.Context, data interface{}) ([]*altair.SyncCommitteeMessage, error)
  • func (s *Service) Prepare(ctx context.Context, data interface{}) error

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.SyncCommitteeMessageMonitor) 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 beacon block attester.

func New

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

New creates a new sync committee messenger.

func (*Service) Message

func (s *Service) Message(ctx context.Context, data interface{}) ([]*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, data interface{}) error

Prepare prepares in advance of a sync committee message.