- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 32 for UnstructuredList (0.26 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/conversion/webhook_converter_test.go
ExpectObjects []runtime.RawExtension }{ { Name: "empty list", Object: &unstructured.UnstructuredList{}, APIVersion: "foo/v1", ExpectObjects: nil, }, { Name: "one-item list, in desired version", Object: &unstructured.UnstructuredList{ Items: []unstructured.Unstructured{*v1Object}, }, APIVersion: "foo/v1", ExpectObjects: nil, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 13 15:27:39 UTC 2023 - 19.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/unstructured/helpers.go
} func (unstructuredJSONScheme) doEncode(obj runtime.Object, w io.Writer) error { switch t := obj.(type) { case *Unstructured: return json.NewEncoder(w).Encode(t.Object) case *UnstructuredList: items := make([]interface{}, 0, len(t.Items)) for _, i := range t.Items { items = append(items, i.Object) } listObj := make(map[string]interface{}, len(t.Object)+1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 20:39:55 UTC 2023 - 16.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/conversion/nop_converter.go
func (c *nopConverter) Convert(in runtime.Object, targetGV schema.GroupVersion) (runtime.Object, error) { // Run the converter on the list items instead of list itself if list, ok := in.(*unstructured.UnstructuredList); ok { for i := range list.Items { list.Items[i].SetGroupVersionKind(targetGV.WithKind(list.Items[i].GroupVersionKind().Kind)) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 13 15:27:39 UTC 2023 - 1.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/test/apis_meta_v1_unstructed_unstructure_test.go
t.Errorf("GetSelfLink() = %s, want %s", got, want) } } func TestUnstructuredListSetters(t *testing.T) { unstruct := unstructured.UnstructuredList{} want := unstructured.UnstructuredList{ Object: map[string]interface{}{ "kind": "test_kind", "apiVersion": "test_version", "metadata": map[string]interface{}{ "resourceVersion": "test_resourceVersion",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 05 20:12:50 UTC 2022 - 17.3K bytes - Viewed (0) -
pkg/controller/namespace/deletion/namespaced_resources_deleter.go
if len(unstructuredList.Items) == 0 { // we're done return gvrDeletionMetadata{finalizerEstimateSeconds: 0, numRemaining: 0}, nil } // use the list to find the finalizers finalizersToNumRemaining := map[string]int{} for _, item := range unstructuredList.Items { for _, finalizer := range item.GetFinalizers() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 07:34:23 UTC 2023 - 25.2K 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) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/unstructured/unstructured.go
if !ok { return false } _, ok = field.([]interface{}) return ok } func (obj *Unstructured) ToList() (*UnstructuredList, error) { if !obj.IsList() { // return an empty list back return &UnstructuredList{Object: obj.Object}, nil } ret := &UnstructuredList{} ret.Object = obj.Object err := obj.EachListItem(func(item runtime.Object) error { castItem := item.(*Unstructured)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun May 28 03:26:35 UTC 2023 - 13.7K 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/apimachinery/pkg/apis/meta/v1/unstructured/helpers_test.go
// i.e. that it does not mutate the object being encoded. func TestCodecOfUnstructuredList(t *testing.T) { var wg sync.WaitGroup concurrency := 10 list := UnstructuredList{ Object: map[string]interface{}{}, } wg.Add(concurrency) for i := 0; i < concurrency; i++ { go func() { defer wg.Done() assert.NoError(t, UnstructuredJSONScheme.Encode(&list, ioutil.Discard))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 24 07:53:28 UTC 2021 - 5.9K bytes - Viewed (0)