opentelemetry

package
v1.3.0 Latest Latest
Warning

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

Go to latest
Published: May 11, 2023 License: LGPL-3.0 Imports: 15 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DefaultMeter added in v1.3.0

func DefaultMeter(ctx context.Context, collectorRawURL string) (metric.Meter, error)

Types

type ChainbridgeMetrics

type ChainbridgeMetrics struct {
	DepositEventCount        metric.Int64Counter
	ExecutionErrorCount      metric.Int64Counter
	ExecutionLatency         metric.Int64Histogram
	ExecutionLatencyPerRoute metric.Int64Histogram
}

func NewChainbridgeMetrics

func NewChainbridgeMetrics(meter metric.Meter) *ChainbridgeMetrics

NewChainbridgeMetrics creates an instance of ChainbridgeMetrics with provided OpenTelemetry meter

type OpenTelemetry

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

func NewOpenTelemetry

func NewOpenTelemetry(meter metric.Meter) *OpenTelemetry

NewOpenTelemetry initializes OpenTelementry metrics

func (*OpenTelemetry) TrackDepositMessage

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

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

func (*OpenTelemetry) TrackExecutionError added in v1.3.0

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

func (*OpenTelemetry) TrackSuccessfulExecution added in v1.3.0

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

Jump to

Keyboard shortcuts

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