- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 395 for GetOptions (0.14 sec)
-
tests/integration/pilot/multicluster_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/kubelet/pod/mirror_client_test.go
err := mc.CreateMirrorPod(pod) if !test.expectSuccess { assert.Error(t, err) return } createdPod, err := clientset.CoreV1().Pods(testPodNS).Get(context.TODO(), testPodName, metav1.GetOptions{}) require.NoError(t, err) // Validate created pod assert.Equal(t, testPodHash, createdPod.Annotations[kubetypes.ConfigMirrorAnnotationKey]) assert.Len(t, createdPod.OwnerReferences, 1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 08 12:44:09 UTC 2023 - 4.2K bytes - Viewed (0) -
pkg/registry/policy/poddisruptionbudget/storage/storage.go
// we don't destroy it here explicitly. } // Get retrieves the object from the storage. It is required to support Patch. func (r *StatusREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error) { return r.store.Get(ctx, name, options) } // Update alters the status subset of an object.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:19 UTC 2022 - 4.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/rest/resttest/resttest.go
} if _, err := getFn(ctx, foo); err != nil { t.Fatalf("did not gracefully delete resource: %v", err) } object, err := t.storage.(rest.Getter).Get(ctx, objectMeta.GetName(), &metav1.GetOptions{}) if err != nil { t.Fatalf("unexpected error, object should exist: %v", err) } objectMeta = t.getObjectMetaOrFail(object)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 55.8K bytes - Viewed (0) -
operator/cmd/mesh/operator-common.go
func deploymentExists(cs kubernetes.Interface, namespace, name string) (bool, error) { d, err := cs.AppsV1().Deployments(namespace).Get(context.TODO(), name, metav1.GetOptions{}) if err != nil { return false, err } return d != nil, nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Dec 17 02:25:04 UTC 2022 - 3.8K bytes - Viewed (0) -
pkg/registry/resource/podschedulingcontext/storage/storage.go
// we don't destroy it here explicitly. } // Get retrieves the object from the storage. It is required to support Patch. func (r *StatusREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error) { return r.store.Get(ctx, name, options) } // Update alters the status subset of an object.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 09:18:08 UTC 2023 - 4K bytes - Viewed (0) -
cmd/kubeadm/app/phases/uploadconfig/uploadconfig_test.go
} } if tt.verifyResult { controlPlaneCfg, err := client.CoreV1().ConfigMaps(metav1.NamespaceSystem).Get(context.TODO(), kubeadmconstants.KubeadmConfigConfigMap, metav1.GetOptions{}) if err != nil { t2.Fatalf("Fail to query ConfigMap error = %v", err) } configData := controlPlaneCfg.Data[kubeadmconstants.ClusterConfigurationConfigMapKey] if configData == "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 08:46:51 UTC 2023 - 3.4K bytes - Viewed (0) -
pkg/registry/admissionregistration/validatingadmissionpolicybinding/storage/storage.go
Getter rest.Getter } func (g *DefaultPolicyGetter) GetValidatingAdmissionPolicy(ctx context.Context, name string) (*admissionregistration.ValidatingAdmissionPolicy, error) { p, err := g.Getter.Get(ctx, name, &metav1.GetOptions{}) if err != nil { return nil, err } return p.(*admissionregistration.ValidatingAdmissionPolicy), err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 10:11:16 UTC 2022 - 3.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/testing/tester.go
accessor, err := meta.Accessor(obj) if err != nil { return nil, err } result, err := t.storage.Get(ctx, accessor.GetName(), &metav1.GetOptions{}) if err != nil { return nil, err } return result, nil } func (t *Tester) createObject(ctx context.Context, obj runtime.Object) error { accessor, err := meta.Accessor(obj) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 16:50:16 UTC 2019 - 4.8K bytes - Viewed (0) -
tests/integration/pilot/webhook_test.go
whc, err := client.AdmissionregistrationV1().ValidatingWebhookConfigurations().Get(context.TODO(), name, metav1.GetOptions{}) if err != nil { return nil, fmt.Errorf("could not get validating webhook config %q: %v", name, err) } return whc, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 01 13:31:34 UTC 2023 - 4.7K bytes - Viewed (0)