Method ProcessPipelineHook

extra/redisotel/tracing.go:145–185

(
	hook redis.ProcessPipelineHook,
)

}

func (th *tracingHook) ProcessPipelineHook(
	hook redis.ProcessPipelineHook,
) redis.ProcessPipelineHook {
	return func(ctx context.Context, cmds []redis.Cmder) error {

		if th.conf.filterProcessPipeline != nil && th.conf.filterProcessPipeline(cmds) {
			return hook(ctx, cmds)
		}

		attrs := make([]attribute.KeyValue, 0, 8)
		attrs = append(attrs,
			attribute.Int("db.redis.num_cmd", len(cmds)),
		)

		if th.conf.callerEnabled {
			fn, file, line := funcFileLine("github.com/redis/go-redis")
			attrs = append(attrs,
				semconv.CodeFunction(fn),
				semconv.CodeFilepath(file),
				semconv.CodeLineNumber(line),
			)
		}

		summary, cmdsString := rediscmd.CmdsString(cmds)
		if th.conf.dbStmtEnabled {
			attrs = append(attrs, semconv.DBStatement(cmdsString))
		}

		opts := th.spanOpts
		opts = append(opts, trace.WithAttributes(attrs...))

		ctx, span := th.conf.tracer.Start(ctx, "redis.pipeline "+summary, opts...)
		defer span.End()

		if err := hook(ctx, cmds); err != nil {
			recordError(span, err)
			return err
		}
		return nil
	}
}

func recordError(span trace.Span, err error) {
	if err != redis.Nil {