- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 69 for restmapper (0.16 sec)
-
staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/resources.go
}, VersionedResources: map[string][]metav1.APIResource{ version: groupResource.APIResources, }, }, } restMapper := restmapper.NewDiscoveryRESTMapper(resources) resolver := scale.NewDiscoveryScaleKindResolver(discoveryClient) return scale.NewForConfig(config, restMapper, dynamic.LegacyAPIPathResolverFunc, resolver)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 19 02:01:40 UTC 2021 - 21.4K 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) -
staging/src/k8s.io/apimachinery/pkg/api/meta/multirestmapper.go
"k8s.io/apimachinery/pkg/runtime/schema" utilerrors "k8s.io/apimachinery/pkg/util/errors" ) var ( _ ResettableRESTMapper = MultiRESTMapper{} ) // MultiRESTMapper is a wrapper for multiple RESTMappers. type MultiRESTMapper []RESTMapper func (m MultiRESTMapper) String() string { nested := make([]string, 0, len(m)) for _, t := range m { currString := fmt.Sprintf("%v", t) splitStrings := strings.Split(currString, "\n")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 05 23:44:02 UTC 2021 - 5.8K 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) -
staging/src/k8s.io/apimachinery/pkg/api/meta/priority_test.go
"reflect" "strings" "testing" "k8s.io/apimachinery/pkg/runtime/schema" ) func TestPriorityRESTMapperResourceForErrorHandling(t *testing.T) { tcs := []struct { name string delegate RESTMapper resourcePatterns []schema.GroupVersionResource result schema.GroupVersionResource err string }{ { name: "error", delegate: fixedRESTMapper{err: errors.New("delegateError")},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 06 15:24:58 UTC 2018 - 13.6K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
"k8s.io/kubernetes/pkg/api/legacyscheme" c "k8s.io/kubernetes/pkg/controller" "k8s.io/kubernetes/test/utils/ktesting" ) type testRESTMapper struct { meta.RESTMapper } func (m *testRESTMapper) Reset() { meta.MaybeResetRESTMapper(m.RESTMapper) } func TestGarbageCollectorConstruction(t *testing.T) { config := &restclient.Config{} tweakableRM := meta.NewDefaultRESTMapper(nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0)