- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 69 for restmapper (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)