@@ -139,17 +139,17 @@ func (src *storeRebalancerControl) scorerOptions() *allocatorimpl.LoadScorerOpti
139
139
}
140
140
}
141
141
142
- func (src * storeRebalancerControl ) checkPendingTicket () (done bool , next time. Time , _ error ) {
142
+ func (src * storeRebalancerControl ) checkPendingTicket () (done bool , _ error ) {
143
143
ticket := src .rebalancerState .pendingTicket
144
144
op , ok := src .controller .Check (ticket )
145
145
if ! ok {
146
- return true , time. Time {}, nil
146
+ return true , nil
147
147
}
148
- done , next = op .Done ()
148
+ done , _ = op .Done ()
149
149
if ! done {
150
- return false , op . Next (), nil
150
+ return false , nil
151
151
}
152
- return true , next , op .Errors ()
152
+ return true , op .Errors ()
153
153
}
154
154
155
155
func (src * storeRebalancerControl ) Tick (ctx context.Context , tick time.Time , state state.State ) {
@@ -207,7 +207,7 @@ func (src *storeRebalancerControl) checkPendingLeaseRebalance(ctx context.Contex
207
207
return true
208
208
}
209
209
210
- done , _ , err := src .checkPendingTicket ()
210
+ done , err := src .checkPendingTicket ()
211
211
if ! done {
212
212
// No more we can do in this tick - we need to wait for the
213
213
// transfer to complete.
@@ -299,7 +299,7 @@ func (src *storeRebalancerControl) checkPendingRangeRebalance(ctx context.Contex
299
299
return true
300
300
}
301
301
302
- done , _ , err := src .checkPendingTicket ()
302
+ done , err := src .checkPendingTicket ()
303
303
if ! done {
304
304
// No more we can do in this tick - we need to wait for the
305
305
// relocate to complete.
0 commit comments