- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for UnstructuredList (0.19 sec)
-
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/cbor/cbor_test.go
} }, }, { name: "into unstructuredlist empty", data: []byte("\xa2\x6aapiVersion\x61v\x64kind\x65kList"), into: &unstructured.UnstructuredList{}, expectedObj: &unstructured.UnstructuredList{Object: map[string]interface{}{ "apiVersion": "v", "kind": "kList", }}, expectedGVK: &schema.GroupVersionKind{Version: "v", Kind: "kList"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 14:57:12 UTC 2024 - 20.1K bytes - Viewed (0) -
operator/pkg/helmreconciler/prune.go
// UnstructuredList of objects and corresponding list of name kind hash of k8sObjects would be returned func (h *HelmReconciler) GetPrunedResources(revision string, includeClusterResources bool, componentName string) ( []*unstructured.UnstructuredList, error, ) { var usList []*unstructured.UnstructuredList labels := make(map[string]string) if revision != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 15.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/conversion/converter.go
return nil } // ConvertToVersion converts in object to the given gvk in place and returns the same `in` object. // The in object can be a single object or a UnstructuredList. CRD storage implementation creates an // UnstructuredList with the request's GV, populates it from storage, then calls conversion to convert // the individual items. This function assumes it never gets a v1.List.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 9.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/cbor/cbor.go
if u, ok := into.(runtime.Unstructured); ok { var content map[string]interface{} defer func() { switch u := u.(type) { case *unstructured.UnstructuredList: // UnstructuredList's implementation of SetUnstructuredContent // produces different objects than those produced by a decode using // UnstructuredJSONScheme: //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 14:57:12 UTC 2024 - 9.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go
listObj, err := crClient.List(ctx, nil) if err != nil { return false, err } if len(listObj.(*unstructured.UnstructuredList).Items) == 0 { return true, nil } klog.V(2).Infof("%s.%s waiting for %d items to be removed", crd.Status.AcceptedNames.Plural, crd.Spec.Group, len(listObj.(*unstructured.UnstructuredList).Items)) return false, nil }) if err != nil { return apiextensionsv1.CustomResourceDefinitionCondition{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.6K bytes - Viewed (0) -
operator/cmd/mesh/uninstall.go
// 2. lists to be pruned resources if user uninstall by --revision flag. func preCheckWarnings(cmd *cobra.Command, kubeClient kube.CLIClient, uiArgs *uninstallArgs, istioNamespace, rev string, resourcesList []*unstructured.UnstructuredList, objectsList object.K8sObjects, l *clog.ConsoleLogger, dryRun bool, ) { pids, err := proxyinfo.GetIDsFromProxyInfo(kubeClient, istioNamespace) needConfirmation, message := false, "" if uiArgs.purge {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 01:18:49 UTC 2024 - 10.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
// For unstructured lists with a target group/version, preserve the group/version in the instantiated list items if unstructuredList, isUnstructured := listObj.(*unstructured.UnstructuredList); isUnstructured { if apiVersion := unstructuredList.GetAPIVersion(); len(apiVersion) > 0 { return func() runtime.Object { return &unstructured.Unstructured{Object: map[string]interface{}{"apiVersion": apiVersion}}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
func getAllIstioObjects() object.K8sObjects { var out object.K8sObjects for _, gvk := range append(allClusterGVKs, allNamespacedGVKs...) { objects := &unstructured.UnstructuredList{} objects.SetGroupVersionKind(gvk) if err := testClient.List(context.TODO(), objects); err != nil { log.Error(err.Error()) continue } for _, o := range objects.Items { no := o.DeepCopy()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 20 22:39:28 UTC 2024 - 11.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go
) func init() { scheme.AddKnownTypeWithName(fakeGVK, &unstructured.Unstructured{}) scheme.AddKnownTypeWithName(fakeGVKList, &unstructured.UnstructuredList{}) } func setupTest(ctx context.Context, customReconciler func(string, string, runtime.Object) error) ( tracker clienttesting.ObjectTracker, controller generic.Controller[*unstructured.Unstructured],
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
} scheme.AddKnownTypeWithName(mapping.GroupVersionKind, &unstructured.Unstructured{}) scheme.AddKnownTypeWithName(mapping.GroupVersionKind.GroupVersion().WithKind(mapping.GroupVersionKind.Kind+"List"), &unstructured.UnstructuredList{}) } return scheme, nil }() if err != nil { return nil, nil, err } fakeRestMapper := func() *meta.DefaultRESTMapper { res := meta.NewDefaultRESTMapper([]schema.GroupVersion{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0)