gopkgsv2/cache/redis/pipeline.go

package redis

import (
	"github.com/go-redis/redis"
)

func (p *Redis) Pipeline() redis.Pipeliner {
	if p.cluster {
		return p.cclient.Pipeline()
	}
	return p.client.Pipeline()
}