Method RecordConnectionCount

extra/redisotel-native/metrics.go:839–875

RecordConnectionCount records a change in connection count (UpDownCounter). Per OTel semantic conventions, db.client.connection.count is an UpDownCounter. delta: +1 when connection added, -1 when connection removed state: connection state (e.g., "idle", "used") isPubSub: true if this is a PubSub con

(
	ctx context.Context,
	delta int,
	cn redis.ConnInfo,
	state string,
	isPubSub bool,
)

// state: connection state (e.g., "idle", "used")
// isPubSub: true if this is a PubSub connection
func (r *metricsRecorder) RecordConnectionCount(
	ctx context.Context,
	delta int,
	cn redis.ConnInfo,
	state string,
	isPubSub bool,
) {
	if r.connectionCount == nil {
		return
	}

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

	// 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))

			// Extract server info from pool name
			serverAddr, serverPort, _ := parsePoolName(poolName)
			if serverAddr != "" {
				attrs = append(attrs, attribute.String(AttrServerAddress, serverAddr))
			}
			attrs = addServerPortIfNonDefault(attrs, serverPort)
		}
	}

	// Record the counter (delta can be +1 or -1)
	r.connectionCount.Add(ctx, int64(delta), metric.WithAttributes(attrs...))
}

// RecordPendingRequests records a change in pending requests (UpDownCounter).
// Per OTel semantic conventions, db.client.connection.pending_requests is an UpDownCounter.