Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 39 for restMapper (0.16 sec)

  1. 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)
  2. staging/src/k8s.io/cli-runtime/pkg/genericclioptions/config_flags_fake.go

    // 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)
    		return expander, nil
    	}
    	return nil, fmt.Errorf("no restmapper")
    }
    
    // WithClientConfig sets the clientConfig flag
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 11 15:04:11 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/cli-runtime/pkg/genericclioptions/config_flags.go

    		}
    		f.restMapper = restMapper
    	}
    	return f.restMapper, nil
    }
    
    func (f *ConfigFlags) toRESTMapper() (meta.RESTMapper, error) {
    	discoveryClient, err := f.ToDiscoveryClient()
    	if err != nil {
    		return nil, err
    	}
    
    	mapper := restmapper.NewDeferredDiscoveryRESTMapper(discoveryClient)
    	expander := restmapper.NewShortcutExpander(mapper, discoveryClient, func(a string) {
    		if f.warningPrinter != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 11 15:04:11 UTC 2023
    - 16.9K bytes
    - Viewed (0)
  4. pkg/kube/client_factory.go

    		if err != nil {
    			return nil, err
    		}
    		return restmapper.NewDeferredDiscoveryRESTMapper(discoveryClient), nil
    	})
    	out.expander = lazy.NewWithRetry(func() (meta.RESTMapper, error) {
    		discoveryClient, err := out.discoveryClient.Get()
    		if err != nil {
    			return nil, err
    		}
    		mapper, err := out.mapper.Get()
    		if err != nil {
    			return nil, err
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Dec 15 21:30:37 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  5. plugin/pkg/admission/gc/gc_admission.go

    	a.authorizer = authorizer
    }
    
    func (a *gcPermissionsEnforcement) SetRESTMapper(restMapper meta.RESTMapper) {
    	a.restMapper = restMapper
    }
    
    func (a *gcPermissionsEnforcement) ValidateInitialization() error {
    	if a.authorizer == nil {
    		return fmt.Errorf("missing authorizer")
    	}
    	if a.restMapper == nil {
    		return fmt.Errorf("missing restMapper")
    	}
    	return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 05 02:24:38 UTC 2023
    - 10.3K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top