Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 34 for restmapper (0.29 sec)

  1. staging/src/k8s.io/cli-runtime/pkg/genericclioptions/config_flags_fake.go

    	return f.discoveryClient, nil
    }
    
    // ToRESTMapper implements RESTClientGetter.
    // Returns a mapper.
    func (f *TestConfigFlags) ToRESTMapper() (meta.RESTMapper, error) {
    	if f.restMapper != nil {
    		return f.restMapper, nil
    	}
    	if f.discoveryClient != nil {
    		mapper := restmapper.NewDeferredDiscoveryRESTMapper(f.discoveryClient)
    		expander := restmapper.NewShortcutExpander(mapper, f.discoveryClient, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 11 15:04:11 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  2. pkg/kube/client_factory.go

    	// ToRESTConfig returns restconfig
    	ToRESTConfig() (*rest.Config, error)
    	// ToDiscoveryClient returns discovery client
    	ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)
    	// ToRESTMapper returns a restmapper
    	ToRESTMapper() (meta.RESTMapper, error)
    	// ToRawKubeConfigLoader return kubeconfig loader as-is
    	ToRawKubeConfigLoader() clientcmd.ClientConfig
    }
    
    type PartialFactory interface {
    	rESTClientGetter
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Dec 15 21:30:37 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer.go

    	featureGates featuregate.FeatureGate,
    	stopCh <-chan struct{},
    	restMapper meta.RESTMapper,
    ) pluginInitializer {
    	return pluginInitializer{
    		externalClient:    extClientset,
    		dynamicClient:     dynamicClient,
    		externalInformers: extInformers,
    		authorizer:        authz,
    		featureGates:      featureGates,
    		stopCh:            stopCh,
    		restMapper:        restMapper,
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/cli-runtime/pkg/resource/mapper.go

    		Namespace:       namespace,
    		Name:            name,
    		ResourceVersion: resourceVersion,
    
    		Object: obj,
    	}
    
    	if m.localFn == nil || !m.localFn() {
    		restMapper, err := m.restMapperFn()
    		if err != nil {
    			return nil, err
    		}
    		mapping, err := restMapper.RESTMapping(gvk.GroupKind(), gvk.Version)
    		if err != nil {
    			if _, ok := err.(*meta.NoKindMatchError); ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 03 10:53:18 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top