mirror of
https://github.com/optim-enterprises-bv/kubernetes.git
synced 2025-12-27 18:25:02 +00:00
969ecabc0f
kube-proxy does not look at Endpoints ever, so it is incorrect for a test to assume that there is any correlation between whether Endpoints exist and whether a Service is working. Tests should only be using the v1.Endpoints API if they are explicitly testing the behavior of v1.Endpoints, the Endpoints controller, or the EndpointSlice mirroring controller. There is no reason for any non SIG Network tests to be testing any of those things, so there should be no references to v1.Endpoints in test/e2e outside of test/e2e/network. Also, simplify some pointlessly complicated e2eservice code.
60 lines
1.7 KiB
Go
60 lines
1.7 KiB
Go
/*
|
|
Copyright 2019 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 network
|
|
|
|
import (
|
|
v1 "k8s.io/api/core/v1"
|
|
)
|
|
|
|
// getContainerPortsByPodUID returns a portsByPodUID map on the given endpoints.
|
|
func getContainerPortsByPodUID(ep *v1.Endpoints) portsByPodUID {
|
|
m := portsByPodUID{}
|
|
for _, ss := range ep.Subsets {
|
|
for _, port := range ss.Ports {
|
|
for _, addr := range ss.Addresses {
|
|
containerPort := port.Port
|
|
if _, ok := m[addr.TargetRef.UID]; !ok {
|
|
m[addr.TargetRef.UID] = make([]int, 0)
|
|
}
|
|
m[addr.TargetRef.UID] = append(m[addr.TargetRef.UID], int(containerPort))
|
|
}
|
|
}
|
|
}
|
|
return m
|
|
}
|
|
|
|
// getFullContainerPortsByPodUID returns a fullPortsByPodUID map on the given endpoints with all the port data.
|
|
func getFullContainerPortsByPodUID(ep *v1.Endpoints) fullPortsByPodUID {
|
|
m := fullPortsByPodUID{}
|
|
for _, ss := range ep.Subsets {
|
|
for _, port := range ss.Ports {
|
|
containerPort := v1.ContainerPort{
|
|
Name: port.Name,
|
|
ContainerPort: port.Port,
|
|
Protocol: port.Protocol,
|
|
}
|
|
for _, addr := range ss.Addresses {
|
|
if _, ok := m[addr.TargetRef.UID]; !ok {
|
|
m[addr.TargetRef.UID] = make([]v1.ContainerPort, 0)
|
|
}
|
|
m[addr.TargetRef.UID] = append(m[addr.TargetRef.UID], containerPort)
|
|
}
|
|
}
|
|
}
|
|
return m
|
|
}
|