Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 92 for PatchOptions (0.19 sec)

  1. tests/integration/ambient/waypoint_test.go

    			if service {
    				_, err := c.Kube().CoreV1().Services(ns).Patch(context.TODO(), name, types.MergePatchType, label, metav1.PatchOptions{})
    				return err
    			}
    			_, err := c.Istio().NetworkingV1beta1().ServiceEntries(ns).Patch(context.TODO(), name, types.MergePatchType, label, metav1.PatchOptions{})
    			return err
    		}
    
    		if err := setWaypoint(waypoint); err != nil {
    			t.Fatal(err)
    		}
    		t.Cleanup(func() {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  2. staging/src/k8s.io/cli-runtime/pkg/resource/helper.go

    		Body(obj).
    		Do(context.TODO()).
    		Get()
    }
    func (m *Helper) Patch(namespace, name string, pt types.PatchType, data []byte, options *metav1.PatchOptions) (runtime.Object, error) {
    	if options == nil {
    		options = &metav1.PatchOptions{}
    	}
    	if m.ServerDryRun {
    		options.DryRun = []string{metav1.DryRunAll}
    	}
    	if m.FieldManager != "" {
    		options.FieldManager = m.FieldManager
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 26 03:45:13 UTC 2022
    - 10.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/test/integration/basic_test.go

    	}
    
    	t.Logf("Patching .num.num2 to 999")
    	patch := []byte(`{"num": {"num2":999}}`)
    	patchedNoxuInstance, err := noxuNamespacedResourceClient.Patch(context.TODO(), "foo", types.MergePatchType, patch, metav1.PatchOptions{})
    	if err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	expectInt64(t, patchedNoxuInstance.UnstructuredContent(), 999, "num", "num2")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 23 11:35:33 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  4. pkg/controller/garbagecollector/operations.go

    	if err != nil {
    		return nil, err
    	}
    	return gc.metadataClient.Resource(resource).Namespace(resourceDefaultNamespace(namespaced, item.Namespace)).Patch(context.TODO(), item.Name, pt, patch, metav1.PatchOptions{})
    }
    
    func (gc *GarbageCollector) removeFinalizer(logger klog.Logger, owner *node, targetFinalizer string) error {
    	err := retry.RetryOnConflict(retry.DefaultBackoff, func() error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 13:37:56 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/fake/fake_example.go

    	return err
    }
    
    // Patch applies the patch and returns the patched example.
    func (c *FakeExamples) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.Example, err error) {
    	emptyResult := &v1.Example{}
    	obj, err := c.Fake.
    		Invokes(testing.NewPatchSubresourceAction(examplesResource, c.ns, name, pt, data, subresources...), emptyResult)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. pkg/scheduler/util/utils.go

    	}
    
    	if "{}" == string(patchBytes) {
    		return nil
    	}
    
    	patchFn := func() error {
    		_, err := cs.CoreV1().Pods(old.Namespace).Patch(ctx, old.Name, types.StrategicMergePatchType, patchBytes, metav1.PatchOptions{}, "status")
    		return err
    	}
    
    	return retry.OnError(retry.DefaultBackoff, Retriable, patchFn)
    }
    
    // DeletePod deletes the given <pod> from API server
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Sep 21 01:40:44 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  7. pkg/controller/controller_utils.go

    func (r RealRSControl) PatchReplicaSet(ctx context.Context, namespace, name string, data []byte) error {
    	_, err := r.KubeClient.AppsV1().ReplicaSets(namespace).Patch(ctx, name, types.StrategicMergePatchType, data, metav1.PatchOptions{})
    	return err
    }
    
    // TODO: merge the controller revision interface in controller_history.go with this one
    // ControllerRevisionControlInterface is an interface that knows how to patch
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 12 15:34:44 UTC 2024
    - 47.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/test/integration/conversion/conversion_test.go

    			// send a non-trivial patch to the main resource to verify the oldObject is in the right version
    			if _, err := client.Patch(context.TODO(), name, types.MergePatchType, []byte(`{"metadata":{"annotations":{"main":"true"}}}`), metav1.PatchOptions{}); err != nil {
    				t.Fatal(err)
    			}
    			// verify that the right, pruned version is in storage
    			obj, err = ctc.etcdObjectReader.GetStoredCustomResource(ns, name)
    			if err != nil {
    				t.Fatal(err)
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 06 05:32:34 UTC 2023
    - 47.1K bytes
    - Viewed (0)
  9. pkg/controller/history/controller_history.go

    	return rh.client.AppsV1().ControllerRevisions(parent.GetNamespace()).Patch(context.TODO(), revision.GetName(),
    		types.StrategicMergePatchType, patchBytes, metav1.PatchOptions{})
    }
    
    func (rh *realHistory) ReleaseControllerRevision(parent metav1.Object, revision *apps.ControllerRevision) (*apps.ControllerRevision, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 05 13:33:52 UTC 2021
    - 18.2K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/test/integration/table_test.go

            }
          }
        ]
      }
    }
    `)
    
    	_, err = apiExtensionClient.ApiextensionsV1().CustomResourceDefinitions().Patch(context.TODO(), crd.Name, types.MergePatchType, patch, metav1.PatchOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	crd, err = apiExtensionClient.ApiextensionsV1().CustomResourceDefinitions().Get(context.TODO(), crd.Name, metav1.GetOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 02 19:34:41 UTC 2021
    - 18.9K bytes
    - Viewed (0)
Back to top