- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 105 for PatchType (0.18 sec)
-
pkg/kube/kclient/client.go
api := kubeclient.GetWriteClient[T](n.client, object.GetNamespace()) return api.Update(context.Background(), object, metav1.UpdateOptions{}) } func (n *writeClient[T]) Patch(name, namespace string, pt apitypes.PatchType, data []byte) (T, error) { api := kubeclient.GetWriteClient[T](n.client, namespace) return api.Patch(context.Background(), name, pt, data, metav1.PatchOptions{}) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0) -
pkg/controller/replication/conversion.go
return nil, errors.New("Watch() is not implemented for conversionClient") } func (c conversionClient) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *apps.ReplicaSet, err error) { // This is not used by RSC. return nil, errors.New("Patch() is not implemented for conversionClient") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 14 18:43:33 UTC 2022 - 12.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/strategicpatch/patch.go
if !ok { delete(original, k) } } continue } originalType := reflect.TypeOf(original[k]) patchType := reflect.TypeOf(patchV) if originalType != patchType { if !isDeleteList { if mergeOptions.IgnoreUnmatchedNulls { discardNullValuesFromPatch(patchV) } original[k], ok = removeDirectives(patchV) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 23:34:23 UTC 2023 - 75.5K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client_test.go
} return nil }) // check we can patch items var patchedCfg config.Config if _, err := store.(*Client).Patch(*cfg, func(cfg config.Config) (config.Config, types.PatchType) { cfg.Annotations["fizz"] = "buzz" patchedCfg = cfg return cfg, types.JSONPatchType }); err != nil { t.Errorf("unexpected err in Patch: %v", err) } // validate it is updated
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 02:58:52 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/config/model.go
} // PatchFunc provides the cached config as a base for modification. Only diff the between the cfg // parameter and the returned Config will be applied. type PatchFunc func(cfg Config) (Config, kubetypes.PatchType) type Namer interface { GetName() string GetNamespace() string } func NamespacedName[T Namer](o T) kubetypes.NamespacedName { return kubetypes.NamespacedName{ Namespace: o.GetNamespace(),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 12.6K bytes - Viewed (0) -
pkg/controller/testutil/test_utils.go
return watch.NewFake(), nil } // Patch patches a Node in the fake store. func (m *FakeNodeHandler) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, _ metav1.PatchOptions, subresources ...string) (*v1.Node, error) { m.lock.Lock() defer func() { m.RequestCount++ if m.PatchWaitChan != nil { m.PatchWaitChan <- struct{}{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 15.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/testing/testcase.go
} func patchAnnotationValue(configuration, webhook string, patch string) string { return strings.Replace(fmt.Sprintf(`{"configuration": "%s", "webhook": "%s", "patch": %s, "patchType": "JSONPatch"}`, configuration, webhook, patch), " ", "", -1) } // NewMutatingTestCases returns test cases with a given base url. // All test cases in NewMutatingTestCases have Patch set in
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 03 06:51:04 UTC 2023 - 47.6K bytes - Viewed (0) -
subprojects/diagnostics/src/main/java/org/gradle/api/tasks/diagnostics/internal/dependencies/MatchType.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.api.tasks.diagnostics.internal.dependencies; public enum MatchType { /** * The attribute was not requested by the configuration. */ NOT_REQUESTED, /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Feb 22 19:19:36 UTC 2022 - 1.3K bytes - Viewed (0) -
pkg/kube/inject/webhook.go
handleError(fmt.Sprintf("Pod injection failed: %v", err)) return toAdmissionResponse(err) } reviewResponse := kube.AdmissionResponse{ Allowed: true, Patch: patchBytes, PatchType: func() *string { pt := "JSONPatch" return &pt }(), } totalSuccessfulInjections.Increment() return &reviewResponse }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:59:39 UTC 2024 - 42.2K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/types.gen.go
default: return nil, fmt.Errorf("unsupported type: %v", cfg.GroupVersionKind) } } func patch(c kube.Client, orig config.Config, origMeta metav1.ObjectMeta, mod config.Config, modMeta metav1.ObjectMeta, typ types.PatchType) (metav1.Object, error) { if orig.GroupVersionKind != mod.GroupVersionKind { return nil, fmt.Errorf("gvk mismatch: %v, modified: %v", orig.GroupVersionKind, mod.GroupVersionKind) } switch orig.GroupVersionKind {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 17:37:32 UTC 2024 - 62.2K bytes - Viewed (0)