Skip to content

Commit 56ae259

Browse files
authored
Use localhost address for internal gRPC client (#1988)
Signed-off-by: Tomas Turek <[email protected]>
1 parent b56cf22 commit 56ae259

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

cmd/app/http.go

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ import (
2020
"crypto/tls"
2121
"errors"
2222
"fmt"
23+
"net"
2324
"net/http"
2425
"os"
2526
"os/signal"
@@ -63,8 +64,14 @@ func createHTTPServer(ctx context.Context, serverEndpoint string, grpcServer, le
6364
} else {
6465
opts = append(opts, grpc.WithTransportCredentials(insecure.NewCredentials()))
6566
}
66-
grpcHealthEndpoint := fmt.Sprintf("localhost:%s", viper.GetString("grpc-port"))
67-
cc, err := grpc.NewClient(grpcHealthEndpoint, opts...)
67+
68+
_, port, err := net.SplitHostPort(grpcServer.grpcServerEndpoint)
69+
if err != nil {
70+
log.Logger.Fatal(err)
71+
}
72+
73+
grpcServerEndpoint := fmt.Sprintf("localhost:%s", port)
74+
cc, err := grpc.NewClient(grpcServerEndpoint, opts...)
6875
if err != nil {
6976
log.Logger.Fatal(err)
7077
}
@@ -73,7 +80,7 @@ func createHTTPServer(ctx context.Context, serverEndpoint string, grpcServer, le
7380
runtime.WithForwardResponseOption(setResponseCodeModifier),
7481
runtime.WithHealthzEndpoint(health.NewHealthClient(cc)))
7582

76-
if err := gw.RegisterCAHandlerFromEndpoint(ctx, mux, grpcServer.grpcServerEndpoint, opts); err != nil {
83+
if err := gw.RegisterCAHandlerFromEndpoint(ctx, mux, grpcServerEndpoint, opts); err != nil {
7784
log.Logger.Fatal(err)
7885
}
7986

0 commit comments

Comments
 (0)