From 5eba5e8c9b95d8cd3c4f29549ec56d634df32467 Mon Sep 17 00:00:00 2001 From: away <1819625428@qq.com> Date: Wed, 26 May 2021 19:39:31 +0800 Subject: [PATCH] Internal user rpc service initial commit --- .../internal_service/get_user_info_to_client.go | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) create mode 100644 src/rpc/user/internal_service/get_user_info_to_client.go diff --git a/src/rpc/user/internal_service/get_user_info_to_client.go b/src/rpc/user/internal_service/get_user_info_to_client.go new file mode 100644 index 000000000..6019a77cf --- /dev/null +++ b/src/rpc/user/internal_service/get_user_info_to_client.go @@ -0,0 +1,16 @@ +package internal_service + +import ( + "Open_IM/src/common/config" + pbUser "Open_IM/src/proto/user" + "context" + "github.com/skiffer-git/grpc-etcdv3/getcdv3" + "strings" +) + +func GetUserInfoClient(req *pbUser.GetUserInfoReq) (*pbUser.GetUserInfoResp, error) { + etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImUserName) + client := pbUser.NewUserClient(etcdConn) + RpcResp, err := client.GetUserInfo(context.Background(), req) + return RpcResp, err +}