diff options
Diffstat (limited to 'vendor/github.com/go-redis/redis/export_test.go')
-rw-r--r-- | vendor/github.com/go-redis/redis/export_test.go | 46 |
1 files changed, 0 insertions, 46 deletions
diff --git a/vendor/github.com/go-redis/redis/export_test.go b/vendor/github.com/go-redis/redis/export_test.go deleted file mode 100644 index bcc18c457..000000000 --- a/vendor/github.com/go-redis/redis/export_test.go +++ /dev/null @@ -1,46 +0,0 @@ -package redis - -import ( - "net" - "time" - - "github.com/go-redis/redis/internal/pool" -) - -func (c *baseClient) Pool() pool.Pooler { - return c.connPool -} - -func (c *PubSub) SetNetConn(netConn net.Conn) { - c.cn = pool.NewConn(netConn) -} - -func (c *PubSub) ReceiveMessageTimeout(timeout time.Duration) (*Message, error) { - return c.receiveMessage(timeout) -} - -func (c *ClusterClient) SlotAddrs(slot int) []string { - state, err := c.state() - if err != nil { - panic(err) - } - - var addrs []string - for _, n := range state.slotNodes(slot) { - addrs = append(addrs, n.Client.getAddr()) - } - return addrs -} - -// SwapSlot swaps a slot's master/slave address for testing MOVED redirects. -func (c *ClusterClient) SwapSlotNodes(slot int) { - state, err := c.state() - if err != nil { - panic(err) - } - - nodes := state.slots[slot] - if len(nodes) == 2 { - nodes[0], nodes[1] = nodes[1], nodes[0] - } -} |