remove versioning interface

Kubernetes-commit: e2fc5cf259463f896213afdef15d58ef9a91eb35
This commit is contained in:
David Eads 2018-04-25 10:55:17 -04:00 committed by Kubernetes Publisher
parent 3fd815dfa7
commit 7205c0679a
5 changed files with 14 additions and 27 deletions

View File

@ -39,7 +39,7 @@ type APIGroupResources struct {
// NewRESTMapper returns a PriorityRESTMapper based on the discovered // NewRESTMapper returns a PriorityRESTMapper based on the discovered
// groups and resources passed in. // groups and resources passed in.
func NewRESTMapper(groupResources []*APIGroupResources, versionInterfaces meta.VersionInterfacesFunc) meta.RESTMapper { func NewRESTMapper(groupResources []*APIGroupResources) meta.RESTMapper {
unionMapper := meta.MultiRESTMapper{} unionMapper := meta.MultiRESTMapper{}
var groupPriority []string var groupPriority []string
@ -90,7 +90,7 @@ func NewRESTMapper(groupResources []*APIGroupResources, versionInterfaces meta.V
} }
gv := schema.GroupVersion{Group: group.Group.Name, Version: discoveryVersion.Version} gv := schema.GroupVersion{Group: group.Group.Name, Version: discoveryVersion.Version}
versionMapper := meta.NewDefaultRESTMapper([]schema.GroupVersion{gv}, versionInterfaces) versionMapper := meta.NewDefaultRESTMapper([]schema.GroupVersion{gv})
for _, resource := range resources { for _, resource := range resources {
scope := meta.RESTScopeNamespace scope := meta.RESTScopeNamespace
@ -175,19 +175,17 @@ func GetAPIGroupResources(cl DiscoveryInterface) ([]*APIGroupResources, error) {
// initialization of the RESTMapper until the first mapping is // initialization of the RESTMapper until the first mapping is
// requested. // requested.
type DeferredDiscoveryRESTMapper struct { type DeferredDiscoveryRESTMapper struct {
initMu sync.Mutex initMu sync.Mutex
delegate meta.RESTMapper delegate meta.RESTMapper
cl CachedDiscoveryInterface cl CachedDiscoveryInterface
versionInterface meta.VersionInterfacesFunc
} }
// NewDeferredDiscoveryRESTMapper returns a // NewDeferredDiscoveryRESTMapper returns a
// DeferredDiscoveryRESTMapper that will lazily query the provided // DeferredDiscoveryRESTMapper that will lazily query the provided
// client for discovery information to do REST mappings. // client for discovery information to do REST mappings.
func NewDeferredDiscoveryRESTMapper(cl CachedDiscoveryInterface, versionInterface meta.VersionInterfacesFunc) *DeferredDiscoveryRESTMapper { func NewDeferredDiscoveryRESTMapper(cl CachedDiscoveryInterface) *DeferredDiscoveryRESTMapper {
return &DeferredDiscoveryRESTMapper{ return &DeferredDiscoveryRESTMapper{
cl: cl, cl: cl,
versionInterface: versionInterface,
} }
} }
@ -204,7 +202,7 @@ func (d *DeferredDiscoveryRESTMapper) getDelegate() (meta.RESTMapper, error) {
return nil, err return nil, err
} }
d.delegate = NewRESTMapper(groupResources, d.versionInterface) d.delegate = NewRESTMapper(groupResources)
return d.delegate, err return d.delegate, err
} }

View File

@ -94,7 +94,7 @@ func TestRESTMapper(t *testing.T) {
}, },
} }
restMapper := NewRESTMapper(resources, nil) restMapper := NewRESTMapper(resources)
kindTCs := []struct { kindTCs := []struct {
input schema.GroupVersionResource input schema.GroupVersionResource
@ -243,7 +243,7 @@ func TestDeferredDiscoveryRESTMapper_CacheMiss(t *testing.T) {
assert := assert.New(t) assert := assert.New(t)
cdc := fakeCachedDiscoveryInterface{fresh: false} cdc := fakeCachedDiscoveryInterface{fresh: false}
m := NewDeferredDiscoveryRESTMapper(&cdc, nil) m := NewDeferredDiscoveryRESTMapper(&cdc)
assert.False(cdc.fresh, "should NOT be fresh after instantiation") assert.False(cdc.fresh, "should NOT be fresh after instantiation")
assert.Zero(cdc.invalidateCalls, "should not have called Invalidate()") assert.Zero(cdc.invalidateCalls, "should not have called Invalidate()")

View File

@ -27,8 +27,8 @@ import (
) )
// NewDiscoveryRESTMapper returns a RESTMapper based on discovery information. // NewDiscoveryRESTMapper returns a RESTMapper based on discovery information.
func NewDiscoveryRESTMapper(resources []*metav1.APIResourceList, versionFunc meta.VersionInterfacesFunc) (*meta.DefaultRESTMapper, error) { func NewDiscoveryRESTMapper(resources []*metav1.APIResourceList) (*meta.DefaultRESTMapper, error) {
rm := meta.NewDefaultRESTMapper(nil, versionFunc) rm := meta.NewDefaultRESTMapper(nil)
for _, resourceList := range resources { for _, resourceList := range resources {
gv, err := schema.ParseGroupVersion(resourceList.GroupVersion) gv, err := schema.ParseGroupVersion(resourceList.GroupVersion)
if err != nil { if err != nil {

View File

@ -19,9 +19,7 @@ package dynamic
import ( import (
"testing" "testing"
"k8s.io/apimachinery/pkg/api/meta"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
"k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/apimachinery/pkg/runtime/schema"
) )
@ -45,7 +43,7 @@ func TestDiscoveryRESTMapper(t *testing.T) {
Kind: "test_kind", Kind: "test_kind",
} }
mapper, err := NewDiscoveryRESTMapper(resources, versionInterfaces) mapper, err := NewDiscoveryRESTMapper(resources)
if err != nil { if err != nil {
t.Fatalf("unexpected error creating mapper: %s", err) t.Fatalf("unexpected error creating mapper: %s", err)
} }
@ -79,11 +77,3 @@ func TestDiscoveryRESTMapper(t *testing.T) {
} }
} }
} }
// VersionInterfaces provides an object converter and metadata
// accessor appropriate for use with unstructured objects.
func versionInterfaces(schema.GroupVersion) (*meta.VersionInterfaces, error) {
return &meta.VersionInterfaces{
ObjectConvertor: &unstructured.UnstructuredObjectConverter{},
}, nil
}

View File

@ -40,7 +40,6 @@ import (
autoscalingv1 "k8s.io/api/autoscaling/v1" autoscalingv1 "k8s.io/api/autoscaling/v1"
corev1 "k8s.io/api/core/v1" corev1 "k8s.io/api/core/v1"
extv1beta1 "k8s.io/api/extensions/v1beta1" extv1beta1 "k8s.io/api/extensions/v1beta1"
apimeta "k8s.io/apimachinery/pkg/api/meta"
coretesting "k8s.io/client-go/testing" coretesting "k8s.io/client-go/testing"
) )
@ -101,7 +100,7 @@ func fakeScaleClient(t *testing.T) (ScalesGetter, []schema.GroupResource) {
if err != nil { if err != nil {
t.Fatalf("unexpected error while constructing resource list from fake discovery client: %v", err) t.Fatalf("unexpected error while constructing resource list from fake discovery client: %v", err)
} }
restMapper := discovery.NewRESTMapper(restMapperRes, apimeta.InterfacesForUnstructured) restMapper := discovery.NewRESTMapper(restMapperRes)
autoscalingScale := &autoscalingv1.Scale{ autoscalingScale := &autoscalingv1.Scale{
TypeMeta: metav1.TypeMeta{ TypeMeta: metav1.TypeMeta{