Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for gvr (0.03 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/test/integration/ratcheting_test.go

    type applyPatchOperation struct {
    	description string
    	gvr         schema.GroupVersionResource
    	name        string
    	patch       interface{}
    }
    
    func (a applyPatchOperation) Do(ctx *ratchetingTestContext) error {
    	// Lookup GVK from discovery
    	kind, ok := fakeRESTMapper[a.gvr]
    	if !ok {
    		return fmt.Errorf("no mapping found for Gvr %v, add entry to fakeRESTMapper", a.gvr)
    	}
    
    	patch := &unstructured.Unstructured{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 59.5K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go

    	return func(action cgotesting.Action) (handled bool, ret apiruntime.Object, err error) {
    		// listAction := action.(cgotesting.ListAction)
    		gvr := action.GetResource()
    		ns := action.GetNamespace()
    		gvr.Resource += "es"
    		list, err := tracker.List(gvr, schema.GroupVersionKind{Group: gvr.Group, Version: gvr.Version, Kind: kind}, ns)
    		return true, list, err
    	}
    }
    
    func Test_isSchedulableAfterClaimChange(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 61.9K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go

    	up.SplitEvents = true
    	cl := kubeclient.NewFakeClient()
    	t.Cleanup(cl.Shutdown)
    	for _, crd := range []schema.GroupVersionResource{
    		gvr.AuthorizationPolicy,
    		gvr.PeerAuthentication,
    		gvr.KubernetesGateway,
    		gvr.GatewayClass,
    		gvr.WorkloadEntry,
    		gvr.ServiceEntry,
    	} {
    		clienttest.MakeCRD(t, cl, crd)
    	}
    	idx := New(Options{
    		Client:          cl,
    		SystemNamespace: systemNS,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 01:04:50 UTC 2024
    - 70.2K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/volumebinding/binder_test.go

    	// TODO refactor all tests to use real watch mechanism, see #72327
    	client.AddWatchReactor("*", func(action k8stesting.Action) (handled bool, ret watch.Interface, err error) {
    		gvr := action.GetResource()
    		ns := action.GetNamespace()
    		watch, err := reactor.Watch(gvr, ns)
    		if err != nil {
    			return false, nil, err
    		}
    		return true, watch, nil
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/endpoints/installer.go

    		gvk := gvkProvider.GroupVersionKind(a.group.GroupVersion)
    		apiResource.Group = gvk.Group
    		apiResource.Version = gvk.Version
    		apiResource.Kind = gvk.Kind
    	}
    
    	// Record the existence of the GVR and the corresponding GVK
    	a.group.EquivalentResourceRegistry.RegisterKindFor(reqScope.Resource, reqScope.Subresource, fqKindToRegister)
    
    	return &apiResource, resourceInfo, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 18:15:22 UTC 2024
    - 51.5K bytes
    - Viewed (0)
Back to top