From 0ae5f9a4eb82d1fac3be7313a6da026723771b1a Mon Sep 17 00:00:00 2001 From: withchao <993506633@qq.com> Date: Wed, 21 Jun 2023 11:29:04 +0800 Subject: [PATCH] rpc client --- internal/rpc/third/third.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/rpc/third/third.go b/internal/rpc/third/third.go index 7a995ce5a..33d9b0a82 100644 --- a/internal/rpc/third/third.go +++ b/internal/rpc/third/third.go @@ -38,7 +38,7 @@ func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) e } third.RegisterThirdServer(server, &thirdServer{ thirdDatabase: controller.NewThirdDatabase(cache.NewMsgCacheModel(rdb)), - userRpcClient: rpcclient.NewUserClient(client), + userRpcClient: rpcclient.NewUserRpcClient(client), s3dataBase: controller.NewS3Database(o, relation.NewObjectHash(db), relation.NewObjectInfo(db), relation.NewObjectPut(db), u), }) return nil @@ -47,7 +47,7 @@ func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) e type thirdServer struct { thirdDatabase controller.ThirdDatabase s3dataBase controller.S3Database - userRpcClient *rpcclient.UserClient + userRpcClient rpcclient.UserRpcClient } func (t *thirdServer) FcmUpdateToken(ctx context.Context, req *third.FcmUpdateTokenReq) (resp *third.FcmUpdateTokenResp, err error) {