Internal user rpc service initial commit

This commit is contained in:
away 2021-05-26 19:39:31 +08:00
parent 2c3d0ae0e8
commit 5eba5e8c9b

View File

@ -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
}