Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 58 for restmapper (0.3 sec)

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