(ctx context.Context)
| 20 | } |
| 21 | |
| 22 | func (c *ClusterClient) LoadState(ctx context.Context) (*clusterState, error) { |
| 23 | // return c.state.Reload(ctx) |
| 24 | return c.loadState(ctx) |
| 25 | } |
| 26 | |
| 27 | func (c *ClusterClient) SlotAddrs(ctx context.Context, slot int) []string { |
| 28 | state, err := c.state.Get(ctx) |
no test coverage detected