spelling: enqueuing
This commit is contained in:
parent
35238fe779
commit
f1d21bfdfe
|
@ -210,7 +210,7 @@ func (b *EvalBroker) processEnqueue(eval *structs.Evaluation, token string) {
|
|||
}
|
||||
|
||||
// processWaitingEnqueue waits the given duration on the evaluation before
|
||||
// enqueueing.
|
||||
// enqueuing.
|
||||
func (b *EvalBroker) processWaitingEnqueue(eval *structs.Evaluation) {
|
||||
timer := time.AfterFunc(eval.Wait, func() {
|
||||
b.enqueueWaiting(eval)
|
||||
|
|
|
@ -1140,7 +1140,7 @@ func TestEvalBroker_Wait(t *testing.T) {
|
|||
}
|
||||
}
|
||||
|
||||
// Ensure that priority is taken into account when enqueueing many evaluations.
|
||||
// Ensure that priority is taken into account when enqueuing many evaluations.
|
||||
func TestEvalBroker_EnqueueAll_Dequeue_Fair(t *testing.T) {
|
||||
t.Parallel()
|
||||
b := testBroker(t, 0)
|
||||
|
|
|
@ -286,7 +286,7 @@ func TestEvalEndpoint_Dequeue_WaitIndex(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestEvalEndpoint_Dequeue_UpdateWaitIndex(t *testing.T) {
|
||||
// test enqueueing an eval, updating a plan result for the same eval and de-queueing the eval
|
||||
// test enqueuing an eval, updating a plan result for the same eval and de-queueing the eval
|
||||
t.Parallel()
|
||||
s1 := TestServer(t, func(c *Config) {
|
||||
c.NumSchedulers = 0 // Prevent automatic dequeue
|
||||
|
|
Loading…
Reference in New Issue