Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for CustomResource (0.45 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/etcd_test.go

    	defer server.Terminate(t)
    	defer storage.CustomResource.Store.DestroyFunc()
    	test := registrytest.New(t, storage.CustomResource.Store)
    	test.TestList(validNewCustomResource())
    }
    
    func TestDelete(t *testing.T) {
    	storage, server := newStorage(t)
    	defer server.Terminate(t)
    	defer storage.CustomResource.Store.DestroyFunc()
    	test := registrytest.New(t, storage.CustomResource.Store)
    	test.TestDelete(validNewCustomResource())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/validation/validation.go

    // `old` to `new` against the schema in the CustomResourceDefinition.
    // Both customResource and old represent a JSON data structures.
    //
    // If feature `CRDValidationRatcheting` is disabled, this behaves identically to
    // ValidateCustomResource(customResource).
    func ValidateCustomResourceUpdate(fldPath *field.Path, customResource, old interface{}, validator SchemaValidator, options ...ValidationOption) field.ErrorList {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 18:23:28 UTC 2023
    - 15K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/strategy.go

    }
    
    // PrepareForCreate clears the status of a CustomResource before creation.
    func (a customResourceStrategy) PrepareForCreate(ctx context.Context, obj runtime.Object) {
    	if a.status != nil {
    		customResourceObject := obj.(*unstructured.Unstructured)
    		customResource := customResourceObject.UnstructuredContent()
    
    		// create cannot set status
    		delete(customResource, "status")
    	}
    
    	accessor, _ := meta.Accessor(obj)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 21:22:34 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/types.go

    	// Only JSON paths without the array notation are allowed.
    	// Must be a JSON Path under .spec.
    	// If there is no value under the given path in the CustomResource, the /scale subresource will return an error on GET.
    	SpecReplicasPath string
    	// StatusReplicasPath defines the JSON path inside of a CustomResource that corresponds to Scale.Status.Replicas.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/validation/metrics_test.go

    	"k8s.io/apiextensions-apiserver/pkg/apiserver/validation"
    	apiextensionsfeatures "k8s.io/apiextensions-apiserver/pkg/features"
    	"k8s.io/apiextensions-apiserver/pkg/registry/customresource"
    	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
    	"k8s.io/apimachinery/pkg/runtime/schema"
    	utilfeature "k8s.io/apiserver/pkg/util/feature"
    	featuregatetesting "k8s.io/component-base/featuregate/testing"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go

    		Type:    apiextensionsv1.Terminating,
    		Status:  apiextensionsv1.ConditionTrue,
    		Reason:  "InstanceDeletionInProgress",
    		Message: "CustomResource deletion is in progress",
    	})
    	crd, err = c.crdClient.CustomResourceDefinitions().UpdateStatus(context.TODO(), crd, metav1.UpdateOptions{})
    	if apierrors.IsNotFound(err) || apierrors.IsConflict(err) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/test/integration/subresources_test.go

    	obj, err = noxuResourceClient.Create(context.TODO(), obj, metav1.CreateOptions{})
    	if err != nil {
    		t.Logf("%#v", obj)
    		t.Fatalf("Failed to create CustomResource: %v", err)
    	}
    
    	noxuResourceClient = newNamespacedCustomResourceVersionedClient(ns, dynamicClient, noxuDefinition, "v1")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 12 17:35:34 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  8. pilot/pkg/features/experimental.go

    	EnableEnhancedResourceScoping = env.Register("ENABLE_ENHANCED_RESOURCE_SCOPING", true,
    		"If enabled, meshConfig.discoverySelectors will limit the CustomResource configurations(like Gateway,VirtualService,DestinationRule,Ingress, etc)"+
    			"that can be processed by pilot. This will also restrict the root-ca certificate distribution.").Get()
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:02:38 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  9. operator/pkg/object/objects.go

    	var ret K8sObjects
    	for _, o := range objs {
    		if o.Kind == kind {
    			ret = append(ret, o)
    		}
    	}
    	return ret
    }
    
    // ParseK8SYAMLToIstioOperator parses a IstioOperator CustomResource YAML string and unmarshals in into
    // an IstioOperatorSpec object. It returns the object and an API group/version with it.
    func ParseK8SYAMLToIstioOperator(yml string) (*v1alpha1.IstioOperator, *schema.GroupVersionKind, error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Sep 21 07:16:46 UTC 2023
    - 15.5K bytes
    - Viewed (0)
  10. plugin/pkg/admission/serviceaccount/admission_test.go

    		}
    	}
    }
    
    func TestIgnoresNonPodResource(t *testing.T) {
    	pod := &api.Pod{}
    	attrs := admission.NewAttributesRecord(pod, nil, api.Kind("Pod").WithVersion("version"), "myns", "myname", api.Resource("CustomResource").WithVersion("version"), "", admission.Create, &metav1.CreateOptions{}, false, nil)
    	handler := admissiontesting.WithReinvocationTesting(t, NewServiceAccount())
    	err := handler.Admit(context.TODO(), attrs, nil)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 17:49:30 UTC 2024
    - 36.9K bytes
    - Viewed (0)
Back to top