metrics

Documentation

Index

• type PipewaveMetrics
  • func New() *PipewaveMetrics
  • func (m *PipewaveMetrics) RecordConnectionClose(ctx context.Context, connType string)
  • func (m *PipewaveMetrics) RecordConnectionDuration(ctx context.Context, seconds float64, connType string)
  • func (m *PipewaveMetrics) RecordConnectionOpen(ctx context.Context, connType string)
  • func (m *PipewaveMetrics) RecordMessageReceived(ctx context.Context)
  • func (m *PipewaveMetrics) RecordMessageSent(ctx context.Context, target string)
  • func (m *PipewaveMetrics) RecordPubsubMessage(ctx context.Context)

Types

type PipewaveMetrics

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

PipewaveMetrics holds all OTEL metrics instruments for the Pipewave SDK.

func New

func New() *PipewaveMetrics

New creates and registers all Pipewave metrics instruments.

func (*PipewaveMetrics) RecordConnectionClose

func (m *PipewaveMetrics) RecordConnectionClose(ctx context.Context, connType string)

RecordConnectionClose decrements the active connection counter.

func (*PipewaveMetrics) RecordConnectionDuration

func (m *PipewaveMetrics) RecordConnectionDuration(ctx context.Context, seconds float64, connType string)

RecordConnectionDuration records the duration of a WebSocket connection.

func (*PipewaveMetrics) RecordConnectionOpen

func (m *PipewaveMetrics) RecordConnectionOpen(ctx context.Context, connType string)

RecordConnectionOpen increments the active connection counter.

func (*PipewaveMetrics) RecordMessageReceived

func (m *PipewaveMetrics) RecordMessageReceived(ctx context.Context)

RecordMessageReceived increments the messages received counter.

func (*PipewaveMetrics) RecordMessageSent

func (m *PipewaveMetrics) RecordMessageSent(ctx context.Context, target string)

RecordMessageSent increments the messages sent counter.

func (*PipewaveMetrics) RecordPubsubMessage

func (m *PipewaveMetrics) RecordPubsubMessage(ctx context.Context)

RecordPubsubMessage increments the pub/sub messages counter.