- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 50 for restMapper (0.14 sec)
-
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) -
staging/src/k8s.io/cli-runtime/pkg/resource/builder.go
gvk := schema.GroupVersionKind{} restMapper, err := b.restMapperFn() if err != nil { return nil, err } if fullySpecifiedGVR != nil { gvk, _ = restMapper.KindFor(*fullySpecifiedGVR) } if gvk.Empty() { gvk, _ = restMapper.KindFor(groupResource.WithVersion("")) } if !gvk.Empty() { return restMapper.RESTMapping(gvk.GroupKind(), gvk.Version) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 10:17:56 UTC 2023 - 37.2K 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) -
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) -
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)