Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 105 for GroupResource (0.86 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go

    func filterLimitedResourcesByGroupResource(input []resourcequotaapi.LimitedResource, groupResource schema.GroupResource) []resourcequotaapi.LimitedResource {
    	result := []resourcequotaapi.LimitedResource{}
    	for i := range input {
    		limitedResource := input[i]
    		limitedGroupResource := schema.GroupResource{Group: limitedResource.APIGroup, Resource: limitedResource.Resource}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/phases/kubeconfig/kubeconfig_test.go

    					return true, nil, apierrors.NewAlreadyExists(
    						schema.GroupResource{}, "name")
    				})
    			},
    			setupSuperAdminClient: func(client *clientsetfake.Clientset) {
    				client.PrependReactor("create", "clusterrolebindings", func(action clientgotesting.Action) (bool, runtime.Object, error) {
    					return true, nil, apierrors.NewAlreadyExists(
    						schema.GroupResource{}, "name")
    				})
    			},
    			expectedError: false,
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:04:18 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/list_work_estimator.go

    		seats = maxSeats
    	}
    	return WorkEstimate{InitialSeats: seats}
    }
    
    func key(requestInfo *apirequest.RequestInfo) string {
    	groupResource := &schema.GroupResource{
    		Group:    requestInfo.APIGroup,
    		Resource: requestInfo.Resource,
    	}
    	return groupResource.String()
    }
    
    // NOTICE: Keep in sync with shouldDelegateList function in
    //
    //	staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 7K bytes
    - Viewed (0)
  4. pkg/controller/resourcequota/resource_quota_controller.go

    func (rq *Controller) replenishQuota(ctx context.Context, groupResource schema.GroupResource, namespace string) {
    	// check if the quota controller can evaluate this groupResource, if not, ignore it altogether...
    	evaluator := rq.registry.Get(groupResource)
    	if evaluator == nil {
    		return
    	}
    
    	// check if this namespace even has a quota...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  5. pkg/controlplane/apiserver/admission/initializer_test.go

    func (doNothingPluginInitialization) ValidateInitialization() error { return nil }
    
    type doNothingQuotaConfiguration struct{}
    
    func (doNothingQuotaConfiguration) IgnoredResources() map[schema.GroupResource]struct{} { return nil }
    
    func (doNothingQuotaConfiguration) Evaluators() []quota.Evaluator { return nil }
    
    type WantsQuotaConfigurationAdmissionPlugin struct {
    	doNothingAdmission
    	doNothingPluginInitialization
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 2K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/test/integration/subresources_test.go

    		}
    		if err := fixtures.DeleteV1CustomResourceDefinition(noxuDefinition, apiExtensionClient); err != nil {
    			t.Fatal(err)
    		}
    	}
    }
    
    func TestScaleSubresource(t *testing.T) {
    	groupResource := schema.GroupResource{
    		Group:    "mygroup.example.com",
    		Resource: "noxus",
    	}
    
    	tearDown, config, _, err := fixtures.StartDefaultServer(t)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer tearDown()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 12 17:35:34 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  7. pkg/controlplane/apiserver/config_test.go

    		t.Errorf("There are different StorageObjectCountTracker in genericConfig and storageFactory")
    	}
    
    	restOptions, err := genericConfig.RESTOptionsGetter.GetRESTOptions(schema.GroupResource{Group: "", Resource: ""})
    	if err != nil {
    		t.Fatal(err)
    	}
    	if restOptions.StorageConfig.StorageObjectCountTracker != genericConfig.StorageObjectCountTracker {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 12:14:06 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease_test.go

    	newListFunc := func() runtime.Object { return &corev1.EndpointsList{} }
    	sc.Codec = apitesting.TestStorageCodec(codecs, corev1.SchemeGroupVersion)
    
    	s, dFunc, err := factory.Create(*sc.ForResource(schema.GroupResource{Resource: "endpoints"}), newFunc, newListFunc, "")
    	if err != nil {
    		t.Fatalf("Error creating storage: %v", err)
    	}
    	t.Cleanup(dFunc)
    
    	tests := []struct {
    		testName     string
    		servers      []serverInfo
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  9. pkg/serviceaccount/claims_test.go

    	if f.serviceAccount == nil {
    		return nil, apierrors.NewNotFound(schema.GroupResource{Group: "", Resource: "serviceaccounts"}, name)
    	}
    	return f.serviceAccount, nil
    }
    func (f fakeGetter) GetPod(namespace, name string) (*v1.Pod, error) {
    	if f.pod == nil {
    		return nil, apierrors.NewNotFound(schema.GroupResource{Group: "", Resource: "pods"}, name)
    	}
    	return f.pod, nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/lister.go

    func (w lister[T]) Get(name string) (T, error) {
    	var result T
    
    	obj, exists, err := w.indexer.GetByKey(name)
    	if err != nil {
    		return result, err
    	}
    	if !exists {
    		// kerrors.StatusNotFound requires a GroupResource we cannot provide
    		return result, &kerrors.StatusError{ErrStatus: metav1.Status{
    			Status:  metav1.StatusFailure,
    			Code:    http.StatusNotFound,
    			Reason:  metav1.StatusReasonNotFound,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 12 18:58:24 UTC 2024
    - 2.6K bytes
    - Viewed (0)
Back to top