func LookupServiceListenPort()

in pkg/k8s/service_utils.go [12:19]

• 8 lines of code
• 5 McCabe index (conditional complexity)

func LookupServiceListenPort(svc *corev1.Service, port intstr.IntOrString, protocol corev1.Protocol) (int32, error) {
	for _, svcPort := range svc.Spec.Ports {
		if svcPort.TargetPort.Type == port.Type && svcPort.TargetPort.String() == port.String() && svcPort.Protocol == protocol {
			return svcPort.Port, nil
		}
	}
	return 0, errors.Errorf("unable to find port %s on service %s", port.String(), NamespacedName(svc))
}