- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 69 for restmapper (0.35 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/plugin.go
return &Plugin{ Plugin: generic.NewPlugin( handler, func(f informers.SharedInformerFactory, client kubernetes.Interface, dynamicClient dynamic.Interface, restMapper meta.RESTMapper) generic.Source[PolicyHook] { return generic.NewPolicySource( f.Admissionregistration().V1().ValidatingAdmissionPolicies().Informer(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 7.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/initializer/interfaces.go
} type WantsDynamicClient interface { SetDynamicClient(dynamic.Interface) admission.InitializationValidator } // WantsRESTMapper defines a function which sets RESTMapper for admission plugins that need it. type WantsRESTMapper interface { SetRESTMapper(meta.RESTMapper) admission.InitializationValidator } // WantsSchemaResolver defines a function which sets the SchemaResolver for // an admission plugin that needs it.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 19:11:10 UTC 2024 - 3.6K bytes - Viewed (0) -
cmd/kube-controller-manager/app/controllermanager.go
ComponentConfig kubectrlmgrconfig.KubeControllerManagerConfiguration // DeferredDiscoveryRESTMapper is a RESTMapper that will defer // initialization of the RESTMapper until the first mapping is // requested. RESTMapper *restmapper.DeferredDiscoveryRESTMapper // Cloud is the cloud provider interface for the controllers to use. // It must be initialized and ready to use.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:53 UTC 2024 - 37.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go
) type policySource[P runtime.Object, B runtime.Object, E Evaluator] struct { ctx context.Context policyInformer generic.Informer[P] bindingInformer generic.Informer[B] restMapper meta.RESTMapper newPolicyAccessor func(P) PolicyAccessor newBindingAccessor func(B) BindingAccessor informerFactory informers.SharedInformerFactory dynamicClient dynamic.Interface compiler func(P) E
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 23:07:34 UTC 2024 - 15.2K bytes - Viewed (0) -
plugin/pkg/admission/gc/gc_admission_test.go
}, }, } restMapperRes, err := restmapper.GetAPIGroupResources(fakeDiscoveryClient) if err != nil { return nil, fmt.Errorf("unexpected error while constructing resource list from fake discovery client: %v", err) } restMapper := restmapper.NewDiscoveryRESTMapper(restMapperRes) genericPluginInitializer := initializer.New(nil, nil, nil, fakeAuthorizer{}, nil, nil, restMapper)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:28:42 UTC 2024 - 24.5K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/storageversionmigrator.go
svmListers svmlisters.StorageVersionMigrationLister svmSynced cache.InformerSynced queue workqueue.TypedRateLimitingInterface[string] restMapper meta.RESTMapper dependencyGraphBuilder *garbagecollector.GraphBuilder } func NewSVMController( ctx context.Context, kubeClient kubernetes.Interface, dynamicClient *dynamic.DynamicClient,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/typechecking_test.go
} }) } } func buildTypeChecker(schemaToReturn *spec.Schema) *TypeChecker { restMapper := meta.NewDefaultRESTMapper([]schema.GroupVersion{ { Group: "", Version: "v1", }, }) restMapper.Add(must3(scheme.ObjectKinds(&corev1.Pod{}))[0], meta.RESTScopeRoot) restMapper.Add(must3(scheme.ObjectKinds(&appsv1.Deployment{}))[0], meta.RESTScopeRoot) return &TypeChecker{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 16.3K bytes - Viewed (0) -
cmd/kube-controller-manager/app/import_known_versions.go
limitations under the License. */ // Package app imports the API groups that the client will support // TODO: Remove this file when namespace controller and garbage collector // stops using legacyscheme.Registry.RESTMapper() package app import ( // These imports are the API groups the client will support. _ "k8s.io/kubernetes/pkg/apis/apps/install" _ "k8s.io/kubernetes/pkg/apis/authentication/install"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 10 19:23:50 UTC 2022 - 1.6K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
// mapper, but we'll deal with it for now. gc.restMapper.Reset() logger.V(4).Info("reset restmapper") // Perform the monitor resync and wait for controllers to report cache sync. // // NOTE: It's possible that newResources will diverge from the resources // discovered by restMapper during the call to Reset, since they are
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/meta/priority.go
) // PriorityRESTMapper is a wrapper for automatically choosing a particular Resource or Kind // when multiple matches are possible type PriorityRESTMapper struct { // Delegate is the RESTMapper to use to locate all the Kind and Resource matches Delegate RESTMapper // ResourcePriority is a list of priority patterns to apply to matching resources. // The list of all matching resources is narrowed based on the patterns until only one remains.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 05 23:44:02 UTC 2021 - 7.6K bytes - Viewed (0)