relaymonitor

May 14, 2026

Changes in this version

type Config

+ Tracing observability.TracingConfig

Dec 17, 2025

Changes in this version

+ type BatchIterator interface

+ NextBatch func(ctx context.Context) (*iterator.BatchRequest, error)

type ConsistencyConfig

+ BatchSize int

Dec 11, 2025

Changes in this version

+ type SlotIterator interface

+ Next func(ctx context.Context) (*phase0.Slot, error)

+ UpdateLocation func(ctx context.Context, slot phase0.Slot) error

Sep 3, 2025

Changes in this version

type ForwardFillConfig

+ TrailDistance uint64

Aug 25, 2025

Changes in this version

+ type BackfillConfig struct

+ Enabled bool

+ ToSlot uint64

type Config

+ Consistency *ConsistencyConfig

+ Coordinator *coordinator.Config

+ type ConsistencyConfig struct

+ Backfill *BackfillConfig

+ CheckEveryDuration human.Duration

+ ForwardFill *ForwardFillConfig

+ RateLimitPerRelay float64

+ func (c *ConsistencyConfig) Validate() error

+ type ForwardFillConfig struct

+ Enabled bool

Dec 12, 2024

Changes in this version

type Config

+ ValidatorRegistrations registrations.Config

Dec 2, 2024

Changes in this version

type Config

+ func (c *Config) ApplyOverrides(o *Override, log logrus.FieldLogger) error

+ type Override struct

+ MetricsAddr struct{ ... }

Sep 16, 2024

Changes in this version

type Config

+ FetchProposerPayloadDelivered bool

Sep 2, 2024

Changes in this version

+ type Config struct

+ Ethereum ethereum.Config

+ Labels map[string]string

+ LoggingLevel string

+ MetricsAddr string

+ NTPServer string

+ Name string

+ Outputs []output.Config

+ PProfAddr *string

+ ProbeAddr *string

+ Relays []relay.Config

+ Schedule Schedule

+ func (c *Config) CreateSinks(log logrus.FieldLogger) ([]output.Sink, error)

+ func (c *Config) Validate() error

+ type DuplicateBidCache struct

+ func NewDuplicateBidCache(ttl time.Duration) *DuplicateBidCache

+ func (dc *DuplicateBidCache) Has(relay string, slot phase0.Slot, blockHash string) bool

+ func (dc *DuplicateBidCache) Set(relay string, slot phase0.Slot, blockHash string)

+ type Metrics struct

+ func NewMetrics(namespace, networkName string) *Metrics

+ func (m *Metrics) AddDecoratedEvent(count int, eventType string)

+ type RelayMonitor struct

+ Config *Config

+ func New(ctx context.Context, log logrus.FieldLogger, config *Config) (*RelayMonitor, error)

+ func (r *RelayMonitor) ServeMetrics(ctx context.Context) error

+ func (r *RelayMonitor) ServePProf(ctx context.Context) error

+ func (r *RelayMonitor) ServeProbe(ctx context.Context) error

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

+ type Schedule struct

+ AtSlotTimes []human.Duration

+ func (s *Schedule) Validate() error