From a48590a2df08da0a62dc114c143ac076b1a853bc Mon Sep 17 00:00:00 2001 From: dragondriver Date: Fri, 5 Feb 2021 10:29:14 +0800 Subject: [PATCH] Add query service logic to Proxy Signed-off-by: dragondriver --- internal/distributed/proxynode/service.go | 21 ++++++++++++--------- 1 file changed, 12 insertions(+), 9 deletions(-) diff --git a/internal/distributed/proxynode/service.go b/internal/distributed/proxynode/service.go index b933d3330..d69f30782 100644 --- a/internal/distributed/proxynode/service.go +++ b/internal/distributed/proxynode/service.go @@ -180,15 +180,18 @@ func (s *Server) init() error { s.impl.SetIndexServiceClient(s.indexServiceClient) log.Println("set index service client ...") - // queryServiceAddr := Params.QueryServiceAddress - // log.Println("query service address: ", queryServiceAddr) - // s.queryServiceClient = grpcqueryserviceclient.NewClient(queryServiceAddr) - // err = s.queryServiceClient.Init() - // if err != nil { - // return err - // } - // s.impl.SetQueryServiceClient(s.queryServiceClient) - // log.Println("set query service client ...") + queryServiceAddr := Params.QueryServiceAddress + log.Println("query server address: ", queryServiceAddr) + s.queryServiceClient, err = grpcqueryserviceclient.NewClient(queryServiceAddr, timeout) + if err != nil { + return err + } + err = s.queryServiceClient.Init() + if err != nil { + return err + } + s.impl.SetQueryServiceClient(s.queryServiceClient) + log.Println("set query service client ...") proxynode.Params.Init() log.Println("init params done ...") -- GitLab