Method ProcessHook

example_instrumentation_test.go:24–31

(hook redis.ProcessHook)

}

func (redisHook) ProcessHook(hook redis.ProcessHook) redis.ProcessHook {
	return func(ctx context.Context, cmd redis.Cmder) error {
		fmt.Printf("starting processing: <%v>\n", cmd.Args())
		err := hook(ctx, cmd)
		fmt.Printf("finished processing: <%v>\n", cmd.Args())
		return err
	}
}

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