Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 345 for GetOptions (0.22 sec)

  1. pkg/controller/cronjob/injection.go

    	KubeClient clientset.Interface
    }
    
    func (c *realCJControl) GetCronJob(ctx context.Context, namespace, name string) (*batchv1.CronJob, error) {
    	return c.KubeClient.BatchV1().CronJobs(namespace).Get(ctx, name, metav1.GetOptions{})
    }
    
    var _ cjControlInterface = &realCJControl{}
    
    func (c *realCJControl) UpdateStatus(ctx context.Context, cj *batchv1.CronJob) (*batchv1.CronJob, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 22 09:37:31 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiextensions-apiserver/test/integration/defaulting_test.go

    		var err error
    		for retry := 0; retry < 10; retry++ {
    			var obj *apiextensionsv1.CustomResourceDefinition
    			obj, err = apiExtensionClient.ApiextensionsV1().CustomResourceDefinitions().Get(context.TODO(), crd.Name, metav1.GetOptions{})
    			if err != nil {
    				t.Fatal(err)
    			}
    			update(obj)
    			obj, err = apiExtensionClient.ApiextensionsV1().CustomResourceDefinitions().Update(context.TODO(), obj, metav1.UpdateOptions{})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 06 05:32:34 UTC 2023
    - 21.2K bytes
    - Viewed (0)
  3. pkg/serviceaccount/jwt_test.go

    				return tc.Client.CoreV1().Secrets(namespace).Get(context.TODO(), name, metav1.GetOptions{})
    			})),
    			v1listers.NewServiceAccountLister(newIndexer(func(namespace, name string) (interface{}, error) {
    				return tc.Client.CoreV1().ServiceAccounts(namespace).Get(context.TODO(), name, metav1.GetOptions{})
    			})),
    			v1listers.NewPodLister(newIndexer(func(namespace, name string) (interface{}, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 27 22:16:08 UTC 2024
    - 17K bytes
    - Viewed (0)
  4. pkg/registry/storage/volumeattachment/storage/storage_test.go

    	if _, err := storage.Create(ctx, attachment, rest.ValidateAllObjectFunc, &metav1.CreateOptions{}); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	obj, err := storage.Get(ctx, attachment.ObjectMeta.Name, &metav1.GetOptions{})
    	if err != nil {
    		t.Errorf("unexpected error: %v", err)
    	}
    
    	// update status
    	attachmentIn := obj.(*storageapi.VolumeAttachment).DeepCopy()
    	attachmentIn.Status.Attached = true
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:46:12 UTC 2023
    - 6.2K bytes
    - Viewed (1)
  5. istioctl/pkg/util/ambient/util.go

    	isZtunnel := strings.HasPrefix(podName, "ztunnel")
    	if client == nil {
    		return isZtunnel
    	}
    	pod, err := client.Kube().CoreV1().Pods(podNamespace).Get(context.Background(), podName, metav1.GetOptions{})
    	if err != nil {
    		return isZtunnel
    	}
    	if v, ok := pod.Labels["app"]; ok {
    		return v == "ztunnel"
    	}
    	return isZtunnel
    }
    
    // InAmbient returns true if a resource is in ambient data plane mode.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 02 21:29:40 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  6. security/pkg/k8s/controller/casecret.go

    ) (*v1.Secret, error) {
    	start := time.Now()
    	var caSecret *v1.Secret
    	var scrtErr error
    	for {
    		caSecret, scrtErr = csc.client.Secrets(namespace).Get(context.TODO(), secretName, metav1.GetOptions{})
    		if scrtErr == nil {
    			return caSecret, nil
    		}
    		k8sControllerLog.Errorf("Failed on loading CA secret %s:%s.",
    			namespace, secretName)
    
    		if time.Since(start) > timeout {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  7. pkg/kubelet/util/util.go

    	"k8s.io/kubernetes/pkg/util/filesystem"
    )
    
    // FromApiserverCache modifies <opts> so that the GET request will
    // be served from apiserver cache instead of from etcd.
    func FromApiserverCache(opts *metav1.GetOptions) {
    	opts.ResourceVersion = "0"
    }
    
    var IsUnixDomainSocket = filesystem.IsUnixDomainSocket
    
    // GetNodenameForKernel gets hostname value to set in the hostname field (the nodename field of struct utsname) of the pod.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 18:07:39 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/dryrun_test.go

    	err := s.Create(context.Background(), "key", obj, out, 0, true)
    	if err != nil {
    		t.Fatalf("Failed to create new dry-run object: %v", err)
    	}
    
    	err = s.Get(context.Background(), "key", storage.GetOptions{}, out)
    	if e, ok := err.(*storage.StorageError); !ok || e.Code != storage.ErrCodeKeyNotFound {
    		t.Errorf("Expected key to be not found, error: %v", err)
    	}
    }
    
    func TestDryRunCreateReturnsObject(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  9. pkg/volume/csi/nodeinfomanager/nodeinfomanager.go

    	if kubeClient == nil {
    		return fmt.Errorf("error getting kube client")
    	}
    
    	nodeClient := kubeClient.CoreV1().Nodes()
    	originalNode, err := nodeClient.Get(context.TODO(), string(nim.nodeName), metav1.GetOptions{})
    	if err != nil {
    		return err
    	}
    	node := originalNode.DeepCopy()
    
    	needUpdate := false
    	for _, update := range updateFuncs {
    		newNode, updated, err := update(node)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  10. pkg/controller/storageversiongc/gc_controller.go

    	return true
    }
    
    func (c *Controller) processDeletedLease(ctx context.Context, name string) error {
    	_, err := c.kubeclientset.CoordinationV1().Leases(metav1.NamespaceSystem).Get(ctx, name, metav1.GetOptions{})
    	// the lease isn't deleted, nothing we need to do here
    	if err == nil {
    		return nil
    	}
    	if !apierrors.IsNotFound(err) {
    		return err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10K bytes
    - Viewed (0)
Back to top