Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for actionType (0.19 sec)

  1. pkg/scheduler/framework/types.go

    		{Event: ClusterEvent{Resource: CSINode, ActionType: All}},
    		{Event: ClusterEvent{Resource: CSIDriver, ActionType: All}},
    		{Event: ClusterEvent{Resource: CSIStorageCapacity, ActionType: All}},
    		{Event: ClusterEvent{Resource: StorageClass, ActionType: All}},
    		{Event: ClusterEvent{Resource: PodSchedulingContext, ActionType: All}},
    		{Event: ClusterEvent{Resource: ResourceClaim, ActionType: All}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  2. pkg/scheduler/scheduler_test.go

    				{Resource: framework.Pod, ActionType: framework.All}: {
    					{PluginName: filterWithoutEnqueueExtensions, QueueingHintFn: defaultQueueingHintFn},
    				},
    				{Resource: framework.Node, ActionType: framework.All}: {
    					{PluginName: filterWithoutEnqueueExtensions, QueueingHintFn: defaultQueueingHintFn},
    				},
    				{Resource: framework.CSINode, ActionType: framework.All}: {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  3. pkg/scheduler/scheduler.go

    	gvkMap := make(map[framework.GVK]framework.ActionType)
    	for _, queueingHints := range queueingHintsPerProfile {
    		for evt := range queueingHints {
    			if _, ok := gvkMap[evt.Resource]; ok {
    				gvkMap[evt.Resource] |= evt.ActionType
    			} else {
    				gvkMap[evt.Resource] = evt.ActionType
    			}
    		}
    	}
    	return gvkMap
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/volumebinding/volume_binding.go

    		{Event: framework.ClusterEvent{Resource: framework.StorageClass, ActionType: framework.Add | framework.Update}},
    		// We bind PVCs with PVs, so any changes may make the pods schedulable.
    		{Event: framework.ClusterEvent{Resource: framework.PersistentVolumeClaim, ActionType: framework.Add | framework.Update}},
    		{Event: framework.ClusterEvent{Resource: framework.PersistentVolume, ActionType: framework.Add | framework.Update}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/types_test.go

    			event:       ClusterEvent{Resource: WildCard, ActionType: UpdateNodeLabel},
    			comingEvent: ClusterEvent{Resource: Pod, ActionType: UpdateNodeLabel},
    			wantResult:  true,
    		},
    		{
    			name:        "event with resource = '*' matching with coming events carries different actionType",
    			event:       ClusterEvent{Resource: WildCard, ActionType: UpdateNodeLabel},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 45.9K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/volumezone/volume_zone.go

    		{Event: framework.ClusterEvent{Resource: framework.Node, ActionType: framework.Add | framework.UpdateNodeLabel | framework.UpdateNodeTaint}},
    		// A new pvc may make a pod schedulable.
    		// Due to fields are immutable except `spec.resources`, pvc update events are ignored.
    		{Event: framework.ClusterEvent{Resource: framework.PersistentVolumeClaim, ActionType: framework.Add}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  7. pkg/scheduler/eventhandlers.go

    	handlers = append(handlers, handlerRegistration)
    
    	logger := sched.logger
    	buildEvtResHandler := func(at framework.ActionType, gvk framework.GVK, shortGVK string) cache.ResourceEventHandlerFuncs {
    		funcs := cache.ResourceEventHandlerFuncs{}
    		if at&framework.Add != 0 {
    			evt := framework.ClusterEvent{Resource: gvk, ActionType: framework.Add, Label: fmt.Sprintf("%vAdd", shortGVK)}
    			funcs.AddFunc = func(obj interface{}) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:21:04 UTC 2024
    - 24K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/podtopologyspread/plugin.go

    // failed by this plugin schedulable.
    func (pl *PodTopologySpread) EventsToRegister() []framework.ClusterEventWithHint {
    	return []framework.ClusterEventWithHint{
    		// All ActionType includes the following events:
    		// - Add. An unschedulable Pod may fail due to violating topology spread constraints,
    		// adding an assigned Pod may make it schedulable.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  9. pkg/scheduler/eventhandlers_test.go

    	tests := []struct {
    		name                   string
    		gvkMap                 map[framework.GVK]framework.ActionType
    		expectStaticInformers  map[reflect.Type]bool
    		expectDynamicInformers map[schema.GroupVersionResource]bool
    	}{
    		{
    			name:   "default handlers in framework",
    			gvkMap: map[framework.GVK]framework.ActionType{},
    			expectStaticInformers: map[reflect.Type]bool{
    				reflect.TypeOf(&v1.Pod{}):       true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 10 14:38:54 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/interpodaffinity/plugin.go

    		// See: https://github.com/kubernetes/kubernetes/issues/110175
    		{Event: framework.ClusterEvent{Resource: framework.Pod, ActionType: framework.All}, QueueingHintFn: pl.isSchedulableAfterPodChange},
    		{Event: framework.ClusterEvent{Resource: framework.Node, ActionType: framework.Add | framework.UpdateNodeLabel | framework.UpdateNodeTaint}, QueueingHintFn: pl.isSchedulableAfterNodeChange},
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 03:08:44 UTC 2024
    - 10.3K bytes
    - Viewed (0)
Back to top