blob: 823e07531260f54cef201873139c8a1a83335237 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
package ports
import (
v1 "k8s.io/api/core/v1"
)
// FilterNodePorts extracts NodePorts from ServiceList.
func FilterNodePorts(services *v1.ServiceList) (map[uint16]string, bool) {
nodeports := make(map[uint16]string)
for _, service := range services.Items {
for _, port := range service.Spec.Ports {
if port.NodePort != 0 {
nodeports[uint16(port.NodePort)] = service.ObjectMeta.Name
}
}
}
return nodeports, len(nodeports) > 0
}
|