relaymonitor

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