From f53dd855aa47b91c2ce654e6732a54b9419b02f7 Mon Sep 17 00:00:00 2001 From: withchao <993506633@qq.com> Date: Tue, 16 Jan 2024 16:42:47 +0800 Subject: [PATCH] feat: local cache --- pkg/rpccache/conversation.go | 1 + pkg/rpccache/friend.go | 1 + pkg/rpccache/group.go | 1 + 3 files changed, 3 insertions(+) diff --git a/pkg/rpccache/conversation.go b/pkg/rpccache/conversation.go index 8ca2f323f..95520f7cb 100644 --- a/pkg/rpccache/conversation.go +++ b/pkg/rpccache/conversation.go @@ -13,6 +13,7 @@ import ( func NewConversationLocalCache(client rpcclient.ConversationRpcClient, cli redis.UniversalClient) *ConversationLocalCache { lc := config.Config.LocalCache.Conversation + log.ZDebug(context.Background(), "ConversationLocalCache", "topic", lc.Topic, "slotNum", lc.SlotNum, "slotSize", lc.SlotSize, "enable", lc.Enable()) x := &ConversationLocalCache{ client: client, local: localcache.New[any]( diff --git a/pkg/rpccache/friend.go b/pkg/rpccache/friend.go index f1dec36cc..d9ee377b3 100644 --- a/pkg/rpccache/friend.go +++ b/pkg/rpccache/friend.go @@ -12,6 +12,7 @@ import ( func NewFriendLocalCache(client rpcclient.FriendRpcClient, cli redis.UniversalClient) *FriendLocalCache { lc := config.Config.LocalCache.Friend + log.ZDebug(context.Background(), "FriendLocalCache", "topic", lc.Topic, "slotNum", lc.SlotNum, "slotSize", lc.SlotSize, "enable", lc.Enable()) x := &FriendLocalCache{ client: client, local: localcache.New[any]( diff --git a/pkg/rpccache/group.go b/pkg/rpccache/group.go index 4c3e32170..c3dfd9d93 100644 --- a/pkg/rpccache/group.go +++ b/pkg/rpccache/group.go @@ -12,6 +12,7 @@ import ( func NewGroupLocalCache(client rpcclient.GroupRpcClient, cli redis.UniversalClient) *GroupLocalCache { lc := config.Config.LocalCache.Group + log.ZDebug(context.Background(), "GroupLocalCache", "topic", lc.Topic, "slotNum", lc.SlotNum, "slotSize", lc.SlotSize, "enable", lc.Enable()) x := &GroupLocalCache{ client: client, local: localcache.New[any](