github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-28 14:07:14 +00:00
Code Issues Projects Releases Wiki Activity

apiserver/util/proxy: Improving test coverage

Browse Source 
Signed-off-by: TommyStarK <thomasmilox@gmail.com>
This commit is contained in:
TommyStarK 2023-02-08 22:44:07 +01:00
parent 468ce59183
commit c6aa6e5007
1 changed files with 69 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

70
staging/src/k8s.io/apiserver/pkg/util/proxy/proxy_test.go
View File

@ -20,7 +20,7 @@ import (
"net/url" "net/url"
"testing" "testing"
"k8s.io/api/core/v1" v1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/util/intstr" "k8s.io/apimachinery/pkg/util/intstr"
v1listers "k8s.io/client-go/listers/core/v1" v1listers "k8s.io/client-go/listers/core/v1"
@ -118,6 +118,59 @@ func TestResolve(t *testing.T) {
clusterMode: expectation{url: "https://hit:443"}, clusterMode: expectation{url: "https://hit:443"},
endpointMode: expectation{error: true}, endpointMode: expectation{error: true},
}, },
{
name: "endpoint without subset",
services: []*v1.Service{
{
ObjectMeta: metav1.ObjectMeta{Namespace: "one", Name: "alfa"},
Spec: v1.ServiceSpec{
Type: v1.ServiceTypeClusterIP,
ClusterIP: "hit",
Ports: []v1.ServicePort{
{Name: "https", Port: 443, TargetPort: intstr.FromInt(1443)},
{Port: 1234, TargetPort: intstr.FromInt(1234)},
},
},
},
},
endpoints: func(svc *v1.Service) []*v1.Endpoints {
return []*v1.Endpoints{{
ObjectMeta: metav1.ObjectMeta{Namespace: svc.Namespace, Name: svc.Name},
Subsets: []v1.EndpointSubset{},
}}
},
clusterMode: expectation{url: "https://hit:443"},
endpointMode: expectation{error: true},
},
{
name: "endpoint subset without addresses",
services: []*v1.Service{
{
ObjectMeta: metav1.ObjectMeta{Namespace: "one", Name: "alfa"},
Spec: v1.ServiceSpec{
Type: v1.ServiceTypeClusterIP,
ClusterIP: "hit",
Ports: []v1.ServicePort{
{Name: "https", Port: 443, TargetPort: intstr.FromInt(1443)},
{Port: 1234, TargetPort: intstr.FromInt(1234)},
},
},
},
},
endpoints: func(svc *v1.Service) []*v1.Endpoints {
return []*v1.Endpoints{{
ObjectMeta: metav1.ObjectMeta{Namespace: svc.Namespace, Name: svc.Name},
Subsets: []v1.EndpointSubset{{
Addresses: []v1.EndpointAddress{},
Ports: []v1.EndpointPort{{Name: "https", Port: 443}},
}},
}}
},
clusterMode: expectation{url: "https://hit:443"},
endpointMode: expectation{error: true},
},
{ {
name: "none cluster ip", name: "none cluster ip",
services: []*v1.Service{ services: []*v1.Service{
@ -190,6 +243,21 @@ func TestResolve(t *testing.T) {
clusterMode: expectation{url: "https://foo.bar.com:443"}, clusterMode: expectation{url: "https://foo.bar.com:443"},
endpointMode: expectation{error: true}, endpointMode: expectation{error: true},
}, },
{
name: "unsupported service",
services: []*v1.Service{
{
ObjectMeta: metav1.ObjectMeta{Namespace: "one", Name: "alfa"},
Spec: v1.ServiceSpec{
Type: "unsupported",
},
},
},
endpoints: nil,
clusterMode: expectation{error: true},
endpointMode: expectation{error: true},
},
{ {
name: "missing service", name: "missing service",
services: nil, services: nil,