(slot int)
| 925 | } |
| 926 | |
| 927 | func (c *clusterState) slotMasterNode(slot int) (*clusterNode, error) { |
| 928 | nodes := c.slotNodes(slot) |
| 929 | if len(nodes) > 0 { |
| 930 | return nodes[0], nil |
| 931 | } |
| 932 | return c.nodes.Random() |
| 933 | } |
| 934 | |
| 935 | func (c *clusterState) slotSlaveNode(slot int) (*clusterNode, error) { |
| 936 | nodes := c.slotNodes(slot) |
no test coverage detected