blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-08-21 04:29:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: msg rpc local cache

Browse Source
This commit is contained in:
withchao 2024-01-17 17:26:46 +08:00
parent c16f17582a
commit 77894b104e
2 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/rpccache/group.go
View File

@ -37,7 +37,7 @@ func (g *GroupLocalCache) getGroupMemberIDs(ctx context.Context, groupID string)
log.ZDebug(ctx, "GroupLocalCache getGroupMemberIDs req", "groupID", groupID) log.ZDebug(ctx, "GroupLocalCache getGroupMemberIDs req", "groupID", groupID)
defer func() { defer func() {
if err == nil { if err == nil {
log.ZDebug(ctx, "GroupLocalCache getGroupMemberIDs return", "value", val.List) log.ZDebug(ctx, "GroupLocalCache getGroupMemberIDs return", "value", val)
} else { } else {
log.ZError(ctx, "GroupLocalCache getGroupMemberIDs return", err) log.ZError(ctx, "GroupLocalCache getGroupMemberIDs return", err)
} }

6
pkg/rpcclient/group.go
View File

@ -18,8 +18,6 @@ import (
"context" "context"
"strings" "strings"
"google.golang.org/grpc"
"github.com/OpenIMSDK/protocol/constant" "github.com/OpenIMSDK/protocol/constant"
"github.com/OpenIMSDK/protocol/group" "github.com/OpenIMSDK/protocol/group"
"github.com/OpenIMSDK/protocol/sdkws" "github.com/OpenIMSDK/protocol/sdkws"
@ -31,9 +29,7 @@ import (
) )
type Group struct { type Group struct {
conn grpc.ClientConnInterface
Client group.GroupClient Client group.GroupClient
discov discoveryregistry.SvcDiscoveryRegistry
} }
func NewGroup(discov discoveryregistry.SvcDiscoveryRegistry) *Group { func NewGroup(discov discoveryregistry.SvcDiscoveryRegistry) *Group {
@ -42,7 +38,7 @@ func NewGroup(discov discoveryregistry.SvcDiscoveryRegistry) *Group {
panic(err) panic(err)
} }
client := group.NewGroupClient(conn) client := group.NewGroupClient(conn)
return &Group{discov: discov, conn: conn, Client: client} return &Group{Client: client}
} }
type GroupRpcClient Group type GroupRpcClient Group