opentelemetry

package

v1.4.2 Latest Latest Go to latest Published: Oct 16, 2023 License: LGPL-3.0 Imports: 12 Imported by: 3

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ChainSafe/chainbridge-core

Links

Open Source Insights

Documentation ¶

Index ¶

func InitMetricProvider(ctx context.Context, agentURL string) (*sdkmetric.MeterProvider, error)
type RelayerMetrics
- func NewRelayerMetrics(meter metric.Meter, attributes ...attribute.KeyValue) (*RelayerMetrics, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func InitMetricProvider ¶ added in v1.4.0

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

Types ¶

type RelayerMetrics ¶ added in v1.4.0

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 ¶ added in v1.4.0

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

NewRelayerMetrics initializes OpenTelemetry metrics

func (*RelayerMetrics) TrackBlockDelta ¶ added in v1.4.0

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

func (*RelayerMetrics) TrackDepositMessage ¶ added in v1.4.0

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

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

func (*RelayerMetrics) TrackExecutionError ¶ added in v1.4.0

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

func (*RelayerMetrics) TrackSuccessfulExecution ¶ added in v1.4.0

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

func (*RelayerMetrics) TrackSuccessfulExecutionLatency ¶ added in v1.4.0

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

Source Files ¶

View all Source files

metrics.go

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