Function RecordPipelineOperationDuration

internal/otel/metrics.go:227–229

RecordPipelineOperationDuration records the total pipeline/transaction duration. This is called from redis.go after pipeline/transaction execution completes. operationName should be "PIPELINE" for regular pipelines or "MULTI" for transactions. err is the error from the pipeline execution (can be nil

(ctx context.Context, duration time.Duration, operationName string, cmdCount int, attempts int, err error, cn *pool.Conn, dbIndex int)

// err is the error from the pipeline execution (can be nil).
// dbIndex is the Redis database index (0-15).
func RecordPipelineOperationDuration(ctx context.Context, duration time.Duration, operationName string, cmdCount int, attempts int, err error, cn *pool.Conn, dbIndex int) {
	getRecorder().RecordPipelineOperationDuration(ctx, duration, operationName, cmdCount, attempts, err, cn, dbIndex)
}

// RecordConnectionCreateTime records the time it took to create a new connection.
func RecordConnectionCreateTime(ctx context.Context, duration time.Duration, cn *pool.Conn) {