- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 105 for GroupResource (0.86 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)