Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for BackoffComplete (0.21 sec)

  1. pkg/scheduler/internal/queue/events.go

    	PodAdd = "PodAdd"
    	// ScheduleAttemptFailure is the event when a schedule attempt fails.
    	ScheduleAttemptFailure = "ScheduleAttemptFailure"
    	// BackoffComplete is the event when a pod finishes backoff.
    	BackoffComplete = "BackoffComplete"
    	// ForceActivate is the event when a pod is moved from unschedulablePods/backoffQ
    	// to activeQ. Usually it's triggered by plugin implementations.
    	ForceActivate = "ForceActivate"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  2. pkg/scheduler/internal/queue/scheduling_queue.go

    			break
    		}
    		if added, _ := p.addToActiveQ(logger, pInfo); added {
    			logger.V(5).Info("Pod moved to an internal scheduling queue", "pod", klog.KObj(pod), "event", BackoffComplete, "queue", activeQ)
    			metrics.SchedulerQueueIncomingPods.WithLabelValues("active", BackoffComplete).Inc()
    			activated = true
    		}
    	}
    
    	if activated {
    		p.cond.Broadcast()
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/queue/scheduling_queue_test.go

    			operations: []operation{
    				popAndRequeueAsBackoff,
    				moveClockForward,
    				flushBackoffQ,
    			},
    			want: ` scheduler_queue_incoming_pods_total{event="BackoffComplete",queue="active"} 3
                scheduler_queue_incoming_pods_total{event="ScheduleAttemptFailure",queue="backoff"} 3
    `,
    		},
    	}
    
    	for _, test := range tests {
    		t.Run(test.name, func(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
Back to top