Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 69 for restmapper (0.35 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. cmd/kube-controller-manager/app/import_known_versions.go

    limitations under the License.
    */
    
    // Package app imports the API groups that the client will support
    // TODO: Remove this file when namespace controller and garbage collector
    // stops using legacyscheme.Registry.RESTMapper()
    package app
    
    import (
    	// These imports are the API groups the client will support.
    	_ "k8s.io/kubernetes/pkg/apis/apps/install"
    	_ "k8s.io/kubernetes/pkg/apis/authentication/install"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 10 19:23:50 UTC 2022
    - 1.6K bytes
    - Viewed (0)
  9. 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)
  10. staging/src/k8s.io/apimachinery/pkg/api/meta/priority.go

    )
    
    // PriorityRESTMapper is a wrapper for automatically choosing a particular Resource or Kind
    // when multiple matches are possible
    type PriorityRESTMapper struct {
    	// Delegate is the RESTMapper to use to locate all the Kind and Resource matches
    	Delegate RESTMapper
    
    	// ResourcePriority is a list of priority patterns to apply to matching resources.
    	// The list of all matching resources is narrowed based on the patterns until only one remains.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 05 23:44:02 UTC 2021
    - 7.6K bytes
    - Viewed (0)
Back to top