Method RecordStreamLag

extra/redisotel-native/metrics.go:789–832

RecordStreamLag records redis.client.stream.lag metric

(
	ctx context.Context,
	lag time.Duration,
	cn redis.ConnInfo,
	streamName string,
	consumerGroup string,
	consumerName string,
)

// RecordStreamLag records redis.client.stream.lag metric
func (r *metricsRecorder) RecordStreamLag(
	ctx context.Context,
	lag time.Duration,
	cn redis.ConnInfo,
	streamName string,
	consumerGroup string,
	consumerName string,
) {
	if r.streamLag == nil {
		return
	}

	// Extract server address and peer address from connection
	serverAddr, serverPort := extractServerInfo(cn)
	peerAddr, peerPort := serverAddr, serverPort

	// Build attributes
	attrs := []attribute.KeyValue{
		attribute.String(AttrDBSystemName, DBSystemRedis),
		attribute.String(AttrServerAddress, serverAddr),
		attribute.String(AttrRedisClientStreamConsumerGroup, consumerGroup),
		attribute.String(AttrRedisClientStreamConsumerName, consumerName),
		getLibraryVersionAttr(),
	}

	// Add stream name if not hidden for cardinality reduction
	if !r.cfg.hideStreamNames && streamName != "" {
		attrs = append(attrs, attribute.String(AttrRedisClientStreamName, streamName))
	}

	// Add server.port if not default
	attrs = addServerPortIfNonDefault(attrs, serverPort)

	// Add peer info
	if peerAddr != "" {
		attrs = append(attrs, attribute.String(AttrNetworkPeerAddress, peerAddr))
		if peerPort != "" {
			attrs = append(attrs, attribute.String(AttrNetworkPeerPort, peerPort))
		}
	}

	// Record the histogram (lag in seconds)
	r.streamLag.Record(ctx, lag.Seconds(), metric.WithAttributes(attrs...))
}

// RecordConnectionCount records a change in connection count (UpDownCounter).
// Per OTel semantic conventions, db.client.connection.count is an UpDownCounter.