executors

Jun 5, 2024

Changes in this version

+ func NewBLSKeysTimeCache(args ArgsBlsKeysTimeCache) (*blsKeysTimeCache, error)

type ArgsBLSKeysExecutor

+ BLSKeysFilter BLSKeysFilter

+ type ArgsBlsKeysTimeCache struct

+ CacheExpiration uint64

+ GetCurrentTimestamp func() int64

+ MaxSnoozeEvents uint32

+ type BLSKeysFilter interface

+ IsInterfaceNil func() bool

+ ShouldNotify func(blsKey string) bool

May 21, 2024

Changes in this version

+ func NewBLSKeysExecutor(args ArgsBLSKeysExecutor) (*blsKeysExecutor, error)

+ func NewNotifiersHandler(args ArgsNotifiersHandler) (*notifiersHandler, error)

+ func NewStatusHandler(name string, notifiersHandler OutputNotifiersHandler) (*statusHandler, error)

+ func NewStatusHandlerTrigger(args ArgsStatusHandlerTrigger) (*statusHandlerTrigger, error)

+ type ArgsBLSKeysExecutor struct

+ BlsKeysFetcher BLSKeysFetcher

+ ExplorerURL string

+ Name string

+ OutputNotifiersHandler OutputNotifiersHandler

+ RatingsChecker RatingsChecker

+ StatusHandler StatusHandler

+ ValidatorStatisticsQuerier ValidatorStatisticsQuerier

+ type ArgsNotifiersHandler struct

+ Notifiers []OutputNotifier

+ NumRetries uint32

+ TimeBetweenRetries time.Duration

+ type ArgsStatusHandlerTrigger struct

+ Executor Executor

+ TimeFunc func() time.Time

+ TriggerDay time.Weekday

+ TriggerHour int

+ TriggerMinute int

+ type BLSKeysFetcher interface

+ GetAllBLSKeys func(ctx context.Context, sender string) ([]string, error)

+ IsInterfaceNil func() bool

+ type Executor interface

+ Execute func(ctx context.Context) error

+ IsInterfaceNil func() bool

+ type OutputNotifier interface

+ IsInterfaceNil func() bool

+ Name func() string

+ OutputMessages func(messages ...core.OutputMessage) error

+ type OutputNotifiersHandler interface

+ IsInterfaceNil func() bool

+ NotifyWithRetry func(caller string, messages ...core.OutputMessage) error

+ type RatingsChecker interface

+ Check func(statistics map[string]*core.ValidatorStatistics, extraBLSKeys []string) ([]core.CheckResponse, error)

+ IsInterfaceNil func() bool

+ type StatusHandler interface

+ CollectKeysProblems func(messages []core.OutputMessage)

+ ErrorEncountered func(err error)

+ Execute func(ctx context.Context) error

+ IsInterfaceNil func() bool

+ NotifyAppStart func()

+ SendCloseMessage func()

+ type ValidatorStatisticsQuerier interface

+ IsInterfaceNil func() bool

+ Query func(ctx context.Context) (map[string]*core.ValidatorStatistics, error)