From aa8c66ec01228eda6130536dff139f6994e4928d Mon Sep 17 00:00:00 2001 From: Manuel de Brito Fontes Date: Wed, 14 Jun 2017 19:42:13 -0400 Subject: [PATCH] Remove dead code --- core/pkg/ingress/controller/named_port.go | 47 ---------- .../pkg/ingress/controller/named_port_test.go | 93 ------------------- 2 files changed, 140 deletions(-) delete mode 100644 core/pkg/ingress/controller/named_port.go delete mode 100644 core/pkg/ingress/controller/named_port_test.go diff --git a/core/pkg/ingress/controller/named_port.go b/core/pkg/ingress/controller/named_port.go deleted file mode 100644 index 99e43c826..000000000 --- a/core/pkg/ingress/controller/named_port.go +++ /dev/null @@ -1,47 +0,0 @@ -/* -Copyright 2015 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package controller - -import ( - "fmt" - - "k8s.io/apimachinery/pkg/util/intstr" - api_v1 "k8s.io/client-go/pkg/api/v1" -) - -// FindPort locates the container port for the given pod and portName. If the -// targetPort is a number, use that. If the targetPort is a string, look that -// string up in all named ports in all containers in the target pod. If no -// match is found, fail. -func findPort(pod *api_v1.Pod, svcPort *api_v1.ServicePort) (int, error) { - portName := svcPort.TargetPort - switch portName.Type { - case intstr.String: - name := portName.StrVal - for _, container := range pod.Spec.Containers { - for _, port := range container.Ports { - if port.Name == name && port.Protocol == svcPort.Protocol { - return int(port.ContainerPort), nil - } - } - } - case intstr.Int: - return portName.IntValue(), nil - } - - return 0, fmt.Errorf("no suitable port for manifest: %s", pod.UID) -} diff --git a/core/pkg/ingress/controller/named_port_test.go b/core/pkg/ingress/controller/named_port_test.go deleted file mode 100644 index 09637cb25..000000000 --- a/core/pkg/ingress/controller/named_port_test.go +++ /dev/null @@ -1,93 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package controller - -import ( - meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - "k8s.io/client-go/kubernetes/fake" - "k8s.io/client-go/pkg/api" - api_v1 "k8s.io/client-go/pkg/api/v1" -) - -func buildSimpleClientSet() *fake.Clientset { - return fake.NewSimpleClientset( - &api_v1.PodList{ - Items: []api_v1.Pod{ - { - ObjectMeta: meta_v1.ObjectMeta{ - Name: "foo1", - Namespace: api.NamespaceDefault, - Labels: map[string]string{ - "lable_sig": "foo_pod", - }, - }, - Spec: api_v1.PodSpec{ - NodeName: "foo_node_1", - Containers: []api_v1.Container{ - { - Ports: []api_v1.ContainerPort{ - { - Name: "foo1_named_port_c1", - Protocol: api_v1.ProtocolTCP, - ContainerPort: 80, - }, - }, - }, - }, - }, - }, - { - ObjectMeta: meta_v1.ObjectMeta{ - Name: "foo1", - Namespace: api.NamespaceSystem, - Labels: map[string]string{ - "lable_sig": "foo_pod", - }, - }, - }, - }, - }, - &api_v1.ServiceList{Items: []api_v1.Service{ - { - ObjectMeta: meta_v1.ObjectMeta{ - Namespace: api.NamespaceDefault, - Name: "named_port_test_service", - }, - }, - }}, - ) -} - -func buildGenericController() *GenericController { - return &GenericController{ - cfg: &Configuration{ - Client: buildSimpleClientSet(), - }, - } -} - -func buildService() *api_v1.Service { - return &api_v1.Service{ - ObjectMeta: meta_v1.ObjectMeta{ - Namespace: api.NamespaceSystem, - Name: "named_port_test_service", - }, - Spec: api_v1.ServiceSpec{ - ClusterIP: "10.10.10.10", - }, - } -}