Method RecordError

extra/redisotel-native/metrics.go:583–630

RecordError records client errors (ASK, MOVED, handshake failures, etc.)

(
	ctx context.Context,
	errorType string,
	cn redis.ConnInfo,
	statusCode string,
	isInternal bool,
	retryAttempts int,
)

// RecordError records client errors (ASK, MOVED, handshake failures, etc.)
func (r *metricsRecorder) RecordError(
	ctx context.Context,
	errorType string,
	cn redis.ConnInfo,
	statusCode string,
	isInternal bool,
	retryAttempts int,
) {
	if r.clientErrors == nil {
		return
	}

	// Extract server address and peer address from connection (may be nil for some errors)
	// For client connections, peer address is the same as server address (remote endpoint)
	var serverAddr, serverPort, peerAddr, peerPort string
	if cn != nil {
		serverAddr, serverPort = extractServerInfo(cn)
		peerAddr, peerPort = serverAddr, serverPort // Peer is same as server for client connections
	}

	// Build attributes
	attrs := []attribute.KeyValue{
		attribute.String(AttrDBSystemName, DBSystemRedis),
		attribute.String(AttrErrorType, errorType),
		attribute.String(AttrRedisClientErrorsCategory, getErrorCategoryFromString(errorType)),
		attribute.String(AttrDBResponseStatusCode, statusCode),
		attribute.Bool(AttrRedisClientErrorsInternal, isInternal),
		attribute.Int(AttrRedisClientOperationRetryAttempts, retryAttempts),
		getLibraryVersionAttr(),
	}

	// Add server info if available
	if serverAddr != "" {
		attrs = append(attrs, attribute.String(AttrServerAddress, serverAddr))
		attrs = addServerPortIfNonDefault(attrs, serverPort)
	}

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

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

// RecordMaintenanceNotification records when a maintenance notification is received
func (r *metricsRecorder) RecordMaintenanceNotification(