Method RecordPubSubMessage

extra/redisotel-native/metrics.go:744–786

RecordPubSubMessage records redis.client.pubsub.messages metric

(
	ctx context.Context,
	cn redis.ConnInfo,
	direction string,
	channel string,
	sharded bool,
)

// RecordPubSubMessage records redis.client.pubsub.messages metric
func (r *metricsRecorder) RecordPubSubMessage(
	ctx context.Context,
	cn redis.ConnInfo,
	direction string,
	channel string,
	sharded bool,
) {
	if r.pubsubMessages == 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(AttrRedisClientPubSubDirection, direction), // "sent" or "received"
		attribute.Bool(AttrRedisClientPubSubSharded, sharded),
		getLibraryVersionAttr(),
	}

	// Add channel name if not hidden for cardinality reduction
	if !r.cfg.hidePubSubChannelNames && channel != "" {
		attrs = append(attrs, attribute.String(AttrRedisClientPubSubChannel, channel))
	}

	// 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 counter
	r.pubsubMessages.Add(ctx, 1, metric.WithAttributes(attrs...))
}

// RecordStreamLag records redis.client.stream.lag metric
func (r *metricsRecorder) RecordStreamLag(