type github.com/go-redis/redis/v8.Cmder

132 uses

	github.com/go-redis/redis/v8 (current package)
		cluster.go#L749: func (c *ClusterClient) Process(ctx context.Context, cmd Cmder) error {
		cluster.go#L753: func (c *ClusterClient) process(ctx context.Context, cmd Cmder) error {
		cluster.go#L762: func (c *ClusterClient) _process(ctx context.Context, cmd Cmder) error {
		cluster.go#L1077: func (c *ClusterClient) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) {
		cluster.go#L1081: func (c *ClusterClient) processPipeline(ctx context.Context, cmds []Cmder) error {
		cluster.go#L1085: func (c *ClusterClient) _processPipeline(ctx context.Context, cmds []Cmder) error {
		cluster.go#L1106: 			go func(node *clusterNode, cmds []Cmder) {
		cluster.go#L1133: func (c *ClusterClient) mapCmdsByNode(ctx context.Context, cmdsMap *cmdsMap, cmds []Cmder) error {
		cluster.go#L1162: func (c *ClusterClient) cmdsAreReadOnly(cmds []Cmder) bool {
		cluster.go#L1173: 	ctx context.Context, node *clusterNode, cmds []Cmder, failedCmds *cmdsMap,
		cluster.go#L1175: 	return node.Client.hooks.processPipeline(ctx, cmds, func(ctx context.Context, cmds []Cmder) error {
		cluster.go#L1195: 	cmds []Cmder,
		cluster.go#L1220: 	ctx context.Context, cmd Cmder, err error, failedCmds *cmdsMap,
		cluster.go#L1256: func (c *ClusterClient) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) {
		cluster.go#L1260: func (c *ClusterClient) processTxPipeline(ctx context.Context, cmds []Cmder) error {
		cluster.go#L1264: func (c *ClusterClient) _processTxPipeline(ctx context.Context, cmds []Cmder) error {
		cluster.go#L1279: 		cmdsMap := map[*clusterNode][]Cmder{node: cmds}
		cluster.go#L1293: 				go func(node *clusterNode, cmds []Cmder) {
		cluster.go#L1321: func (c *ClusterClient) mapCmdsBySlot(cmds []Cmder) map[int][]Cmder {
		cluster.go#L1322: 	cmdsMap := make(map[int][]Cmder)
		cluster.go#L1331: 	ctx context.Context, node *clusterNode, cmds []Cmder, failedCmds *cmdsMap,
		cluster.go#L1333: 	return node.Client.hooks.processTxPipeline(ctx, cmds, func(ctx context.Context, cmds []Cmder) error {
		cluster.go#L1366: 	cmds []Cmder,
		cluster.go#L1404: 	ctx context.Context, cmds []Cmder,
		cluster.go#L1612: func (c *ClusterClient) cmdSlot(cmd Cmder) int {
		cluster.go#L1622: func cmdSlot(cmd Cmder, pos int) int {
		cluster.go#L1690: 	m  map[*clusterNode][]Cmder
		cluster.go#L1695: 		m: make(map[*clusterNode][]Cmder),
		cluster.go#L1699: func (m *cmdsMap) Add(node *clusterNode, cmds ...Cmder) {
		command.go#L15: type Cmder interface {
		command.go#L29: func setCmdsErr(cmds []Cmder, e error) {
		command.go#L37: func cmdsFirstErr(cmds []Cmder) error {
		command.go#L46: func writeCmds(wr *proto.Writer, cmds []Cmder) error {
		command.go#L55: func writeCmd(wr *proto.Writer, cmd Cmder) error {
		command.go#L59: func cmdFirstKeyPos(cmd Cmder, info *CommandInfo) int {
		command.go#L82: func cmdString(cmd Cmder, val interface{}) string {
		command.go#L113: var _ Cmder = (*Cmd)(nil)
		command.go#L336: var _ Cmder = (*SliceCmd)(nil)
		command.go#L377: var _ Cmder = (*StatusCmd)(nil)
		command.go#L413: var _ Cmder = (*IntCmd)(nil)
		command.go#L453: var _ Cmder = (*IntSliceCmd)(nil)
		command.go#L500: var _ Cmder = (*DurationCmd)(nil)
		command.go#L549: var _ Cmder = (*TimeCmd)(nil)
		command.go#L602: var _ Cmder = (*BoolCmd)(nil)
		command.go#L659: var _ Cmder = (*StringCmd)(nil)
		command.go#L752: var _ Cmder = (*FloatCmd)(nil)
		command.go#L788: var _ Cmder = (*StringSliceCmd)(nil)
		command.go#L841: var _ Cmder = (*BoolSliceCmd)(nil)
		command.go#L887: var _ Cmder = (*StringStringMapCmd)(nil)
		command.go#L939: var _ Cmder = (*StringIntMapCmd)(nil)
		command.go#L991: var _ Cmder = (*StringStructMapCmd)(nil)
		command.go#L1042: var _ Cmder = (*XMessageSliceCmd)(nil)
		command.go#L1142: var _ Cmder = (*XStreamSliceCmd)(nil)
		command.go#L1214: var _ Cmder = (*XPendingCmd)(nil)
		command.go#L1316: var _ Cmder = (*XPendingExtCmd)(nil)
		command.go#L1399: var _ Cmder = (*XInfoGroupsCmd)(nil)
		command.go#L1486: var _ Cmder = (*ZSliceCmd)(nil)
		command.go#L1541: var _ Cmder = (*ZWithKeyCmd)(nil)
		command.go#L1604: var _ Cmder = (*ScanCmd)(nil)
		command.go#L1659: var _ Cmder = (*ClusterSlotsCmd)(nil)
		command.go#L1779: var _ Cmder = (*GeoLocationCmd)(nil)
		command.go#L1926: var _ Cmder = (*GeoPosCmd)(nil)
		command.go#L2003: var _ Cmder = (*CommandsInfoCmd)(nil)
		command.go#L2190: var _ Cmder = (*SlowLogCmd)(nil)
		commands.go#L71: 	Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)
		commands.go#L73: 	TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)
		commands.go#L345: type cmdable func(ctx context.Context, cmd Cmder) error
		commands.go#L347: type statefulCmdable func(ctx context.Context, cmd Cmder) error
		pipeline.go#L10: type pipelineExecer func(context.Context, []Cmder) error
		pipeline.go#L28: 	Process(ctx context.Context, cmd Cmder) error
		pipeline.go#L31: 	Exec(ctx context.Context) ([]Cmder, error)
		pipeline.go#L47: 	cmds   []Cmder
		pipeline.go#L63: func (c *Pipeline) Process(ctx context.Context, cmd Cmder) error {
		pipeline.go#L100: func (c *Pipeline) Exec(ctx context.Context) ([]Cmder, error) {
		pipeline.go#L118: func (c *Pipeline) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) {
		pipeline.go#L131: func (c *Pipeline) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) {
		pubsub.go#L93: func (c *PubSub) writeCmd(ctx context.Context, cn *pool.Conn, cmd Cmder) error {
		redis.go#L23: 	BeforeProcess(ctx context.Context, cmd Cmder) (context.Context, error)
		redis.go#L24: 	AfterProcess(ctx context.Context, cmd Cmder) error
		redis.go#L26: 	BeforeProcessPipeline(ctx context.Context, cmds []Cmder) (context.Context, error)
		redis.go#L27: 	AfterProcessPipeline(ctx context.Context, cmds []Cmder) error
		redis.go#L49: 	ctx context.Context, cmd Cmder, fn func(context.Context, Cmder) error,
		redis.go#L80: 	ctx context.Context, cmds []Cmder, fn func(context.Context, []Cmder) error,
		redis.go#L111: 	ctx context.Context, cmds []Cmder, fn func(context.Context, []Cmder) error,
		redis.go#L285: func (c *baseClient) process(ctx context.Context, cmd Cmder) error {
		redis.go#L294: func (c *baseClient) _process(ctx context.Context, cmd Cmder) error {
		redis.go#L342: func (c *baseClient) cmdTimeout(cmd Cmder) time.Duration {
		redis.go#L374: func (c *baseClient) processPipeline(ctx context.Context, cmds []Cmder) error {
		redis.go#L378: func (c *baseClient) processTxPipeline(ctx context.Context, cmds []Cmder) error {
		redis.go#L382: type pipelineProcessor func(context.Context, *pool.Conn, []Cmder) (bool, error)
		redis.go#L385: 	ctx context.Context, cmds []Cmder, p pipelineProcessor,
		redis.go#L396: 	ctx context.Context, cmds []Cmder, p pipelineProcessor,
		redis.go#L420: 	ctx context.Context, cn *pool.Conn, cmds []Cmder,
		redis.go#L435: func pipelineReadCmds(rd *proto.Reader, cmds []Cmder) error {
		redis.go#L446: 	ctx context.Context, cn *pool.Conn, cmds []Cmder,
		redis.go#L470: func wrapMultiExec(ctx context.Context, cmds []Cmder) []Cmder {
		redis.go#L474: 	cmds = append(cmds, make([]Cmder, 2)...)
		redis.go#L481: func txPipelineReadQueued(rd *proto.Reader, statusCmd *StatusCmd, cmds []Cmder) error {
		redis.go#L577: func (c *Client) Process(ctx context.Context, cmd Cmder) error {
		redis.go#L581: func (c *Client) processPipeline(ctx context.Context, cmds []Cmder) error {
		redis.go#L585: func (c *Client) processTxPipeline(ctx context.Context, cmds []Cmder) error {
		redis.go#L602: func (c *Client) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) {
		redis.go#L615: func (c *Client) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) {
		redis.go#L715: func (c *Conn) Process(ctx context.Context, cmd Cmder) error {
		redis.go#L719: func (c *Conn) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) {
		redis.go#L732: func (c *Conn) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) {
		ring.go#L453: func (c *Ring) Process(ctx context.Context, cmd Cmder) error {
		ring.go#L580: func (c *Ring) cmdShard(cmd Cmder) (*ringShard, error) {
		ring.go#L590: func (c *Ring) process(ctx context.Context, cmd Cmder) error {
		ring.go#L599: func (c *Ring) _process(ctx context.Context, cmd Cmder) error {
		ring.go#L621: func (c *Ring) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) {
		ring.go#L634: func (c *Ring) processPipeline(ctx context.Context, cmds []Cmder) error {
		ring.go#L635: 	return c.hooks.processPipeline(ctx, cmds, func(ctx context.Context, cmds []Cmder) error {
		ring.go#L640: func (c *Ring) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) {
		ring.go#L653: func (c *Ring) processTxPipeline(ctx context.Context, cmds []Cmder) error {
		ring.go#L654: 	return c.hooks.processPipeline(ctx, cmds, func(ctx context.Context, cmds []Cmder) error {
		ring.go#L660: 	ctx context.Context, cmds []Cmder, tx bool,
		ring.go#L662: 	cmdsMap := make(map[string][]Cmder)
		ring.go#L675: 		go func(hash string, cmds []Cmder) {
		ring.go#L687: 	ctx context.Context, hash string, cmds []Cmder, tx bool,
		sentinel.go#L255: func (c *SentinelClient) Process(ctx context.Context, cmd Cmder) error {
		tx.go#L58: func (c *Tx) Process(ctx context.Context, cmd Cmder) error {
		tx.go#L115: 		exec: func(ctx context.Context, cmds []Cmder) error {
		tx.go#L125: func (c *Tx) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) {
		tx.go#L137: func (c *Tx) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) {
		tx.go#L145: 		exec: func(ctx context.Context, cmds []Cmder) error {
		universal.go#L180: 	Process(ctx context.Context, cmd Cmder) error