From 160ae771454a2c55223f1013b078bc2a4f9dec6a Mon Sep 17 00:00:00 2001 From: RamiBerm <54766858+RamiBerm@users.noreply.github.com> Date: Wed, 20 Oct 2021 11:50:39 +0300 Subject: [PATCH] TRA-3811 fix service resolving (#382) Co-authored-by: Rami Berman --- agent/pkg/resolver/resolver.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/agent/pkg/resolver/resolver.go b/agent/pkg/resolver/resolver.go index b4a09ea5a..3d2ac5544 100644 --- a/agent/pkg/resolver/resolver.go +++ b/agent/pkg/resolver/resolver.go @@ -140,6 +140,13 @@ func (resolver *Resolver) watchServices(ctx context.Context) error { serviceHostname := fmt.Sprintf("%s.%s", service.Name, service.Namespace) if service.Spec.ClusterIP != "" && service.Spec.ClusterIP != kubClientNullString { resolver.saveResolvedName(service.Spec.ClusterIP, serviceHostname, event.Type) + if service.Spec.Ports != nil { + for _, port := range service.Spec.Ports { + if port.Port > 0 { + resolver.saveResolvedName(fmt.Sprintf("%s:%d", service.Spec.ClusterIP, port.Port), serviceHostname, event.Type) + } + } + } resolver.saveServiceIP(service.Spec.ClusterIP, serviceHostname, event.Type) } if service.Status.LoadBalancer.Ingress != nil {