Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for postFilter (0.29 sec)

  1. pkg/scheduler/framework/interface.go

    	// other postFilter plugins like preemption would not change anything.
    	// See the comment on PostFilter interface for more details about how PostFilter should handle this status.
    	// Plugins should return Unschedulable if it is possible that the pod can get scheduled
    	// after running other postFilter plugins.
    	// The accompanying status message should explain why the pod is unschedulable.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go

    				initialObjects = testCtx.updateAPIServer(t, initialObjects, tc.prepare.postfilter)
    				result, status := testCtx.p.PostFilter(testCtx.ctx, testCtx.state, tc.pod, nil /* filteredNodeStatusMap not used by plugin */)
    				t.Run("postfilter", func(t *testing.T) {
    					assert.Equal(t, tc.want.postFilterResult, result)
    					testCtx.verify(t, tc.want.postfilter, initialObjects, nil, status)
    				})
    			}
    		})
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 61.9K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/runtime/framework.go

    	if !state.ShouldRecordPluginMetrics() {
    		return pl.PostFilter(ctx, state, pod, filteredNodeStatusMap)
    	}
    	startTime := time.Now()
    	r, s := pl.PostFilter(ctx, state, pod, filteredNodeStatusMap)
    	f.metricsRecorder.ObservePluginDurationAsync(metrics.PostFilter, pl.Name(), s.Code().String(), metrics.SinceInSeconds(startTime))
    	return r, s
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/runtime/framework_test.go

    						return tmpPl, nil
    					}); err != nil {
    					t.Fatalf("fail to register postFilter plugin (%s)", pl.name)
    				}
    				// append plugins to filter pluginset
    				cfgPls.PostFilter.Enabled = append(
    					cfgPls.PostFilter.Enabled,
    					config.Plugin{Name: pl.name},
    				)
    			}
    			profile := config.KubeSchedulerProfile{Plugins: cfgPls}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
  5. pkg/scheduler/schedule_one.go

    		// into the resources that were preempted, but this is harmless.
    
    		if !fwk.HasPostFilterPlugins() {
    			logger.V(3).Info("No PostFilter plugins are registered, so no preemption will be performed")
    			return ScheduleResult{}, podInfo, framework.NewStatus(framework.Unschedulable).WithError(err)
    		}
    
    		// Run PostFilter plugins to attempt to make the pod schedulable in a future scheduling cycle.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/types.go

    			reasonMsg += fmt.Sprintf(" %v.", strings.Join(sortedFilterMsg, ", "))
    		}
    	}
    
    	// Add the messages from PostFilter plugins to reasonMsg.
    	// We can add this message regardless of whether the scheduling cycle fails at PreFilter or Filter
    	// since we may run PostFilter (if enabled) in both cases.
    	postFilterMsg := f.Diagnosis.PostFilterMsg
    	if postFilterMsg != "" {
    		reasonMsg += fmt.Sprintf(" %v", postFilterMsg)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    	}
    
    	return nil
    }
    
    // PostFilter checks whether there are allocated claims that could get
    // deallocated to help get the Pod schedulable. If yes, it picks one and
    // requests its deallocation.  This only gets called when filtering found no
    // suitable node.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.31.md

    - Improved scheduling performance when many nodes, and prefilter returns 1-2 nodes (e.g. daemonset)
      
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 20:34:14 UTC 2024
    - 60.3K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    			// Ensure <state> is populated.
    			if _, status := f.RunPreFilterPlugins(ctx, state, tt.pod); !status.IsSuccess() {
    				t.Errorf("Unexpected PreFilter Status: %v", status)
    			}
    
    			gotResult, gotStatus := p.PostFilter(ctx, state, tt.pod, tt.filteredNodesStatuses)
    			// As we cannot compare two errors directly due to miss the equal method for how to compare two errors, so just need to compare the reasons.
    			if gotStatus.Code() == framework.Error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.29.md

    ## Changelog since v1.29.5
    
    ## Changes by Kind
    
    ### API Change
    
    - Improved scheduling performance when many nodes, and prefilter returns 1-2 nodes (e.g. daemonset)
      
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 03:42:38 UTC 2024
    - 324.5K bytes
    - Viewed (0)
Back to top