- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 49 for restmapper (0.18 sec)
-
staging/src/k8s.io/cli-runtime/pkg/genericclioptions/config_flags.go
if err != nil { return nil, err } f.restMapper = restMapper } return f.restMapper, nil } func (f *ConfigFlags) toRESTMapper() (meta.RESTMapper, error) { discoveryClient, err := f.ToDiscoveryClient() if err != nil { return nil, err } mapper := restmapper.NewDeferredDiscoveryRESTMapper(discoveryClient) expander := restmapper.NewShortcutExpander(mapper, discoveryClient, func(a string) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 11 15:04:11 UTC 2023 - 16.9K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/genericclioptions/config_flags_fake.go
return f.discoveryClient, nil } // ToRESTMapper implements RESTClientGetter. // Returns a mapper. func (f *TestConfigFlags) ToRESTMapper() (meta.RESTMapper, error) { if f.restMapper != nil { return f.restMapper, nil } if f.discoveryClient != nil { mapper := restmapper.NewDeferredDiscoveryRESTMapper(f.discoveryClient) expander := restmapper.NewShortcutExpander(mapper, f.discoveryClient, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 11 15:04:11 UTC 2023 - 3.9K bytes - Viewed (0) -
pkg/kube/client_factory.go
// ToRESTConfig returns restconfig ToRESTConfig() (*rest.Config, error) // ToDiscoveryClient returns discovery client ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error) // ToRESTMapper returns a restmapper ToRESTMapper() (meta.RESTMapper, error) // ToRawKubeConfigLoader return kubeconfig loader as-is ToRawKubeConfigLoader() clientcmd.ClientConfig } type PartialFactory interface { rESTClientGetter
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 15 21:30:37 UTC 2023 - 5.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer.go
featureGates featuregate.FeatureGate, stopCh <-chan struct{}, restMapper meta.RESTMapper, ) pluginInitializer { return pluginInitializer{ externalClient: extClientset, dynamicClient: dynamicClient, externalInformers: extInformers, authorizer: authz, featureGates: featureGates, stopCh: stopCh, restMapper: restMapper, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 3K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/mapper.go
Namespace: namespace, Name: name, ResourceVersion: resourceVersion, Object: obj, } if m.localFn == nil || !m.localFn() { restMapper, err := m.restMapperFn() if err != nil { return nil, err } mapping, err := restMapper.RESTMapping(gvk.GroupKind(), gvk.Version) if err != nil { if _, ok := err.(*meta.NoKindMatchError); ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 03 10:53:18 UTC 2024 - 4.8K bytes - Viewed (0) -
plugin/pkg/admission/gc/gc_admission.go
a.authorizer = authorizer } func (a *gcPermissionsEnforcement) SetRESTMapper(restMapper meta.RESTMapper) { a.restMapper = restMapper } func (a *gcPermissionsEnforcement) ValidateInitialization() error { if a.authorizer == nil { return fmt.Errorf("missing authorizer") } if a.restMapper == nil { return fmt.Errorf("missing restMapper") } return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 05 02:24:38 UTC 2023 - 10.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/plugin.go
source Source[H] dispatcher Dispatcher[H] matcher *matching.Matcher informerFactory informers.SharedInformerFactory client kubernetes.Interface restMapper meta.RESTMapper dynamicClient dynamic.Interface excludedResources sets.Set[schema.GroupResource] stopCh <-chan struct{} authorizer authorizer.Authorizer enabled bool } var (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 19:11:10 UTC 2024 - 6.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/typechecking.go
Resource: resource, } resolved, err := c.RestMapper.KindsFor(gvr) if err != nil { if restMapperRefreshAttempted { // RESTMapper refresh happens at most once per policy continue } c.tryRefreshRESTMapper() restMapperRefreshAttempted = true resolved, err = c.RestMapper.KindsFor(gvr) if err != nil { continue } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 15.3K bytes - Viewed (0) -
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)