metrics

package
v0.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 1, 2026 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Metrics

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

Metrics represents the metrics server for the validator

func NewMetrics

func NewMetrics(serverAddress, chainID string, logger *utils.ZapLogger) *Metrics

NewMetrics creates a new metrics server

func (*Metrics) RecordAttestationConfirmed

func (m *Metrics) RecordAttestationConfirmed()

RecordAttestationConfirmed increments the attestation confirmed counter

func (*Metrics) RecordAttestationFailure

func (m *Metrics) RecordAttestationFailure()

RecordAttestationFailure increments the attestation failure counter

func (*Metrics) RecordAttestationSubmitted

func (m *Metrics) RecordAttestationSubmitted()

RecordAttestationSubmitted increments the attestation submitted counter

func (*Metrics) RecordSignerBalanceAboveThreshold added in v0.2.7

func (m *Metrics) RecordSignerBalanceAboveThreshold()

RecordSignerBalanceAboveThreshold sets the value to 0

func (*Metrics) RecordSignerBalanceBelowThreshold added in v0.2.7

func (m *Metrics) RecordSignerBalanceBelowThreshold()

RecordSignerBalanceBelowThreshold sets the value to 1

func (*Metrics) Start

func (m *Metrics) Start() error

Start starts the metrics server

func (*Metrics) Stop

func (m *Metrics) Stop(ctx context.Context) error

Stop stops the metrics server

func (*Metrics) UpdateEpochInfo

func (m *Metrics) UpdateEpochInfo(epochInfo *types.EpochInfo, targetBlock uint64)

UpdateEpochInfo updates the epoch-related metrics

func (*Metrics) UpdateLatestBlockNumber

func (m *Metrics) UpdateLatestBlockNumber(blockNumber uint64)

UpdateLatestBlockNumber updates the latest block number metric

func (*Metrics) UpdateSignerBalance added in v0.2.7

func (m *Metrics) UpdateSignerBalance(balance float64)

UpdateSignerBalance set's the signer account balance. If it is too big a default max value is set instead

type NoOpMetrics

type NoOpMetrics struct{}

func NewNoOpMetrics

func NewNoOpMetrics() *NoOpMetrics

func (*NoOpMetrics) RecordAttestationConfirmed

func (m *NoOpMetrics) RecordAttestationConfirmed()

func (*NoOpMetrics) RecordAttestationFailure

func (m *NoOpMetrics) RecordAttestationFailure()

func (*NoOpMetrics) RecordAttestationSubmitted

func (m *NoOpMetrics) RecordAttestationSubmitted()

func (*NoOpMetrics) RecordSignerBalanceAboveThreshold added in v0.2.7

func (m *NoOpMetrics) RecordSignerBalanceAboveThreshold()

func (*NoOpMetrics) RecordSignerBalanceBelowThreshold added in v0.2.7

func (m *NoOpMetrics) RecordSignerBalanceBelowThreshold()

func (*NoOpMetrics) UpdateEpochInfo

func (m *NoOpMetrics) UpdateEpochInfo(epochInfo *types.EpochInfo, targetBlock uint64)

func (*NoOpMetrics) UpdateLatestBlockNumber

func (m *NoOpMetrics) UpdateLatestBlockNumber(blockNumber uint64)

func (*NoOpMetrics) UpdateSignerBalance added in v0.2.7

func (m *NoOpMetrics) UpdateSignerBalance(balance float64)

type Tracer

type Tracer interface {
	UpdateLatestBlockNumber(blockNumber uint64)
	UpdateEpochInfo(epochInfo *types.EpochInfo, targetBlock uint64)
	UpdateSignerBalance(balance float64)
	RecordAttestationSubmitted()
	RecordAttestationFailure()
	RecordAttestationConfirmed()
	RecordSignerBalanceAboveThreshold()
	RecordSignerBalanceBelowThreshold()
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL