Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 69 for restmapper (0.2 sec)

  1. 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)
  2. staging/src/k8s.io/apimachinery/pkg/api/meta/interfaces.go

    }
    
    // ResettableRESTMapper is a RESTMapper which is capable of resetting itself
    // from discovery.
    // All rest mappers that delegate to other rest mappers must implement this interface and dynamically
    // check if the delegate mapper supports the Reset() operation.
    type ResettableRESTMapper interface {
    	RESTMapper
    	Reset()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 05 23:44:02 UTC 2021
    - 5.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/api/meta/testrestmapper/test_restmapper.go

    //
    // TODO callers of this method should be updated to build their own specific restmapper based on their scheme for their tests
    // TODO the things being tested are related to whether various cases are handled, not tied to the particular types being checked.
    func TestOnlyStaticRESTMapper(scheme *runtime.Scheme, versionPatterns ...schema.GroupVersion) meta.RESTMapper {
    	unionMapper := meta.MultiRESTMapper{}
    	unionedGroups := sets.NewString()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 06 09:07:02 UTC 2023
    - 6.5K bytes
    - Viewed (0)
  4. 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)
  5. staging/src/k8s.io/apimachinery/pkg/api/meta/errors.go

    limitations under the License.
    */
    
    package meta
    
    import (
    	"errors"
    	"fmt"
    
    	"k8s.io/apimachinery/pkg/runtime/schema"
    	"k8s.io/apimachinery/pkg/util/sets"
    )
    
    // AmbiguousResourceError is returned if the RESTMapper finds multiple matches for a resource
    type AmbiguousResourceError struct {
    	PartialResource schema.GroupVersionResource
    
    	MatchingResources []schema.GroupVersionResource
    	MatchingKinds     []schema.GroupVersionKind
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 11 22:50:51 UTC 2022
    - 4.2K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top