- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 96 for newFoo (0.12 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)