Struct pipelineErrInjector

tx_unwatch_test.go:101–101

pipelineErrInjector returns a fixed error for the MULTI/EXEC batch without executing it, simulating a server error reported before EXEC runs (such as -LOADING on the MULTI reply). The watched keys stay armed, so Close must still send UNWATCH.

// -LOADING on the MULTI reply). The watched keys stay armed, so Close must
// still send UNWATCH.
type pipelineErrInjector struct{ err error }

func (h *pipelineErrInjector) DialHook(next redis.DialHook) redis.DialHook { return next }