Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for GroupResource (0.19 sec)

  1. staging/src/k8s.io/apiserver/pkg/endpoints/apiserver_test.go

    	return true
    }
    
    func (storage *SimpleRESTStorage) ConvertToTable(ctx context.Context, obj runtime.Object, tableOptions runtime.Object) (*metav1.Table, error) {
    	return rest.NewDefaultTableConvertor(schema.GroupResource{Resource: "simple"}).ConvertToTable(ctx, obj, tableOptions)
    }
    
    func (storate *SimpleRESTStorage) GetSingularName() string {
    	return "simple"
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 20:15:22 UTC 2023
    - 158.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    		config := cacherstorage.Config{
    			Storage:        s,
    			Versioner:      storage.APIObjectVersioner{},
    			GroupResource:  schema.GroupResource{Resource: "pods"},
    			ResourcePrefix: podPrefix,
    			KeyFunc:        func(obj runtime.Object) (string, error) { return storage.NoNamespaceKeyFunc(podPrefix, obj) },
    			GetAttrsFunc:   getPodAttrs,
    			NewFunc:        newFunc,
    			NewListFunc:    newListFunc,
    			Codec:          sc.Codec,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  3. pkg/controller/podautoscaler/horizontal_test.go

    				mapping, err := mapper.RESTMapping(gk)
    				if err != nil {
    					t.Logf("unable to get mapping for %s: %v", gk.String(), err)
    					continue
    				}
    				groupResource := mapping.Resource.GroupResource()
    
    				if getForAction.GetResource().Resource == groupResource.String() {
    					matchedTarget = &tc.metricsTarget[i]
    				}
    			}
    		}
    		assert.NotNil(t, matchedTarget, "this request should have matched one of the metric specs")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 199.3K bytes
    - Viewed (0)
  4. pkg/controller/garbagecollector/garbagecollector_test.go

    	// construction will not fail.
    	alwaysStarted := make(chan struct{})
    	close(alwaysStarted)
    	logger, tCtx := ktesting.NewTestContext(t)
    	gc, err := NewGarbageCollector(tCtx, client, metadataClient, rm, map[schema.GroupResource]struct{}{},
    		informerfactory.NewInformerFactory(sharedInformers, metadataInformers), alwaysStarted)
    	if err != nil {
    		t.Fatal(err)
    	}
    	assert.Equal(t, 0, len(gc.dependencyGraphBuilder.monitors))
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.6K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_pods_test.go

    					err = apierrors.NewNotFound(action.GetResource().GroupResource(), "configmap-name")
    				}
    				return true, tc.configMap, err
    			})
    			testKubelet.fakeKubeClient.AddReactor("get", "secrets", func(action core.Action) (bool, runtime.Object, error) {
    				var err error
    				if tc.secret == nil {
    					err = apierrors.NewNotFound(action.GetResource().GroupResource(), "secret-name")
    				}
    				return true, tc.secret, err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  6. pkg/printers/internalversion/printers.go

    	row := metav1.TableRow{
    		Object: runtime.RawExtension{Object: obj},
    	}
    
    	parentRefName := "<none>"
    	if obj.Spec.ParentRef != nil {
    		gr := schema.GroupResource{
    			Group:    obj.Spec.ParentRef.Group,
    			Resource: obj.Spec.ParentRef.Resource,
    		}
    		parentRefName = strings.ToLower(gr.String())
    		if obj.Spec.ParentRef.Namespace != "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
  7. pkg/controller/job/job_controller_test.go

    			wantRequeued: false,
    		},
    		"generic error": {
    			updateErr:    fmt.Errorf("update error"),
    			wantRequeued: true,
    		},
    		"conflict error": {
    			updateErr:    apierrors.NewConflict(schema.GroupResource{}, "", nil),
    			wantRequeued: true,
    		},
    	}
    	for name, tc := range cases {
    		t.Run(name, func(t *testing.T) {
    			t.Cleanup(setDurationDuringTest(&DefaultJobApiBackOff, fastJobApiBackoff))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
Back to top