(ctx context.Context)
| 255 | } |
| 256 | |
| 257 | func (n *ClusterNode) Reset(ctx context.Context) error { |
| 258 | if n.IsMaster() { |
| 259 | _ = n.GetClient().FlushAll(ctx).Err() |
| 260 | } |
| 261 | return n.GetClient().ClusterResetHard(ctx).Err() |
| 262 | } |
| 263 | |
| 264 | func (n *ClusterNode) MigrateSlot(ctx context.Context, slot SlotRange, targetNodeID string) error { |
| 265 | return n.GetClient().Do(ctx, "CLUSTERX", "MIGRATE", slot.String(), targetNodeID).Err() |