Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 58 of 58 for casgstatus (0.27 sec)

  1. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    		return framework.AsStatus(fmt.Errorf("failed to add pod: %v", podToSchedule.Name))
    	}
    	return nil
    }
    
    func (pl *TestPlugin) RemovePod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, podInfoToRemove *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status {
    	if nodeInfo.Node().GetLabels()["error"] == "true" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/nodevolumelimits/non_csi_test.go

    		{
    			newPod:           ephemeralVolumePod,
    			ephemeralEnabled: true,
    			extraClaims:      []v1.PersistentVolumeClaim{*conflictingClaim},
    			test:             "volume not owned",
    			wantStatus:       framework.AsStatus(errors.New("PVC test/abc-xyz was not created for pod test/abc (pod is not owner)")),
    		},
    		{
    			newPod:           ephemeralVolumePod,
    			ephemeralEnabled: true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 30 23:00:56 UTC 2023
    - 36.8K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/nodeaffinity/node_affinity_test.go

    						},
    					},
    				},
    			},
    			nodes: []*v1.Node{
    				{ObjectMeta: metav1.ObjectMeta{Name: "node1", Labels: label1}},
    			},
    			runPreScore:        true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Dec 18 12:00:10 UTC 2023
    - 38.7K bytes
    - Viewed (0)
  4. pkg/scheduler/schedule_one_test.go

    func (pl *falseMapPlugin) Name() string {
    	return "FalseMap"
    }
    
    func (pl *falseMapPlugin) Score(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ string) (int64, *framework.Status) {
    	return 0, framework.AsStatus(errPrioritize)
    }
    
    func (pl *falseMapPlugin) ScoreExtensions() framework.ScoreExtensions {
    	return nil
    }
    
    type numericMapPlugin struct{}
    
    func newNumericMapPlugin() frameworkruntime.PluginFactory {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	cycleState := framework.NewCycleState()
    	gotStatus := p.(framework.FilterPlugin).Filter(ctx, cycleState, pod, nodeInfo)
    	wantStatus := framework.AsStatus(fmt.Errorf(`error reading "PreFilterNodeResourcesFit" from cycleState: %w`, framework.ErrNotFound))
    	if !reflect.DeepEqual(gotStatus, wantStatus) {
    		t.Errorf("status does not match: %v, want: %v", gotStatus, wantStatus)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/interpodaffinity/filtering_test.go

    	cycleState := framework.NewCycleState()
    	gotStatus := p.(framework.FilterPlugin).Filter(context.Background(), cycleState, pod, nodeInfo)
    	wantStatus := framework.AsStatus(fmt.Errorf(`error reading "PreFilterInterPodAffinity" from cycleState: %w`, framework.ErrNotFound))
    	if !reflect.DeepEqual(gotStatus, wantStatus) {
    		t.Errorf("status does not match: %v, want: %v", gotStatus, wantStatus)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 01 10:24:54 UTC 2023
    - 58.2K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    		helper, loggerV := loggerV.WithCallStackHelper()
    		helper()
    		// nolint: logcheck // warns because it cannot check key/values
    		loggerV.Error(err, "dynamic resource plugin failed", kv...)
    	}
    	return framework.AsStatus(err)
    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. pkg/scheduler/framework/plugins/podtopologyspread/filtering_test.go

    	cycleState := framework.NewCycleState()
    	gotStatus := p.(*PodTopologySpread).Filter(context.Background(), cycleState, pod, nodeInfo)
    	wantStatus := framework.AsStatus(fmt.Errorf(`reading "PreFilterPodTopologySpread" from cycleState: %w`, framework.ErrNotFound))
    	if !reflect.DeepEqual(gotStatus, wantStatus) {
    		t.Errorf("status does not match: %v, want: %v", gotStatus, wantStatus)
    	}
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 143.1K bytes
    - Viewed (0)
Back to top