Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 49 for restmapper (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top