- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 101 for unstructured (0.39 sec)
-
istioctl/pkg/validate/validate.go
) type validator struct{} func checkFields(un *unstructured.Unstructured) error { var errs error for key := range un.Object { if _, ok := validFields[key]; !ok { errs = multierror.Append(errs, fmt.Errorf("unknown field %q", key)) } } return errs } func (v *validator) validateResource(istioNamespace, defaultNamespace string, un *unstructured.Unstructured, writer io.Writer) (validation.Warning, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 22 17:58:52 UTC 2024 - 15K bytes - Viewed (0) -
operator/pkg/verifier/verifier.go
err := visitor.Visit(func(info *resource.Info, err error) error { if err != nil { return err } content, err := runtime.DefaultUnstructuredConverter.ToUnstructured(info.Object) if err != nil { return err } un := &unstructured.Unstructured{Object: content} kind := un.GetKind() name := un.GetName() namespace := un.GetNamespace() kinds := resourceKinds(un) if namespace == "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 19:23:44 UTC 2024 - 15K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache.go
return nil }) } func (ic *serviceImportCacheImpl) onServiceImportEvent(_, obj controllers.Object, event model.Event) error { si := controllers.Extract[*unstructured.Unstructured](obj) if si == nil { return nil } // We need a full push if the cluster VIP changes. needsFullPush := false // Get the updated MCS service.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/subresources_test.go
}, }, Schema: fixtures.AllowAllSchema(), }, }, }, }, } } func NewNoxuSubresourceInstance(namespace, name, version string) *unstructured.Unstructured { return &unstructured.Unstructured{ Object: map[string]interface{}{ "apiVersion": fmt.Sprintf("mygroup.example.com/%s", version), "kind": "WishIHadChosenNoxu", "metadata": map[string]interface{}{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 12 17:35:34 UTC 2024 - 33.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/oidc.go
} func convertObjectToUnstructured(obj interface{}) (*unstructured.Unstructured, error) { if obj == nil || reflect.ValueOf(obj).IsNil() { return &unstructured.Unstructured{Object: nil}, nil } ret, err := runtime.DefaultUnstructuredConverter.ToUnstructured(obj) if err != nil { return nil, err } return &unstructured.Unstructured{Object: ret}, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 19:29:33 UTC 2024 - 37.9K bytes - Viewed (0) -
operator/pkg/helmreconciler/prune.go
func (h *HelmReconciler) GetPrunedResources(revision string, includeClusterResources bool, componentName string) ( []*unstructured.UnstructuredList, error, ) { var usList []*unstructured.UnstructuredList labels := make(map[string]string) if revision != "" { labels[label.IoIstioRev.Name] = revision } if componentName != "" {
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/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
if scheme.Recognizes(mapping.GroupVersionKind) { continue } 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 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0) -
operator/cmd/mesh/uninstall.go
} } // constructResourceListOutput is a helper function to construct the output of to be removed resources list func constructResourceListOutput(resourcesList []*unstructured.UnstructuredList, objectsList object.K8sObjects) (string, string) { var items []unstructured.Unstructured if objectsList != nil { items = objectsList.UnstructuredItems() } for _, usList := range resourcesList { items = append(items, usList.Items...) }
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/admission/plugin/webhook/mutating/dispatcher.go
} var newVersionedObject runtime.Object if _, ok := attr.VersionedObject.(*unstructured.Unstructured); ok { // Custom Resources don't have corresponding Go struct's. // They are represented as Unstructured. newVersionedObject = &unstructured.Unstructured{} } else { newVersionedObject, err = o.GetObjectCreater().New(attr.VersionedKind) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 19.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fieldselector_test.go
shirtv1Client := dynamicClient.Resource(schema.GroupVersionResource{Group: crd.Spec.Group, Version: crd.Spec.Versions[0].Name, Resource: crd.Spec.Names.Plural}) for _, instance := range []string{shirtInstance1} { shirt := &unstructured.Unstructured{} if err := yaml.Unmarshal([]byte(instance), &shirt.Object); err != nil { t.Fatal(err) } _, err = shirtv1Client.Create(ctx, shirt, metav1.CreateOptions{}) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 15:53:03 UTC 2024 - 27K bytes - Viewed (0)