- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 39 for restMapper (0.55 sec)
-
pkg/controller/storageversionmigrator/storageversionmigrator.go
svmListers svmlisters.StorageVersionMigrationLister svmSynced cache.InformerSynced queue workqueue.TypedRateLimitingInterface[string] restMapper meta.RESTMapper dependencyGraphBuilder *garbagecollector.GraphBuilder } func NewSVMController( ctx context.Context, kubeClient kubernetes.Interface, dynamicClient *dynamic.DynamicClient,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/typechecking_test.go
} }) } } func buildTypeChecker(schemaToReturn *spec.Schema) *TypeChecker { restMapper := meta.NewDefaultRESTMapper([]schema.GroupVersion{ { Group: "", Version: "v1", }, }) restMapper.Add(must3(scheme.ObjectKinds(&corev1.Pod{}))[0], meta.RESTScopeRoot) restMapper.Add(must3(scheme.ObjectKinds(&appsv1.Deployment{}))[0], meta.RESTScopeRoot) return &TypeChecker{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 16.3K bytes - Viewed (0) -
cmd/kube-controller-manager/app/import_known_versions.go
limitations under the License. */ // Package app imports the API groups that the client will support // TODO: Remove this file when namespace controller and garbage collector // stops using legacyscheme.Registry.RESTMapper() package app import ( // These imports are the API groups the client will support. _ "k8s.io/kubernetes/pkg/apis/apps/install" _ "k8s.io/kubernetes/pkg/apis/authentication/install"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 10 19:23:50 UTC 2022 - 1.6K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
// mapper, but we'll deal with it for now. gc.restMapper.Reset() logger.V(4).Info("reset restmapper") // Perform the monitor resync and wait for controllers to report cache sync. // // NOTE: It's possible that newResources will diverge from the resources // discovered by restMapper during the call to Reset, since they are
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
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) -
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) -
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) -
staging/src/k8s.io/cli-runtime/pkg/resource/builder_test.go
meta.MaybeResetRESTMapper(l.RESTMapper) } func newDefaultBuilderWithMapperError(fakeClientFn FakeClientFunc, err error) *Builder { return NewFakeBuilder( fakeClientFn, func() (meta.RESTMapper, error) { return &errorRestMapper{ RESTMapper: testrestmapper.TestOnlyStaticRESTMapper(scheme.Scheme), err: err, }, nil }, func() (restmapper.CategoryExpander, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 11:58:41 UTC 2023 - 56.1K bytes - Viewed (0) -
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) -
pkg/controller/garbagecollector/operations.go
func (gc *GarbageCollector) apiResource(apiVersion, kind string) (schema.GroupVersionResource, bool, error) { fqKind := schema.FromAPIVersionAndKind(apiVersion, kind) mapping, err := gc.restMapper.RESTMapping(fqKind.GroupKind(), fqKind.Version) if err != nil { return schema.GroupVersionResource{}, false, newRESTMappingError(kind, apiVersion) } return mapping.Resource, mapping.Scope == meta.RESTScopeNamespace, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 13:37:56 UTC 2023 - 4.9K bytes - Viewed (0)