Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for GroupResource (0.45 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    	// An underlying storage.Interface.
    	Storage storage.Interface
    
    	// An underlying storage.Versioner.
    	Versioner storage.Versioner
    
    	// The GroupResource the cacher is caching. Used for disambiguating *unstructured.Unstructured (CRDs) in logging
    	// and metrics.
    	GroupResource schema.GroupResource
    
    	// The Cache will be caching objects of a given Type and assumes that they
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go

    			return nil, fmt.Errorf("the server could not properly serve the list kind")
    		}
    
    		storages[v.Name] = customresource.NewStorage(
    			resource.GroupResource(),
    			singularResource.GroupResource(),
    			kind,
    			listKind,
    			customresource.NewStrategy(
    				typer,
    				crd.Spec.Scope == apiextensionsv1.NamespaceScoped,
    				kind,
    				validator,
    				statusValidator,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 52.9K bytes
    - Viewed (0)
  3. cmd/kube-controller-manager/app/options/options_test.go

    		},
    		GarbageCollectorController: &GarbageCollectorControllerOptions{
    			&garbagecollectorconfig.GarbageCollectorControllerConfiguration{
    				ConcurrentGCSyncs: 30,
    				GCIgnoredResources: []garbagecollectorconfig.GroupResource{
    					{Group: "", Resource: "events"},
    					{Group: eventv1.GroupName, Resource: "events"},
    				},
    				EnableGarbageCollector: false,
    			},
    		},
    		HPAController: &HPAControllerOptions{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 02:59:09 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  4. pkg/controller/cronjob/cronjob_controllerv2_test.go

    			ranPreviously:              true,
    			jobCreationTime:            justAfterThePriorHour(),
    			now:                        *justAfterTheHour(),
    			jobCreateError:             errors.NewAlreadyExists(schema.GroupResource{Resource: "job", Group: "batch"}, ""),
    			expectErr:                  false,
    			expectUpdateStatus:         true,
    			jobPresentInCJActiveStatus: true,
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 70.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go

    	return obj, nil
    }
    
    // qualifiedResourceFromContext attempts to retrieve a GroupResource from the context's request info.
    // If the context has no request info, DefaultQualifiedResource is used.
    func (e *Store) qualifiedResourceFromContext(ctx context.Context) schema.GroupResource {
    	if info, ok := genericapirequest.RequestInfoFrom(ctx); ok {
    		return schema.GroupResource{Group: info.APIGroup, Resource: info.Resource}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 23:22:44 UTC 2024
    - 60.8K bytes
    - Viewed (0)
  6. pkg/controller/podautoscaler/replica_calculator_test.go

    		mapping, err := mapper.RESTMapping(gk)
    		if err != nil {
    			return true, nil, fmt.Errorf("unable to get mapping for %s: %v", gk.String(), err)
    		}
    		groupResource := mapping.Resource.GroupResource()
    
    		assert.Equal(t, groupResource.String(), getForAction.GetResource().Resource, "should have requested metrics for the resource matching the GroupKind passed in")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Aug 19 03:31:34 UTC 2023
    - 68.4K bytes
    - Viewed (0)
  7. pkg/controller/podautoscaler/horizontal.go

    func (a *HorizontalController) scaleForResourceMappings(ctx context.Context, namespace, name string, mappings []*apimeta.RESTMapping) (*autoscalingv1.Scale, schema.GroupResource, error) {
    	var firstErr error
    	for i, mapping := range mappings {
    		targetGR := mapping.Resource.GroupResource()
    		scale, err := a.scaleNamespacer.Scales(namespace).Get(ctx, targetGR, name, metav1.GetOptions{})
    		if err == nil {
    			return scale, targetGR, nil
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    )
    
    func newTestCacherWithoutSyncing(s storage.Interface) (*Cacher, storage.Versioner, error) {
    	prefix := "pods"
    	config := Config{
    		Storage:        s,
    		Versioner:      storage.APIObjectVersioner{},
    		GroupResource:  schema.GroupResource{Resource: "pods"},
    		ResourcePrefix: prefix,
    		KeyFunc:        func(obj runtime.Object) (string, error) { return storage.NamespaceKeyFunc(prefix, obj) },
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  9. pkg/controller/disruption/disruption_test.go

    			dc, _ := newFakeDisruptionController(ctx)
    
    			dc.scaleClient.AddReactor("get", resourceName, func(action core.Action) (handled bool, ret runtime.Object, err error) {
    				gr := schema.GroupResource{
    					Group:    customGVK.Group,
    					Resource: resourceName,
    				}
    				return true, nil, errors.NewNotFound(gr, "name")
    			})
    			dc.discoveryClient.Resources = []*metav1.APIResourceList{
    				{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 50K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/endpoints/installer.go

    		if a.group.ConvertabilityChecker != nil {
    			decodableVersions = a.group.ConvertabilityChecker.VersionsForGroupKind(fqKindToRegister.GroupKind())
    		}
    
    		resourceInfo = &storageversion.ResourceInfo{
    			GroupResource: schema.GroupResource{
    				Group:    a.group.GroupVersion.Group,
    				Resource: apiResource.Name,
    			},
    			EncodingVersion: encodingGVK.GroupVersion().String(),
    			// We record EquivalentResourceMapper first instead of calculate
    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