Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 22 for PreScore (0.18 sec)

  1. pkg/scheduler/framework/interface.go

    }
    
    // PreScorePlugin is an interface for "PreScore" plugin. PreScore is an
    // informational extension point. Plugins will be called with a list of nodes
    // that passed the filtering phase. A plugin may use this data to update internal
    // state or to generate logs/metrics.
    type PreScorePlugin interface {
    	Plugin
    	// PreScore is called by the scheduling framework after a list of nodes
    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/volumebinding/volume_binding.go

    	state.hasStaticBindings = state.hasStaticBindings || (podVolumes != nil && len(podVolumes.StaticBindings) > 0)
    	state.Unlock()
    	return nil
    }
    
    // PreScore invoked at the preScore extension point. It checks whether volumeBinding can skip Score
    func (pl *VolumeBinding) PreScore(ctx context.Context, cs *framework.CycleState, pod *v1.Pod, nodes []*framework.NodeInfo) *framework.Status {
    	if pl.scorer == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  3. cmd/kube-scheduler/app/server_test.go

      plugins:
        preFilter:
          disabled:
          - name: "*"
        filter:
          disabled:
          - name: "*"
        postFilter:
          disabled:
          - name: "*"
        preScore:
          disabled:
          - name: "*"
        score:
          disabled:
          - name: "*"
    `, configKubeconfig)), os.FileMode(0600)); err != nil {
    		t.Fatal(err)
    	}
    
    	// empty leader-election config
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  4. pkg/scheduler/apis/config/types.go

    	Filter PluginSet
    
    	// PostFilter is a list of plugins that are invoked after filtering phase, but only when no feasible nodes were found for the pod.
    	PostFilter PluginSet
    
    	// PreScore is a list of plugins that are invoked before scoring.
    	PreScore PluginSet
    
    	// Score is a list of plugins that should be invoked when ranking nodes that have passed the filtering phase.
    	Score PluginSet
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 18:47:23 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/noderesources/most_allocated_test.go

    				t.Fatalf("got err (-want,+got):\n%s", diff)
    			}
    			if err != nil {
    				return
    			}
    
    			status := p.(framework.PreScorePlugin).PreScore(ctx, state, test.requestedPod, tf.BuildNodeInfos(test.nodes))
    			if !status.IsSuccess() {
    				t.Errorf("PreScore is expected to return success, but didn't. Got status: %v", status)
    			}
    
    			var gotScores framework.NodeScoreList
    			for _, n := range test.nodes {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 16K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go

    				assert.Equal(t, item.wantFilterStatus[i], gotStatus)
    			}
    
    			t.Logf("Verify: call PreScore and check status")
    			gotPreScoreStatus := p.PreScore(ctx, state, item.pod, tf.BuildNodeInfos(item.nodes))
    			if diff := cmp.Diff(item.wantPreScoreStatus, gotPreScoreStatus); diff != "" {
    				t.Errorf("state got after prescore does not match (-want,+got):\n%s", diff)
    			}
    			if !gotPreScoreStatus.IsSuccess() {
    				return
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 32K bytes
    - Viewed (0)
  7. cmd/kube-scheduler/app/options/options_test.go

    apiVersion: kubescheduler.config.k8s.io/v1
    kind: KubeSchedulerConfiguration
    clientConnection:
      kubeconfig: '%s'
    profiles:
    - schedulerName: "high-throughput-profile"
      plugins:
        preScore:
          enabled:
          - name: InterPodAffinity
      pluginConfig:
      - name: InterPodAffinity
        args:
          ignorePreferredTermsOfExistingPods: true
    `, configKubeconfig)), os.FileMode(0600)); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 13 07:42:19 UTC 2023
    - 30.3K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/noderesources/least_allocated_test.go

    				t.Fatalf("got err (-want,+got):\n%s", diff)
    			}
    			if err != nil {
    				return
    			}
    
    			status := p.(framework.PreScorePlugin).PreScore(ctx, state, test.requestedPod, tf.BuildNodeInfos(test.nodes))
    			if !status.IsSuccess() {
    				t.Errorf("PreScore is expected to return success, but didn't. Got status: %v", status)
    			}
    
    			var gotScores framework.NodeScoreList
    			for _, n := range test.nodes {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 18.8K bytes
    - Viewed (0)
  9. pkg/scheduler/apis/config/v1/zz_generated.conversion.go

    		return err
    	}
    	if err := Convert_v1_PluginSet_To_config_PluginSet(&in.PostFilter, &out.PostFilter, s); err != nil {
    		return err
    	}
    	if err := Convert_v1_PluginSet_To_config_PluginSet(&in.PreScore, &out.PreScore, s); err != nil {
    		return err
    	}
    	if err := Convert_v1_PluginSet_To_config_PluginSet(&in.Score, &out.Score, s); err != nil {
    		return err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 18:47:23 UTC 2024
    - 46.9K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration_test.go

    			p, err := New(ctx, nil, fh, feature.Features{})
    			if err != nil {
    				t.Fatalf("creating plugin: %v", err)
    			}
    			status := p.(framework.PreScorePlugin).PreScore(ctx, state, test.pod, tf.BuildNodeInfos(test.nodes))
    			if !status.IsSuccess() {
    				t.Errorf("unexpected error: %v", status)
    			}
    			var gotList framework.NodeScoreList
    			for _, n := range test.nodes {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 17.5K bytes
    - Viewed (0)
Back to top