Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 345 for GetOptions (0.19 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1/customresourcedefinition.go

    	Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error
    	DeleteCollection(ctx context.Context, opts metav1.DeleteOptions, listOpts metav1.ListOptions) error
    	Get(ctx context.Context, name string, opts metav1.GetOptions) (*v1.CustomResourceDefinition, error)
    	List(ctx context.Context, opts metav1.ListOptions) (*v1.CustomResourceDefinitionList, error)
    	Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 10:52:54 UTC 2024
    - 12K bytes
    - Viewed (0)
  2. tests/integration/pilot/multicluster_test.go

    					t.Logf("error cleaning up %s: %v", pod, err)
    				}
    			})
    
    			retry.UntilSuccessOrFail(t, func() error {
    				pod, err := pods.Get(context.TODO(), pod, metav1.GetOptions{})
    				if err != nil {
    					return err
    				}
    				for _, status := range pod.Status.ContainerStatuses {
    					if status.Started != nil && !*status.Started {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  3. pkg/registry/apps/daemonset/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.3K bytes
    - Viewed (0)
  4. pkg/registry/batch/cronjob/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.3K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/test/integration/basic_test.go

    			}
    		}
    
    		// Check get for all versions
    		for version2, noxuResourceClient2 := range noxuResourceClients {
    			// Get test
    			gottenNoxuInstance, err := noxuResourceClient2.Get(context.TODO(), "foo", metav1.GetOptions{})
    
    			if disabledVersions[version2] {
    				if !errors.IsNotFound(err) {
    					t.Errorf("expected the get operation fail with NotFound for disabled version %s, got error: %v", version2, err)
    
    				}
    			} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 23 11:35:33 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top