Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 96 for newFoo (0.12 sec)

  1. cmd/kube-scheduler/app/server_test.go

    		{
    			name: "out-of-tree component configuration v1",
    			flags: []string{
    				"--config", outOfTreePluginConfigFilev1,
    				"--kubeconfig", configKubeconfig,
    			},
    			registryOptions: []Option{WithPlugin("Foo", newFoo)},
    			wantPlugins: map[string]*config.Plugins{
    				"default-scheduler": func() *config.Plugins {
    					plugins := defaults.ExpandedPluginsV1.DeepCopy()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  2. operator/pkg/controller/istiocontrolplane/istiocontrolplane_controller.go

    					crHash := strings.Join([]string{newIOP.Name, newIOP.Namespace, string(component), host}, "-")
    					cache.RemoveCache(crHash)
    				}
    			}
    
    			if oldIOP.GetDeletionTimestamp() != newIOP.GetDeletionTimestamp() {
    				metrics.IncrementReconcileRequest("update_deletion_timestamp")
    				return true
    			}
    
    			if oldIOP.GetGeneration() != newIOP.GetGeneration() {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 13:56:46 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/nodeports/node_ports_test.go

    			wantPreFilterStatus: framework.NewStatus(framework.Skip),
    		},
    		{
    			pod: newPod("m1", "UDP/127.0.0.1/8080"),
    			nodeInfo: framework.NewNodeInfo(
    				newPod("m1", "UDP/127.0.0.1/9090")),
    			name: "other port",
    		},
    		{
    			pod: newPod("m1", "UDP/127.0.0.1/8080"),
    			nodeInfo: framework.NewNodeInfo(
    				newPod("m1", "UDP/127.0.0.1/8080")),
    			name:             "same udp port",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 19 11:02:11 UTC 2023
    - 10.1K bytes
    - Viewed (0)
  4. pkg/controller/tainteviction/taint_eviction_test.go

    			prevPod:     testutil.NewPod("pod1", ""),
    			newPod:      testutil.NewPod("pod1", "node1"),
    			taintedNodes: map[string][]corev1.Taint{
    				"node1": {createNoExecuteTaint(1)},
    			},
    			expectDelete: true,
    		},
    		{
    			description: "scheduling onto tainted Node with toleration",
    			prevPod:     addToleration(testutil.NewPod("pod1", ""), 1, -1),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 31.3K bytes
    - Viewed (0)
  5. pkg/registry/batch/job/strategy.go

    		isJobFailureTargetChanged := batchvalidation.IsConditionTrue(oldJob.Status.Conditions, batch.JobFailureTarget) != batchvalidation.IsConditionTrue(newJob.Status.Conditions, batch.JobFailureTarget)
    		isCompletedIndexesChanged := oldJob.Status.CompletedIndexes != newJob.Status.CompletedIndexes
    		isFailedIndexesChanged := !ptr.Equal(oldJob.Status.FailedIndexes, newJob.Status.FailedIndexes)
    		isActiveChanged := oldJob.Status.Active != newJob.Status.Active
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 16:43:24 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  6. pkg/controller/controller_ref_manager_test.go

    					func(ctx context.Context) error { return nil },
    					"foo-finalizer", "bar-finalizer"),
    				pods:    []*v1.Pod{newPod("pod1", productionLabel, &controller), newPod("pod2", testLabel, &controller), newPod("pod3", productionLabel, nil)},
    				claimed: []*v1.Pod{newPod("pod1", productionLabel, &controller), newPod("pod3", productionLabel, nil)},
    				patches: 2,
    			}
    		}(),
    		func() test {
    			controller := v1.ReplicationController{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 10 17:19:26 UTC 2021
    - 10.6K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/nodevolumelimits/csi_test.go

    		wantPreFilterStatus *framework.Status
    	}{
    		{
    			newPod:       csiEBSOneVolPod,
    			existingPods: []*v1.Pod{runningPod, csiEBSTwoVolPod},
    			filterName:   "csi",
    			maxVols:      4,
    			driverNames:  []string{ebsCSIDriverName},
    			test:         "fits when node volume limit >= new pods CSI volume",
    			limitSource:  "node",
    		},
    		{
    			newPod:       csiEBSOneVolPod,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 28.6K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/nodevolumelimits/non_csi_test.go

    		},
    	}).Obj()
    
    	tests := []struct {
    		newPod              *v1.Pod
    		existingPods        []*v1.Pod
    		extraClaims         []v1.PersistentVolumeClaim
    		ephemeralEnabled    bool
    		maxVols             int32
    		test                string
    		wantStatus          *framework.Status
    		wantPreFilterStatus *framework.Status
    	}{
    		{
    			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)
  9. pkg/scheduler/framework/plugins/podtopologyspread/plugin_test.go

    		name           string
    		pod            *v1.Pod
    		oldPod, newPod *v1.Pod
    		expectedHint   framework.QueueingHint
    		expectedErr    bool
    	}{
    		{
    			name: "add pod with labels match topologySpreadConstraints selector",
    			pod: st.MakePod().Name("p").Label("foo", "").
    				SpreadConstraint(1, "zone", v1.DoNotSchedule, fooSelector, nil, nil, nil, nil).
    				Obj(),
    			newPod:       st.MakePod().Node("fake-node").Label("foo", "").Obj(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Dec 17 06:30:53 UTC 2023
    - 13K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/informers.go

    		// For update, we just need to handle opt outs
    		newPod := event.New.(*corev1.Pod)
    		oldPod := event.Old.(*corev1.Pod)
    		ns := s.namespaces.Get(newPod.Namespace, "")
    		if ns == nil {
    			return fmt.Errorf("failed to find namespace %v", ns)
    		}
    		wasAnnotated := oldPod.Annotations != nil && oldPod.Annotations[constants.AmbientRedirection] == constants.AmbientRedirectionEnabled
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 21:31:35 UTC 2024
    - 11.8K bytes
    - Viewed (0)
Back to top