registrations

Dec 12, 2024

Changes in this version

+ type Config struct

+ ActiveValidatorsFetchInterval human.Duration

+ Enabled *bool

+ NumShards int

+ Shard int

+ TargetSweepDuration human.Duration

+ Workers int

+ func (c *Config) Validate() error

+ type RelayValidatorRegistrationScraper struct

+ func NewRelayValidatorRegistrationScraper(log logrus.FieldLogger, workers int, r *relay.Client, ...) *RelayValidatorRegistrationScraper

+ func (w *RelayValidatorRegistrationScraper) Add(validator *apiv1.Validator)

+ func (w *RelayValidatorRegistrationScraper) Start(ctx context.Context) error

+ func (w *RelayValidatorRegistrationScraper) Stop()

+ type ValidatorMonitor struct

+ func NewValidatorMonitor(log logrus.FieldLogger, config *Config, relays []*relay.Client, ...) *ValidatorMonitor

+ func (r *ValidatorMonitor) Start(ctx context.Context) error

+ type ValidatorRegistrationEvent struct

+ Registration *mevrelay.ValidatorRegistration

+ Relay *relay.Client

+ Validator *apiv1.Validator

+ type ValidatorSetWalker struct

+ func NewValidatorSetWalker(shard, numShards int) *ValidatorSetWalker

+ func (v *ValidatorSetWalker) GetValidator(index *phase0.ValidatorIndex) (*apiv1.Validator, error)

+ func (v *ValidatorSetWalker) Marker() *phase0.ValidatorIndex

+ func (v *ValidatorSetWalker) Max() phase0.ValidatorIndex

+ func (v *ValidatorSetWalker) Min() phase0.ValidatorIndex

+ func (v *ValidatorSetWalker) Next() (phase0.ValidatorIndex, error)

+ func (v *ValidatorSetWalker) NumShards() int

+ func (v *ValidatorSetWalker) NumValidatorsInShard() uint64

+ func (v *ValidatorSetWalker) Shard() int

+ func (v *ValidatorSetWalker) Update(validators map[phase0.ValidatorIndex]*apiv1.Validator)

+ func (v *ValidatorSetWalker) ValidatorMap() map[phase0.ValidatorIndex]*apiv1.Validator

+ func (v *ValidatorSetWalker) Validators() []phase0.ValidatorIndex