From 77894b104e8ee8e2ffe43eb68c829939130c19b7 Mon Sep 17 00:00:00 2001 From: withchao <993506633@qq.com> Date: Wed, 17 Jan 2024 17:26:46 +0800 Subject: [PATCH] feat: msg rpc local cache --- pkg/rpccache/group.go | 2 +- pkg/rpcclient/group.go | 6 +----- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/pkg/rpccache/group.go b/pkg/rpccache/group.go index 4b4720539..333177d2d 100644 --- a/pkg/rpccache/group.go +++ b/pkg/rpccache/group.go @@ -37,7 +37,7 @@ func (g *GroupLocalCache) getGroupMemberIDs(ctx context.Context, groupID string) log.ZDebug(ctx, "GroupLocalCache getGroupMemberIDs req", "groupID", groupID) defer func() { if err == nil { - log.ZDebug(ctx, "GroupLocalCache getGroupMemberIDs return", "value", val.List) + log.ZDebug(ctx, "GroupLocalCache getGroupMemberIDs return", "value", val) } else { log.ZError(ctx, "GroupLocalCache getGroupMemberIDs return", err) } diff --git a/pkg/rpcclient/group.go b/pkg/rpcclient/group.go index bf0efe60c..98c8387e5 100644 --- a/pkg/rpcclient/group.go +++ b/pkg/rpcclient/group.go @@ -18,8 +18,6 @@ import ( "context" "strings" - "google.golang.org/grpc" - "github.com/OpenIMSDK/protocol/constant" "github.com/OpenIMSDK/protocol/group" "github.com/OpenIMSDK/protocol/sdkws" @@ -31,9 +29,7 @@ import ( ) type Group struct { - conn grpc.ClientConnInterface Client group.GroupClient - discov discoveryregistry.SvcDiscoveryRegistry } func NewGroup(discov discoveryregistry.SvcDiscoveryRegistry) *Group { @@ -42,7 +38,7 @@ func NewGroup(discov discoveryregistry.SvcDiscoveryRegistry) *Group { panic(err) } client := group.NewGroupClient(conn) - return &Group{discov: discov, conn: conn, Client: client} + return &Group{Client: client} } type GroupRpcClient Group