From dbe6022fa527d15a8ce61dedfc01b0d77c3908aa Mon Sep 17 00:00:00 2001 From: CooooolFrog <329851721@qq.com> Date: Thu, 27 Oct 2022 14:55:38 +0800 Subject: [PATCH] fix: fix input address format mistake (#89) --- server/service/util.go | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/server/service/util.go b/server/service/util.go index c27d486f..f489307f 100644 --- a/server/service/util.go +++ b/server/service/util.go @@ -4,6 +4,8 @@ package service import ( "context" + "net/url" + "strings" "github.com/CeresDB/ceresmeta/pkg/coderr" "google.golang.org/grpc" @@ -19,7 +21,16 @@ var ( func GetClientConn(ctx context.Context, addr string) (*grpc.ClientConn, error) { opt := grpc.WithTransportCredentials(insecure.NewCredentials()) - cc, err := grpc.DialContext(ctx, addr, opt) + host := addr + if strings.HasPrefix(addr, "http") { + u, err := url.Parse(addr) + if err != nil { + return nil, ErrParseURL.WithCause(err) + } + host = u.Host + } + + cc, err := grpc.DialContext(ctx, host, opt) if err != nil { return nil, ErrGRPCDial.WithCause(err) }