Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for pfxadd (0.09 sec)

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

    limitations under the License.
    */
    
    package queue
    
    import (
    	"k8s.io/kubernetes/pkg/scheduler/framework"
    )
    
    const (
    	// PodAdd is the event when a new pod is added to API server.
    	PodAdd = "PodAdd"
    	// ScheduleAttemptFailure is the event when a schedule attempt fails.
    	ScheduleAttemptFailure = "ScheduleAttemptFailure"
    	// BackoffComplete is the event when a pod finishes backoff.
    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_test.go

    				{eventHappens: &PvcAdd},
    				{podPopped: pod},
    				// This gets added for the pod.
    				{eventHappens: &PvAdd},
    				// This doesn't get added because no plugin is interested in PvUpdate.
    				{eventHappens: &PvUpdate},
    			},
    			wantInFlightPods:   []*v1.Pod{pod},
    			wantInFlightEvents: []interface{}{pod, PvAdd},
    			queueingHintMap: QueueingHintMapPerProfile{
    				"": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/queue/scheduling_queue.go

    		logger.Error(nil, "Error: pod is already in the podBackoff queue", "pod", klog.KObj(pod))
    	}
    	logger.V(5).Info("Pod moved to an internal scheduling queue", "pod", klog.KObj(pod), "event", PodAdd, "queue", activeQ)
    	metrics.SchedulerQueueIncomingPods.WithLabelValues("active", PodAdd).Inc()
    	p.addNominatedPodUnlocked(logger, pInfo.PodInfo, nil)
    	p.cond.Broadcast()
    
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
Back to top