Method RecordConnectionClosed

extra/redisotel-native/metrics.go:699–741

RecordConnectionClosed records redis.client.connection.closed metric

(
	ctx context.Context,
	cn redis.ConnInfo,
	reason string,
	err error,
)

// RecordConnectionClosed records redis.client.connection.closed metric
func (r *metricsRecorder) RecordConnectionClosed(
	ctx context.Context,
	cn redis.ConnInfo,
	reason string,
	err error,
) {
	if r.connectionClosed == nil {
		return
	}

	// Build attributes
	attrs := []attribute.KeyValue{
		attribute.String(AttrDBSystemName, DBSystemRedis),
		getLibraryVersionAttr(),
	}

	// Use pool name from connection (set when connection was created)
	if cn != nil {
		poolName := cn.PoolName()
		if poolName != "" {
			attrs = append(attrs, attribute.String(AttrDBClientConnectionPoolName, poolName))
		}
	}

	// Add error type and category (always required per spec)
	// Use classifyError to normalize error messages and prevent high cardinality
	if err != nil {
		// Normalize the close reason to prevent high cardinality from variable data
		// (e.g., port numbers, connection IDs in error messages)
		normalizedReason := classifyError(err)
		attrs = append(attrs, attribute.String(AttrRedisClientConnectionCloseReason, normalizedReason))
		attrs = append(attrs, attribute.String(AttrErrorType, normalizedReason))
		attrs = append(attrs, attribute.String(AttrRedisClientErrorsCategory, getErrorCategory(err)))
	} else {
		// For non-error closures, use reason directly (these are controlled strings like "pool_closed")
		attrs = append(attrs, attribute.String(AttrRedisClientConnectionCloseReason, reason))
		attrs = append(attrs, attribute.String(AttrErrorType, reason))
		attrs = append(attrs, attribute.String(AttrRedisClientErrorsCategory, getErrorCategoryFromString(reason)))
	}

	// Record the counter
	r.connectionClosed.Add(ctx, 1, metric.WithAttributes(attrs...))
}

// RecordPubSubMessage records redis.client.pubsub.messages metric
func (r *metricsRecorder) RecordPubSubMessage(