opentelemetry

Documentation

Index

• func InitMetricProvider(ctx context.Context, agentURL string) (*sdkmetric.MeterProvider, error)
• type RelayerMetrics
  • func NewRelayerMetrics(meter metric.Meter, attributes ...attribute.KeyValue) (*RelayerMetrics, error)
  • func (t *RelayerMetrics) TrackBlockDelta(domainID uint8, head *big.Int, current *big.Int)
  • func (t *RelayerMetrics) TrackDepositMessage(m *message.Message)
  • func (t *RelayerMetrics) TrackExecutionError(m *message.Message)
  • func (t *RelayerMetrics) TrackSuccessfulExecution(m *message.Message)
  • func (t *RelayerMetrics) TrackSuccessfulExecutionLatency(m *message.Message)

Functions

func InitMetricProvider

func InitMetricProvider(ctx context.Context, agentURL string) (*sdkmetric.MeterProvider, error)

Types

type RelayerMetrics

type RelayerMetrics struct {
	Opts api.MeasurementOption

	DepositEventCount        metric.Int64Counter
	MessageEventTime         map[string]time.Time
	ExecutionErrorCount      metric.Int64Counter
	ExecutionLatency         metric.Int64Histogram
	ExecutionLatencyPerRoute metric.Int64Histogram
	BlockDelta               metric.Int64ObservableGauge
	BlockDeltaMap            map[uint8]*big.Int
	// contains filtered or unexported fields
}

func NewRelayerMetrics

func NewRelayerMetrics(meter metric.Meter, attributes ...attribute.KeyValue) (*RelayerMetrics, error)

NewRelayerMetrics initializes OpenTelemetry metrics

func (*RelayerMetrics) TrackBlockDelta

func (t *RelayerMetrics) TrackBlockDelta(domainID uint8, head *big.Int, current *big.Int)

func (*RelayerMetrics) TrackDepositMessage

func (t *RelayerMetrics) TrackDepositMessage(m *message.Message)

TrackDepositMessage extracts metrics from deposit message and sends them to OpenTelemetry collector

func (*RelayerMetrics) TrackExecutionError

func (t *RelayerMetrics) TrackExecutionError(m *message.Message)

func (*RelayerMetrics) TrackSuccessfulExecution

func (t *RelayerMetrics) TrackSuccessfulExecution(m *message.Message)

func (*RelayerMetrics) TrackSuccessfulExecutionLatency

func (t *RelayerMetrics) TrackSuccessfulExecutionLatency(m *message.Message)