opentelemetry

Documentation

Index

• type ChainbridgeMetrics
  • func NewChainbridgeMetrics(meter metric.Meter) *ChainbridgeMetrics
• type ConsoleTelemetry
  • func (t *ConsoleTelemetry) TrackDepositMessage(m *message.Message)
• type OpenTelemetry
  • func NewOpenTelemetry(collectorRawURL string) (*OpenTelemetry, error)
  • func (t *OpenTelemetry) MonitorHeadBlocks(chains []relayer.RelayedChain)
  • func (t *OpenTelemetry) MonitorSyncBlocks(chains []relayer.RelayedChain)
  • func (t *OpenTelemetry) TrackDepositMessage(m *message.Message)
  • func (t *OpenTelemetry) TrackHeadBlock(id uint8, value int64, fromAddr string)
  • func (t *OpenTelemetry) TrackSyncBlock(id uint8, value int64, fromAddr string)

Types

type ChainbridgeMetrics

type ChainbridgeMetrics struct {
	DepositEventCount metric.Int64Counter

	HeadBlocks  map[uint8]metric.Int64GaugeObserver
	StartBlocks map[uint8]metric.Int64GaugeObserver
	// contains filtered or unexported fields
}

func NewChainbridgeMetrics

func NewChainbridgeMetrics(meter metric.Meter) *ChainbridgeMetrics

NewChainbridgeMetrics creates an instance of ChainbridgeMetrics with provided OpenTelemetry meter

type ConsoleTelemetry

type ConsoleTelemetry struct{}

ConsoleTelemetry is telemetry that logs metrics and should be used when metrics sending to OpenTelemetry should be disabled

func (*ConsoleTelemetry) TrackDepositMessage

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

type OpenTelemetry

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

func NewOpenTelemetry

func NewOpenTelemetry(collectorRawURL string) (*OpenTelemetry, error)

NewOpenTelemetry initializes OpenTelementry metrics

func (*OpenTelemetry) MonitorHeadBlocks

func (t *OpenTelemetry) MonitorHeadBlocks(chains []relayer.RelayedChain)

func (*OpenTelemetry) MonitorSyncBlocks

func (t *OpenTelemetry) MonitorSyncBlocks(chains []relayer.RelayedChain)

func (*OpenTelemetry) TrackDepositMessage

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

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

func (*OpenTelemetry) TrackHeadBlock

func (t *OpenTelemetry) TrackHeadBlock(id uint8, value int64, fromAddr string)

func (*OpenTelemetry) TrackSyncBlock

func (t *OpenTelemetry) TrackSyncBlock(id uint8, value int64, fromAddr string)