WaitRingTokensStability waits for the Ring to be unchanged at least for minStability time period, excluding transitioning between allowed states (e.g. JOINING->ACTIVE if allowed by op). This can be used to avoid wasting resources on moving data around due to multiple changes in the Ring.
(ctx context.Context, r *Ring, op Operation, minStability, maxWaiting time.Duration)
| 71 | // This can be used to avoid wasting resources on moving data around |
| 72 | // due to multiple changes in the Ring. |
| 73 | func WaitRingTokensStability(ctx context.Context, r *Ring, op Operation, minStability, maxWaiting time.Duration) error { |
| 74 | return waitStability(ctx, r, op, minStability, maxWaiting, HasReplicationSetChangedWithoutState) |
| 75 | } |
| 76 | |
| 77 | func waitStability(ctx context.Context, r *Ring, op Operation, minStability, maxWaiting time.Duration, isChanged func(ReplicationSet, ReplicationSet) bool) error { |
| 78 | // Configure the max waiting time as a context deadline. |