- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for GetOptions (0.21 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
} }() } wg.Wait() if _, err := registry.Get(testContext, podA.Name, &metav1.GetOptions{}); !errors.IsNotFound(err) { t.Errorf("Unexpected error: %v", err) } if _, err := registry.Get(testContext, podB.Name, &metav1.GetOptions{}); !errors.IsNotFound(err) { t.Errorf("Unexpected error: %v", err) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller_test.go
node0, err := fakeNodeHandler.Get(ctx, "node0", metav1.GetOptions{}) if err != nil { t.Errorf("Can't get current node0...") return } if !taintutils.TaintExists(node0.Spec.Taints, UnreachableTaintTemplate) { t.Errorf("Can't find taint %v in %v", originalTaint, node0.Spec.Taints) } node2, err := fakeNodeHandler.Get(ctx, "node2", metav1.GetOptions{}) if err != nil { t.Errorf("Can't get current node2...")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 03:26:45 UTC 2024 - 119K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
pv := volumeToMount.VolumeSpec.PersistentVolume pvc, err := og.kubeClient.CoreV1().PersistentVolumeClaims(pv.Spec.ClaimRef.Namespace).Get(context.TODO(), pv.Spec.ClaimRef.Name, metav1.GetOptions{}) if err != nil { eventErr, detailedErr := volumeToMount.GenerateError("VerifyControllerAttachedVolume fetching pvc failed", err) return volumetypes.NewOperationContext(eventErr, detailedErr, migrated) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
err = wait.PollUntilContextTimeout(ctx, 200*time.Microsecond, 3*time.Second, true, func(ctx context.Context) (done bool, err error) { j, err = clientset.BatchV1().Jobs(metav1.NamespaceDefault).Get(ctx, job.GetName(), metav1.GetOptions{}) if err != nil { return false, err } return j.Status.StartTime != nil, nil }) if err != nil { t.Errorf("Job failed to ensure that start time was set: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status_test.go
} type delegatingNodeLister struct { client clientset.Interface } func (l delegatingNodeLister) Get(name string) (*v1.Node, error) { return l.client.CoreV1().Nodes().Get(context.Background(), name, metav1.GetOptions{}) } func (l delegatingNodeLister) List(selector labels.Selector) (ret []*v1.Node, err error) { opts := metav1.ListOptions{} if selector != nil { opts.LabelSelector = selector.String() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0)