WaitRingStability monitors the ring topology for the provided operation and waits until it keeps stable for at least minStability.
(ctx context.Context, r *Ring, op Operation, minStability, maxWaiting time.Duration)
| 62 | // WaitRingStability monitors the ring topology for the provided operation and waits until it |
| 63 | // keeps stable for at least minStability. |
| 64 | func WaitRingStability(ctx context.Context, r *Ring, op Operation, minStability, maxWaiting time.Duration) error { |
| 65 | return waitStability(ctx, r, op, minStability, maxWaiting, HasReplicationSetChanged) |
| 66 | } |
| 67 | |
| 68 | // WaitRingTokensStability waits for the Ring to be unchanged at |
| 69 | // least for minStability time period, excluding transitioning between |