Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for UnstructuredList (0.19 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top