- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 58 for restmapper (0.3 sec)
-
cmd/kube-controller-manager/app/validatingadmissionpolicystatus.go
typeChecker := &pluginvalidatingadmissionpolicy.TypeChecker{ SchemaResolver: schemaResolver, RestMapper: controllerContext.RESTMapper, } c, err := validatingadmissionpolicystatus.NewController( controllerContext.InformerFactory.Admissionregistration().V1().ValidatingAdmissionPolicies(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 2.6K bytes - Viewed (0) -
cmd/kube-controller-manager/app/autoscaling.go
scaleClient, err := scale.NewForConfig(hpaClientConfig, controllerContext.RESTMapper, dynamic.LegacyAPIPathResolverFunc, scaleKindResolver) if err != nil { return nil, false, err } go podautoscaler.NewHorizontalController( ctx, hpaClient.CoreV1(), scaleClient, hpaClient.AutoscalingV2(), controllerContext.RESTMapper, metricsClient,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 01:37:36 UTC 2024 - 4.2K 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) -
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)