- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 369 for GetOptions (0.17 sec)
-
pkg/registry/apps/replicaset/storage/storage_test.go
rs, err := createReplicaSet(storage.ReplicaSet, modifiedSno, t) if err != nil { t.Errorf("unexpected error: %v", err) } etcdRS, err := storage.ReplicaSet.Get(ctx, rs.Name, &metav1.GetOptions{}) if err != nil { t.Errorf("unexpected error: %v", err) } storedRS, _ := etcdRS.(*apps.ReplicaSet) // Generation initialization
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 17.7K bytes - Viewed (0) -
pkg/kubelet/client/kubelet_client.go
Get(ctx context.Context, name string, options metav1.GetOptions) (*v1.Node, error) } // NodeGetterFunc allows implementing NodeGetter with a function type NodeGetterFunc func(ctx context.Context, name string, options metav1.GetOptions) (*v1.Node, error) // Get fetches information via NodeGetterFunc. func (f NodeGetterFunc) Get(ctx context.Context, name string, options metav1.GetOptions) (*v1.Node, error) { return f(ctx, name, options) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 07 01:34:49 UTC 2023 - 7.4K bytes - Viewed (0) -
istioctl/pkg/multicluster/cluster.go
func clusterUID(client kubernetes.Interface) (types.UID, error) { kubeSystem, err := client.CoreV1().Namespaces().Get(context.TODO(), "kube-system", metav1.GetOptions{}) if err != nil { return "", err } return kubeSystem.UID, nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Sep 02 03:11:58 UTC 2022 - 1.1K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller_test.go
// add a delay to ensure controller had a chance to reconcile time.Sleep(2 * time.Second) storageVersion, err := clientset.InternalV1alpha1().StorageVersions().Get(context.Background(), "k8s.test.resources", metav1.GetOptions{}) if err != nil { t.Fatalf("error getting StorageVersion: %v", err) } expectedServerStorageVersions := []apiserverinternalv1alpha1.ServerStorageVersion{ { APIServerID: "kube-apiserver-2",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 12:19:43 UTC 2023 - 12.1K bytes - Viewed (0) -
pkg/registry/core/replicationcontroller/storage/storage_test.go
rc, err := createController(storage.Controller, modifiedSno, t) if err != nil { t.Errorf("unexpected error: %v", err) } ctrl, err := storage.Controller.Get(ctx, rc.Name, &metav1.GetOptions{}) if err != nil { t.Errorf("unexpected error: %v", err) } controller, _ := ctrl.(*api.ReplicationController) // Generation initialization
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 16 06:57:01 UTC 2024 - 16.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/change_test.go
updateCRD := func() { noxuDefinitionToUpdate, err := apiExtensionsClient.ApiextensionsV1().CustomResourceDefinitions().Get(context.TODO(), noxuDefinition.Name, metav1.GetOptions{}) if err != nil { t.Error(err) return } if len(noxuDefinitionToUpdate.Spec.Versions) == 1 { v2 := noxuDefinitionToUpdate.Spec.Versions[0] v2.Name = "v2" v2.Served = true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:59:03 UTC 2024 - 5.2K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject.go
if err != nil { return err } pod, err := kubeClient.Kube().CoreV1().Pods(podNs).Get(context.TODO(), podName, metav1.GetOptions{}) if err != nil { return err } ns, err := kubeClient.Kube().CoreV1().Namespaces().Get(context.TODO(), podNs, metav1.GetOptions{}) if err != nil { return err } podLabels = pod.GetLabels() nsLabels = ns.GetLabels() } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 9.3K bytes - Viewed (0) -
pkg/registry/core/pod/storage/storage_test.go
if err != nil { t.Fatalf("unexpected error: %v", err) } ctx := genericapirequest.NewDefaultContext() object, err := storage.Get(ctx, "foo", &metav1.GetOptions{}) if err != nil { t.Errorf("unexpected error: %v", err) } actual := object.(*api.Pod) if actual.Name != pod.Name { t.Errorf("unexpected pod: %#v", actual) } if len(actual.UID) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 07:18:44 UTC 2024 - 38.8K bytes - Viewed (0) -
tests/integration/operator/uninstall_test.go
ObjectMeta: metav1.ObjectMeta{ Name: IstioNamespace, }, }, metav1.CreateOptions{}); err != nil { _, err := cs.Kube().CoreV1().Namespaces().Get(context.TODO(), IstioNamespace, metav1.GetOptions{}) if err == nil { log.Info("istio namespace already exist") } else { t.Errorf("failed to create istio namespace: %v", err) } } iopCRFile = filepath.Join(workDir, "iop_cr.yaml")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 7.7K bytes - Viewed (0) -
pkg/test/framework/components/ambient/waypoint.go
if service == "" { return } cs := t.AllClusters() for _, c := range cs { oldSvc, err := c.Kube().CoreV1().Services(ns.Name()).Get(t.Context(), service, metav1.GetOptions{}) if err != nil { t.Fatalf("error getting svc %s, err %v", service, err) } oldLabels := oldSvc.ObjectMeta.GetLabels() if oldLabels == nil { oldLabels = make(map[string]string, 1) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.5K bytes - Viewed (0)