standard

Documentation

Index

• type Parameter
  • func WithLogLevel(logLevel zerolog.Level) Parameter
  • func WithMonitor(monitor metrics.SyncCommitteeSubscriptionMonitor) Parameter
  • func WithSyncCommitteeSubmitter(provider eth2client.SyncCommitteeSubscriptionsSubmitter) Parameter
• type Service
  • func New(_ context.Context, params ...Parameter) (*Service, error)
  • func (s *Service) Subscribe(ctx context.Context, endEpoch phase0.Epoch, duties []*api.SyncCommitteeDuty) error

Types

type Parameter

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

Parameter is the interface for service parameters.

func WithLogLevel

func WithLogLevel(logLevel zerolog.Level) Parameter

WithLogLevel sets the log level for the module.

func WithMonitor

func WithMonitor(monitor metrics.SyncCommitteeSubscriptionMonitor) Parameter

WithMonitor sets the monitor for the module.

func WithSyncCommitteeSubmitter

func WithSyncCommitteeSubmitter(provider eth2client.SyncCommitteeSubscriptionsSubmitter) Parameter

WithSyncCommitteeSubmitter sets the sync committee subscriptions provider.

type Service

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

Service is an beacon committee subscriber.

func New

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

New creates a new sync committee subscriber.

func (*Service) Subscribe

func (s *Service) Subscribe(ctx context.Context,
	endEpoch phase0.Epoch,
	duties []*api.SyncCommitteeDuty,
) error

Subscribe subscribes to sync committees given a set of duties.