Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 49 for restmapper (0.16 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer_test.go

    	}
    }
    
    type WantsRESTMapperAdmissionPlugin struct {
    	doNothingAdmission
    	doNothingPluginInitialization
    	mapper meta.RESTMapper
    }
    
    func (p *WantsRESTMapperAdmissionPlugin) SetRESTMapper(mapper meta.RESTMapper) {
    	p.mapper = mapper
    }
    
    type doNothingRESTMapper struct{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go

    	context.Context
    	Plugin *Plugin[PolicyHook[P, B, E]]
    	Source Source[PolicyHook[P, B, E]]
    	Start  func() error
    
    	scheme     *runtime.Scheme
    	restMapper *meta.DefaultRESTMapper
    	policyGVR  schema.GroupVersionResource
    	bindingGVR schema.GroupVersionResource
    
    	policyGVK  schema.GroupVersionKind
    	bindingGVK schema.GroupVersionKind
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 19K bytes
    - Viewed (0)
  3. pkg/controller/disruption/disruption.go

    	kubeClient clientset.Interface,
    	restMapper apimeta.RESTMapper,
    	scaleNamespacer scaleclient.ScalesGetter,
    	discoveryClient discovery.DiscoveryInterface,
    ) *DisruptionController {
    	return NewDisruptionControllerInternal(
    		ctx,
    		podInformer,
    		pdbInformer,
    		rcInformer,
    		rsInformer,
    		dInformer,
    		ssInformer,
    		kubeClient,
    		restMapper,
    		scaleNamespacer,
    		discoveryClient,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.1K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/server/options/admission.go

    	"k8s.io/apiserver/pkg/server"
    	cacheddiscovery "k8s.io/client-go/discovery/cached/memory"
    	"k8s.io/client-go/dynamic"
    	"k8s.io/client-go/informers"
    	"k8s.io/client-go/kubernetes"
    	"k8s.io/client-go/restmapper"
    	"k8s.io/component-base/featuregate"
    )
    
    var configScheme = runtime.NewScheme()
    
    func init() {
    	utilruntime.Must(apiserverapi.AddToScheme(configScheme))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun May 12 08:49:42 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  5. pkg/controller/garbagecollector/garbagecollector_test.go

    	"k8s.io/kubernetes/pkg/api/legacyscheme"
    	c "k8s.io/kubernetes/pkg/controller"
    	"k8s.io/kubernetes/test/utils/ktesting"
    )
    
    type testRESTMapper struct {
    	meta.RESTMapper
    }
    
    func (m *testRESTMapper) Reset() {
    	meta.MaybeResetRESTMapper(m.RESTMapper)
    }
    
    func TestGarbageCollectorConstruction(t *testing.T) {
    	config := &restclient.Config{}
    	tweakableRM := meta.NewDefaultRESTMapper(nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.6K bytes
    - Viewed (0)
  6. pkg/controller/validatingadmissionpolicystatus/controller_test.go

    			typeChecker := &validatingadmissionpolicy.TypeChecker{
    				SchemaResolver: resolver.NewDefinitionsSchemaResolver(openapi.GetOpenAPIDefinitions, scheme.Scheme),
    				RestMapper:     testrestmapper.TestOnlyStaticRESTMapper(scheme.Scheme),
    			}
    			controller, err := NewController(
    				informerFactory.Admissionregistration().V1().ValidatingAdmissionPolicies(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  7. pkg/controller/garbagecollector/graph_builder.go

    // a graph that caches the dependencies as we know, and enqueues
    // items to the attemptToDelete and attemptToOrphan.
    type GraphBuilder struct {
    	restMapper meta.RESTMapper
    
    	// each monitor list/watches a resource, the results are funneled to the
    	// dependencyGraphBuilder
    	monitors    monitors
    	monitorLock sync.RWMutex
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  8. cmd/kube-controller-manager/app/core.go

    	}
    
    	garbageCollector, err := garbagecollector.NewComposedGarbageCollector(
    		ctx,
    		gcClientset,
    		metadataClient,
    		controllerContext.RESTMapper,
    		controllerContext.GraphBuilder,
    	)
    	if err != nil {
    		return nil, true, fmt.Errorf("failed to start the generic garbage collector: %w", err)
    	}
    
    	// Start the garbage collector.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 39K bytes
    - Viewed (0)
  9. pkg/controller/podautoscaler/horizontal.go

    // control.
    type HorizontalController struct {
    	scaleNamespacer scaleclient.ScalesGetter
    	hpaNamespacer   autoscalingclient.HorizontalPodAutoscalersGetter
    	mapper          apimeta.RESTMapper
    
    	replicaCalc   *ReplicaCalculator
    	eventRecorder record.EventRecorder
    
    	downscaleStabilisationWindow time.Duration
    
    	monitor monitor.Monitor
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  10. src/mdo/java/WrapperList.java

        private final Function<U, T> mapper;
        private final Function<T, U> revMapper;
    
        WrapperList(List<U> list, Function<U, T> mapper, Function<T, U> revMapper) {
            this(() -> list, null, mapper, revMapper);
        }
    
        WrapperList(Supplier<List<U>> getter, Consumer<List<U>> setter, Function<U, T> mapper, Function<T, U> revMapper) {
            this.getter = getter;
            this.setter = setter;
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Fri Mar 01 16:30:18 UTC 2024
    - 3.5K bytes
    - Viewed (0)
Back to top