Method RecordOperationDuration

extra/redisotel-native/metrics.go:63–126

RecordOperationDuration records db.client.operation.duration metric

(
	ctx context.Context,
	duration time.Duration,
	cmd redis.Cmder,
	attempts int,
	err error,
	cn redis.ConnInfo,
	dbIndex int,
)

// RecordOperationDuration records db.client.operation.duration metric
func (r *metricsRecorder) RecordOperationDuration(
	ctx context.Context,
	duration time.Duration,
	cmd redis.Cmder,
	attempts int,
	err error,
	cn redis.ConnInfo,
	dbIndex int,
) {
	if r.operationDuration == nil {
		return
	}

	// Check if command should be included
	if r.cfg != nil && !r.cfg.isCommandIncluded(cmd.Name()) {
		return
	}

	// Convert duration to seconds (OTel convention for duration metrics)
	durationSeconds := duration.Seconds()

	serverAddr, serverPort := extractServerInfo(cn)

	// Build attributes
	attrs := []attribute.KeyValue{
		// Required attributes
		attribute.String(AttrDBOperationName, cmd.FullName()),
		getLibraryVersionAttr(),
		attribute.Int(AttrRedisClientOperationRetryAttempts, attempts-1), // attempts-1 = retry count

		// Recommended attributes
		attribute.String(AttrDBSystemName, DBSystemRedis),
		attribute.String(AttrServerAddress, serverAddr),
		attribute.String(AttrDBNamespace, strconv.Itoa(dbIndex)),
	}

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

	// Add network.peer.address and network.peer.port from connection
	if cn != nil {
		remoteAddr := cn.RemoteAddr()
		if remoteAddr != nil {
			peerAddr, peerPort := splitHostPort(remoteAddr.String())
			if peerAddr != "" {
				attrs = append(attrs, attribute.String(AttrNetworkPeerAddress, peerAddr))
			}
			if peerPort != "" {
				attrs = append(attrs, attribute.String(AttrNetworkPeerPort, peerPort))
			}
		}
	}

	if err != nil {
		attrs = append(attrs, attribute.String(AttrErrorType, classifyError(err)))
		attrs = append(attrs, attribute.String(AttrRedisClientErrorsCategory, getErrorCategory(err)))
		if statusCode := extractRedisErrorPrefix(err); statusCode != "" {
			attrs = append(attrs, attribute.String(AttrDBResponseStatusCode, statusCode))