Function RecordPubSubMessage

internal/otel/metrics.go:237–239

RecordPubSubMessage records a Pub/Sub message sent or received.

(ctx context.Context, cn *pool.Conn, direction, channel string, sharded bool)

// RecordPubSubMessage records a Pub/Sub message sent or received.
func RecordPubSubMessage(ctx context.Context, cn *pool.Conn, direction, channel string, sharded bool) {
	getRecorder().RecordPubSubMessage(ctx, cn, direction, channel, sharded)
}

// RecordStreamLag records the lag between message creation and consumption in a stream.
func RecordStreamLag(ctx context.Context, lag time.Duration, cn *pool.Conn, streamName, consumerGroup, consumerName string) {