github.com/go-redis/redis/v8.clusterNode.Client (field)

25 uses

	github.com/go-redis/redis/v8 (current package)
		cluster.go#L165: 	Client *Client
		cluster.go#L176: 		Client: clOpt.NewClient(opt),
		cluster.go#L188: 	return n.Client.String()
		cluster.go#L192: 	return n.Client.Close()
		cluster.go#L203: 		n.Client.Ping(context.TODO())
		cluster.go#L281: 		if err := node.Client.Close(); err != nil && firstErr == nil {
		cluster.go#L342: 		_ = node.Client.Close()
		cluster.go#L785: 			pipe := node.Client.Pipeline()
		cluster.go#L792: 			lastErr = node.Client.Process(ctx, cmd)
		cluster.go#L861: 			err := fn(ctx, node.Client)
		cluster.go#L899: 			err := fn(ctx, node.Client)
		cluster.go#L935: 		err := fn(ctx, node.Client)
		cluster.go#L973: 		s := node.Client.connPool.Stats()
		cluster.go#L984: 		s := node.Client.connPool.Stats()
		cluster.go#L1024: 		slots, err := node.Client.ClusterSlots(ctx).Result()
		cluster.go#L1032: 		return newClusterState(c.nodes, slots, node.Client.opt.Addr)
		cluster.go#L1060: 			_, err := node.Client.connPool.(*pool.ConnPool).ReapStaleConns()
		cluster.go#L1175: 	return node.Client.hooks.processPipeline(ctx, cmds, func(ctx context.Context, cmds []Cmder) error {
		cluster.go#L1176: 		return node.Client.withConn(ctx, func(ctx context.Context, cn *pool.Conn) error {
		cluster.go#L1333: 	return node.Client.hooks.processTxPipeline(ctx, cmds, func(ctx context.Context, cmds []Cmder) error {
		cluster.go#L1334: 		return node.Client.withConn(ctx, func(ctx context.Context, cn *pool.Conn) error {
		cluster.go#L1457: 		err = node.Client.Watch(ctx, fn, keys...)
		cluster.go#L1513: 			cn, err := node.Client.newConn(context.TODO())
		cluster.go#L1523: 			err := node.Client.connPool.CloseConn(cn)
		cluster.go#L1584: 		info, err := node.Client.Command(c.ctx).Result()