Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 49 for restmapper (0.16 sec)

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