- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 49 for restmapper (0.16 sec)
-
cmd/kube-controller-manager/app/policy.go
config := controllerContext.ClientBuilder.ConfigOrDie("disruption-controller") scaleKindResolver := scale.NewDiscoveryScaleKindResolver(client.Discovery()) scaleClient, err := scale.NewForConfig(config, controllerContext.RESTMapper, dynamic.LegacyAPIPathResolverFunc, scaleKindResolver) if err != nil { return nil, false, err } go disruption.NewDisruptionController( ctx, controllerContext.InformerFactory.Core().V1().Pods(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 11:28:02 UTC 2023 - 2.2K bytes - Viewed (0) -
cmd/kube-controller-manager/app/storageversionmigrator.go
ctx, client, discoveryClient, metadata.NewForConfigOrDie(config), informer, controllerContext.RESTMapper, ).Run(ctx) svmController := svm.NewSVMController( ctx, client, dynamicClient, informer, controllerName, controllerContext.RESTMapper, controllerContext.GraphBuilder, ) go svmController.Run(ctx) return svmController, true, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 19:25:10 UTC 2024 - 2.6K bytes - Viewed (0) -
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) -
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) -
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)