feat: local cache

pkg/rpccache/common.go

@@ -0,0 +1,20 @@
+package rpccache
+
+func newListMap[V comparable](values []V, err error) (*listMap[V], error) {
+	if err != nil {
+		return nil, err
+	}
+	lm := &listMap[V]{
+		List: values,
+		Map:  make(map[V]struct{}, len(values)),
+	}
+	for _, value := range values {
+		lm.Map[value] = struct{}{}
+	}
+	return lm, nil
+}
+
+type listMap[V comparable] struct {
+	List []V
+	Map  map[V]struct{}
+}

pkg/rpccache/conversation.go

@@ -19,7 +19,9 @@ func NewConversationLocalCache(client rpcclient.ConversationRpcClient, cli redis
 			localcache.WithLocalSlotSize(lc.SlotSize),
 		),
 	}
+	if lc.Enable() {
 		go subscriberRedisDeleteCache(context.Background(), cli, lc.Topic, x.local.DelLocal)
+	}
 	return x
 }
 

pkg/rpccache/friend.go

@@ -19,7 +19,9 @@ func NewFriendLocalCache(client rpcclient.FriendRpcClient, cli redis.UniversalCl
 			localcache.WithLocalSlotSize(lc.SlotSize),
 		),
 	}
+	if lc.Enable() {
 		go subscriberRedisDeleteCache(context.Background(), cli, lc.Topic, x.local.DelLocal)
+	}
 	return x
 }
 

pkg/rpccache/group.go

@@ -19,7 +19,9 @@ func NewGroupLocalCache(client rpcclient.GroupRpcClient, cli redis.UniversalClie
 			localcache.WithLocalSlotSize(lc.SlotSize),
 		),
 	}
+	if lc.Enable() {
 		go subscriberRedisDeleteCache(context.Background(), cli, lc.Topic, x.local.DelLocal)
+	}
 	return x
 }
 
@@ -28,25 +30,6 @@ type GroupLocalCache struct {
 	local  localcache.Cache[any]
 }
 
-type listMap[V comparable] struct {
-	List []V
-	Map  map[V]struct{}
-}
-
-func newListMap[V comparable](values []V, err error) (*listMap[V], error) {
-	if err != nil {
-		return nil, err
-	}
-	lm := &listMap[V]{
-		List: values,
-		Map:  make(map[V]struct{}, len(values)),
-	}
-	for _, value := range values {
-		lm.Map[value] = struct{}{}
-	}
-	return lm, nil
-}
-
 func (g *GroupLocalCache) getGroupMemberIDs(ctx context.Context, groupID string) (val *listMap[string], err error) {
 	log.ZDebug(ctx, "GroupLocalCache getGroupMemberIDs req", "groupID", groupID)
 	defer func() {