cache

Apr 20, 2024

Changes in this version

+ func InitLocalCache(localCache *config.LocalCache)

+ type MsgCache interface

+ CleanUpOneConversationAllMsg func(ctx context.Context, conversationID string) error

+ DelMsgFromCache func(ctx context.Context, userID string, seqList []int64) error

+ DelUserDeleteMsgsList func(ctx context.Context, conversationID string, seqs []int64)

+ DeleteMessages func(ctx context.Context, conversationID string, seqs []int64) error

+ DeleteOneMessageKey func(ctx context.Context, clientMsgID string, sessionType int32, subKey string) error

+ GetMessageTypeKeyValue func(ctx context.Context, clientMsgID string, sessionType int32, typeKey string) (string, error)

+ GetMessagesBySeq func(ctx context.Context, conversationID string, seqs []int64) (seqMsg []*sdkws.MsgData, failedSeqList []int64, err error)

+ GetOneMessageAllReactionList func(ctx context.Context, clientMsgID string, sessionType int32) (map[string]string, error)

+ GetSendMsgStatus func(ctx context.Context, id string) (int32, error)

+ GetUserDelList func(ctx context.Context, userID, conversationID string) (seqs []int64, err error)

+ JudgeMessageReactionExist func(ctx context.Context, clientMsgID string, sessionType int32) (bool, error)

+ LockMessageTypeKey func(ctx context.Context, clientMsgID string, TypeKey string) error

+ SetMessageReactionExpire func(ctx context.Context, clientMsgID string, sessionType int32, ...) (bool, error)

+ SetMessageToCache func(ctx context.Context, conversationID string, msgs []*sdkws.MsgData) (int, error)

+ SetMessageTypeKeyValue func(ctx context.Context, clientMsgID string, sessionType int32, ...) error

+ SetSendMsgStatus func(ctx context.Context, id string, status int32) error

+ UnLockMessageTypeKey func(ctx context.Context, clientMsgID string, TypeKey string) error

+ UserDeleteMsgs func(ctx context.Context, conversationID string, seqs []int64, userID string) error

+ func NewMsgCache(client redis.UniversalClient, redisEnablePipeline bool) MsgCache

type SeqCache

+ func NewSeqCache(rdb redis.UniversalClient) SeqCache

+ type ThirdCache interface

+ DelFcmToken func(ctx context.Context, account string, platformID int) error

+ GetFcmToken func(ctx context.Context, account string, platformID int) (string, error)

+ GetGetuiTaskID func(ctx context.Context) (string, error)

+ GetGetuiToken func(ctx context.Context) (string, error)

+ GetUserBadgeUnreadCountSum func(ctx context.Context, userID string) (int, error)

+ IncrUserBadgeUnreadCountSum func(ctx context.Context, userID string) (int, error)

+ SetFcmToken func(ctx context.Context, account string, platformID int, fcmToken string, ...) (err error)

+ SetGetuiTaskID func(ctx context.Context, taskID string, expireTime int64) error

+ SetGetuiToken func(ctx context.Context, token string, expireTime int64) error

+ SetUserBadgeUnreadCountSum func(ctx context.Context, userID string, value int) error

+ func NewThirdCache(rdb redis.UniversalClient) ThirdCache

+ type TokenModel interface

+ AddTokenFlag func(ctx context.Context, userID string, platformID int, token string, flag int) error

+ DeleteTokenByUidPid func(ctx context.Context, userID string, platformID int, fields []string) error

+ GetTokensWithoutError func(ctx context.Context, userID string, platformID int) (map[string]int, error)

+ SetTokenMapByUidPid func(ctx context.Context, userID string, platformID int, m map[string]int) error

+ func NewTokenCacheModel(rdb redis.UniversalClient) TokenModel

Mar 7, 2024

Changes in this version

type FriendCache

+ DelFriends func(ownerUserID string, friendUserIDs []string) FriendCache

type FriendCacheRedis

+ func (f *FriendCacheRedis) DelFriends(ownerUserID string, friendUserIDs []string) FriendCache

Dec 14, 2023

Changes in this version

type GroupCache

+ DelGroupAllRoleLevel func(groupID string) GroupCache

+ DelGroupRoleLevel func(groupID string, roleLevel []int32) GroupCache

+ FindGroupMemberUser func(ctx context.Context, groupIDs []string, userID string) ([]*relationtb.GroupMemberModel, error)

+ GetGroupOwner func(ctx context.Context, groupID string) (*relationtb.GroupMemberModel, error)

+ GetGroupRoleLevelMemberIDs func(ctx context.Context, groupID string, roleLevel int32) ([]string, error)

+ GetGroupRoleLevelMemberInfo func(ctx context.Context, groupID string, roleLevel int32) ([]*relationtb.GroupMemberModel, error)

+ GetGroupRolesLevelMemberInfo func(ctx context.Context, groupID string, roleLevels []int32) ([]*relationtb.GroupMemberModel, error)

+ GetGroupsOwner func(ctx context.Context, groupIDs []string) ([]*relationtb.GroupMemberModel, error)

type GroupCacheRedis

+ func (g *GroupCacheRedis) DelGroupAllRoleLevel(groupID string) GroupCache

+ func (g *GroupCacheRedis) DelGroupRoleLevel(groupID string, roleLevels []int32) GroupCache

+ func (g *GroupCacheRedis) DelGroupsOwner(groupIDs ...string) GroupCache

+ func (g *GroupCacheRedis) FindGroupMemberUser(ctx context.Context, groupIDs []string, userID string) (_ []*relationtb.GroupMemberModel, err error)

+ func (g *GroupCacheRedis) GetGroupOwner(ctx context.Context, groupID string) (*relationtb.GroupMemberModel, error)

+ func (g *GroupCacheRedis) GetGroupRoleLevelMemberIDs(ctx context.Context, groupID string, roleLevel int32) ([]string, error)

+ func (g *GroupCacheRedis) GetGroupRoleLevelMemberInfo(ctx context.Context, groupID string, roleLevel int32) ([]*relationtb.GroupMemberModel, error)

+ func (g *GroupCacheRedis) GetGroupRolesLevelMemberInfo(ctx context.Context, groupID string, roleLevels []int32) ([]*relationtb.GroupMemberModel, error)

+ func (g *GroupCacheRedis) GetGroupsOwner(ctx context.Context, groupIDs []string) ([]*relationtb.GroupMemberModel, error)

+ type GroupHash interface

+ GetGroupHash func(ctx context.Context, groupID string) (uint64, error)

Nov 10, 2023

Changes in this version

+ const FCM_TOKEN

+ func RemoveRepeatedElementsInList[T Comparable](slc []T) []T

+ type Comparable interface

+ type MinioCache interface

+ DelImageThumbnailKey func(key string, format string, width int, height int) MinioCache

+ DelObjectImageInfoKey func(keys ...string) MinioCache

+ GetImageObjectKeyInfo func(ctx context.Context, key string, ...) (*MinioImageInfo, error)

+ GetThumbnailKey func(ctx context.Context, key string, format string, width int, height int, ...) (string, error)

+ func NewMinioCache(rdb redis.UniversalClient) MinioCache

+ type MinioImageInfo struct

+ Etag string

+ Format string

+ Height int

+ IsImg bool

+ Width int

+ type ObjectCache interface

+ DelObjectName func(names ...string) ObjectCache

+ GetName func(ctx context.Context, name string) (*relationtb.ObjectModel, error)

+ func NewObjectCacheRedis(rdb redis.UniversalClient, objDB relationtb.ObjectInfoModelInterface) ObjectCache

+ type S3Cache interface

+ DelS3Key func(engine string, keys ...string) S3Cache

+ GetKey func(ctx context.Context, engine string, key string) (*s3.ObjectInfo, error)

+ func NewS3Cache(rdb redis.UniversalClient, s3 s3.Interface) S3Cache

Sep 20, 2023

Changes in this version

type ConversationCache

+ DelConversationNotReceiveMessageUserIDs func(conversationIDs ...string) ConversationCache

+ GetConversationNotReceiveMessageUserIDs func(ctx context.Context, conversationID string) ([]string, error)

type ConversationRedisCache

+ func (c *ConversationRedisCache) DelConversationNotReceiveMessageUserIDs(conversationIDs ...string) ConversationCache

+ func (c *ConversationRedisCache) GetConversationNotReceiveMessageUserIDs(ctx context.Context, conversationID string) ([]string, error)

Sep 8, 2023

Changes in this version

+ const SuperGroupMemberIDsKey

+ const TwoWayFriendsIDsKey

+ func GetDefaultOpt() rockscache.Options

+ func NewMetaCacheRedis(rcClient *rockscache.Client, keys ...string) metaCache

+ func NewRedis() (redis.UniversalClient, error)

+ type BlackCache interface

+ DelBlackIDs func(ctx context.Context, userID string) BlackCache

+ GetBlackIDs func(ctx context.Context, userID string) (blackIDs []string, err error)

+ NewCache func() BlackCache

+ func NewBlackCacheRedis(rdb redis.UniversalClient, blackDB relationtb.BlackModelInterface, ...) BlackCache

+ type BlackCacheRedis struct

+ func (b *BlackCacheRedis) DelBlackIDs(ctx context.Context, userID string) BlackCache

+ func (b *BlackCacheRedis) GetBlackIDs(ctx context.Context, userID string) (blackIDs []string, err error)

+ func (b *BlackCacheRedis) NewCache() BlackCache

+ type ConversationCache interface

+ DelConversationByConversationID func(conversationIDs ...string) ConversationCache

+ DelConversationIDs func(userIDs ...string) ConversationCache

+ DelConversations func(ownerUserID string, conversationIDs ...string) ConversationCache

+ DelSuperGroupRecvMsgNotNotifyUserIDs func(groupID string) ConversationCache

+ DelSuperGroupRecvMsgNotNotifyUserIDsHash func(groupID string) ConversationCache

+ DelUserAllHasReadSeqs func(ownerUserID string, conversationIDs ...string) ConversationCache

+ DelUserConversationIDsHash func(ownerUserIDs ...string) ConversationCache

+ DelUserRecvMsgOpt func(ownerUserID, conversationID string) ConversationCache

+ DelUsersConversation func(conversationID string, ownerUserIDs ...string) ConversationCache

+ GetConversation func(ctx context.Context, ownerUserID, conversationID string) (*relationtb.ConversationModel, error)

+ GetConversations func(ctx context.Context, ownerUserID string, conversationIDs []string) ([]*relationtb.ConversationModel, error)

+ GetConversationsByConversationID func(ctx context.Context, conversationIDs []string) ([]*relationtb.ConversationModel, error)

+ GetSuperGroupRecvMsgNotNotifyUserIDs func(ctx context.Context, groupID string) (userIDs []string, err error)

+ GetSuperGroupRecvMsgNotNotifyUserIDsHash func(ctx context.Context, groupID string) (hash uint64, err error)

+ GetUserAllConversations func(ctx context.Context, ownerUserID string) ([]*relationtb.ConversationModel, error)

+ GetUserAllHasReadSeqs func(ctx context.Context, ownerUserID string) (map[string]int64, error)

+ GetUserConversationIDs func(ctx context.Context, ownerUserID string) ([]string, error)

+ GetUserConversationIDsHash func(ctx context.Context, ownerUserID string) (hash uint64, err error)

+ GetUserRecvMsgOpt func(ctx context.Context, ownerUserID, conversationID string) (opt int, err error)

+ NewCache func() ConversationCache

+ func NewConversationRedis(rdb redis.UniversalClient, opts rockscache.Options, ...) ConversationCache

+ func NewNewConversationRedis(rdb redis.UniversalClient, conversationDB *relation.ConversationGorm, ...) ConversationCache

+ type ConversationRedisCache struct

+ func (c *ConversationRedisCache) DelConversationByConversationID(conversationIDs ...string) ConversationCache

+ func (c *ConversationRedisCache) DelConversationIDs(userIDs ...string) ConversationCache

+ func (c *ConversationRedisCache) DelConversations(ownerUserID string, conversationIDs ...string) ConversationCache

+ func (c *ConversationRedisCache) DelSuperGroupRecvMsgNotNotifyUserIDs(groupID string) ConversationCache

+ func (c *ConversationRedisCache) DelSuperGroupRecvMsgNotNotifyUserIDsHash(groupID string) ConversationCache

+ func (c *ConversationRedisCache) DelUserAllHasReadSeqs(ownerUserID string, conversationIDs ...string) ConversationCache

+ func (c *ConversationRedisCache) DelUserConversationIDsHash(ownerUserIDs ...string) ConversationCache

+ func (c *ConversationRedisCache) DelUserRecvMsgOpt(ownerUserID, conversationID string) ConversationCache

+ func (c *ConversationRedisCache) DelUsersConversation(conversationID string, ownerUserIDs ...string) ConversationCache

+ func (c *ConversationRedisCache) GetConversation(ctx context.Context, ownerUserID, conversationID string) (*relationtb.ConversationModel, error)

+ func (c *ConversationRedisCache) GetConversations(ctx context.Context, ownerUserID string, conversationIDs []string) ([]*relationtb.ConversationModel, error)

+ func (c *ConversationRedisCache) GetConversationsByConversationID(ctx context.Context, conversationIDs []string) ([]*relationtb.ConversationModel, error)

+ func (c *ConversationRedisCache) GetSuperGroupRecvMsgNotNotifyUserIDs(ctx context.Context, groupID string) (userIDs []string, err error)

+ func (c *ConversationRedisCache) GetSuperGroupRecvMsgNotNotifyUserIDsHash(ctx context.Context, groupID string) (hash uint64, err error)

+ func (c *ConversationRedisCache) GetUserAllConversations(ctx context.Context, ownerUserID string) ([]*relationtb.ConversationModel, error)

+ func (c *ConversationRedisCache) GetUserAllHasReadSeqs(ctx context.Context, ownerUserID string) (map[string]int64, error)

+ func (c *ConversationRedisCache) GetUserConversationIDs(ctx context.Context, ownerUserID string) ([]string, error)

+ func (c *ConversationRedisCache) GetUserConversationIDsHash(ctx context.Context, ownerUserID string) (hash uint64, err error)

+ func (c *ConversationRedisCache) GetUserRecvMsgOpt(ctx context.Context, ownerUserID, conversationID string) (opt int, err error)

+ func (c *ConversationRedisCache) NewCache() ConversationCache

+ type FriendCache interface

+ DelFriend func(ownerUserID, friendUserID string) FriendCache

+ DelFriendIDs func(ownerUserID ...string) FriendCache

+ GetFriend func(ctx context.Context, ownerUserID, friendUserID string) (friend *relationtb.FriendModel, err error)

+ GetFriendIDs func(ctx context.Context, ownerUserID string) (friendIDs []string, err error)

+ NewCache func() FriendCache

+ func NewFriendCacheRedis(rdb redis.UniversalClient, friendDB relationtb.FriendModelInterface, ...) FriendCache

+ type FriendCacheRedis struct

+ func (c *FriendCacheRedis) NewCache() FriendCache

+ func (f *FriendCacheRedis) DelFriend(ownerUserID, friendUserID string) FriendCache

+ func (f *FriendCacheRedis) DelFriendIDs(ownerUserID ...string) FriendCache

+ func (f *FriendCacheRedis) DelTwoWayFriendIDs(ctx context.Context, ownerUserID string) FriendCache

+ func (f *FriendCacheRedis) GetFriend(ctx context.Context, ownerUserID, friendUserID string) (friend *relationtb.FriendModel, err error)

+ func (f *FriendCacheRedis) GetFriendIDs(ctx context.Context, ownerUserID string) (friendIDs []string, err error)

+ func (f *FriendCacheRedis) GetTwoWayFriendIDs(ctx context.Context, ownerUserID string) (twoWayFriendIDs []string, err error)

+ type GroupCache interface

+ DelGroupMemberIDs func(groupID string) GroupCache

+ DelGroupMembersHash func(groupID string) GroupCache

+ DelGroupMembersInfo func(groupID string, userID ...string) GroupCache

+ DelGroupsInfo func(groupIDs ...string) GroupCache

+ DelGroupsMemberNum func(groupID ...string) GroupCache

+ DelJoinedGroupID func(userID ...string) GroupCache

+ DelJoinedSuperGroupIDs func(userIDs ...string) GroupCache

+ DelSuperGroupMemberIDs func(groupIDs ...string) GroupCache

+ GetAllGroupMembersInfo func(ctx context.Context, groupID string) (groupMembers []*relationtb.GroupMemberModel, err error)

+ GetGroupInfo func(ctx context.Context, groupID string) (group *relationtb.GroupModel, err error)

+ GetGroupMemberHashMap func(ctx context.Context, groupIDs []string) (map[string]*relationtb.GroupSimpleUserID, error)

+ GetGroupMemberIDs func(ctx context.Context, groupID string) (groupMemberIDs []string, err error)

+ GetGroupMemberInfo func(ctx context.Context, groupID, userID string) (groupMember *relationtb.GroupMemberModel, err error)

+ GetGroupMemberNum func(ctx context.Context, groupID string) (memberNum int64, err error)

+ GetGroupMembersHash func(ctx context.Context, groupID string) (hashCode uint64, err error)

+ GetGroupMembersInfo func(ctx context.Context, groupID string, userID []string) (groupMembers []*relationtb.GroupMemberModel, err error)

+ GetGroupMembersPage func(ctx context.Context, groupID string, userID []string, ...) (total uint32, groupMembers []*relationtb.GroupMemberModel, err error)

+ GetGroupsInfo func(ctx context.Context, groupIDs []string) (groups []*relationtb.GroupModel, err error)

+ GetGroupsMemberIDs func(ctx context.Context, groupIDs []string) (groupMemberIDs map[string][]string, err error)

+ GetJoinedGroupIDs func(ctx context.Context, userID string) (joinedGroupIDs []string, err error)

+ GetJoinedSuperGroupIDs func(ctx context.Context, userID string) (joinedSuperGroupIDs []string, err error)

+ GetSuperGroupMemberIDs func(ctx context.Context, groupIDs ...string) (models []*unrelationtb.SuperGroupModel, err error)

+ NewCache func() GroupCache

+ func NewGroupCacheRedis(rdb redis.UniversalClient, groupDB relationtb.GroupModelInterface, ...) GroupCache

+ type GroupCacheRedis struct

+ func (g *GroupCacheRedis) DelGroupMemberIDs(groupID string) GroupCache

+ func (g *GroupCacheRedis) DelGroupMembersHash(groupID string) GroupCache

+ func (g *GroupCacheRedis) DelGroupMembersInfo(groupID string, userIDs ...string) GroupCache

+ func (g *GroupCacheRedis) DelGroupsInfo(groupIDs ...string) GroupCache

+ func (g *GroupCacheRedis) DelGroupsMemberNum(groupID ...string) GroupCache

+ func (g *GroupCacheRedis) DelJoinedGroupID(userIDs ...string) GroupCache

+ func (g *GroupCacheRedis) DelJoinedSuperGroupIDs(userIDs ...string) GroupCache

+ func (g *GroupCacheRedis) DelSuperGroupMemberIDs(groupIDs ...string) GroupCache

+ func (g *GroupCacheRedis) GetAllGroupMemberInfo(ctx context.Context, groupID string) ([]*relationtb.GroupMemberModel, error)

+ func (g *GroupCacheRedis) GetAllGroupMembersInfo(ctx context.Context, groupID string) (groupMembers []*relationtb.GroupMemberModel, err error)

+ func (g *GroupCacheRedis) GetGroupIndex(group *relationtb.GroupModel, keys []string) (int, error)

+ func (g *GroupCacheRedis) GetGroupInfo(ctx context.Context, groupID string) (group *relationtb.GroupModel, err error)

+ func (g *GroupCacheRedis) GetGroupMemberHashMap(ctx context.Context, groupIDs []string) (map[string]*relationtb.GroupSimpleUserID, error)

+ func (g *GroupCacheRedis) GetGroupMemberIDs(ctx context.Context, groupID string) (groupMemberIDs []string, err error)

+ func (g *GroupCacheRedis) GetGroupMemberIndex(groupMember *relationtb.GroupMemberModel, keys []string) (int, error)

+ func (g *GroupCacheRedis) GetGroupMemberInfo(ctx context.Context, groupID, userID string) (groupMember *relationtb.GroupMemberModel, err error)

+ func (g *GroupCacheRedis) GetGroupMemberNum(ctx context.Context, groupID string) (memberNum int64, err error)

+ func (g *GroupCacheRedis) GetGroupMembersHash(ctx context.Context, groupID string) (hashCode uint64, err error)

+ func (g *GroupCacheRedis) GetGroupMembersInfo(ctx context.Context, groupID string, userIDs []string) ([]*relationtb.GroupMemberModel, error)

+ func (g *GroupCacheRedis) GetGroupMembersPage(ctx context.Context, groupID string, userIDs []string, ...) (total uint32, groupMembers []*relationtb.GroupMemberModel, err error)

+ func (g *GroupCacheRedis) GetGroupsInfo(ctx context.Context, groupIDs []string) (groups []*relationtb.GroupModel, err error)

+ func (g *GroupCacheRedis) GetGroupsMemberIDs(ctx context.Context, groupIDs []string) (map[string][]string, error)

+ func (g *GroupCacheRedis) GetJoinedGroupIDs(ctx context.Context, userID string) (joinedGroupIDs []string, err error)

+ func (g *GroupCacheRedis) GetJoinedSuperGroupIDs(ctx context.Context, userID string) (joinedSuperGroupIDs []string, err error)

+ func (g *GroupCacheRedis) GetSuperGroupMemberIDs(ctx context.Context, groupIDs ...string) (models []*unrelationtb.SuperGroupModel, err error)

+ func (g *GroupCacheRedis) NewCache() GroupCache

+ type MsgModel interface

+ AddTokenFlag func(ctx context.Context, userID string, platformID int, token string, flag int) error

+ CleanUpOneConversationAllMsg func(ctx context.Context, conversationID string) error

+ DelMsgFromCache func(ctx context.Context, userID string, seqList []int64) error

+ DelUserDeleteMsgsList func(ctx context.Context, conversationID string, seqs []int64)

+ DeleteMessages func(ctx context.Context, conversationID string, seqs []int64) error

+ DeleteOneMessageKey func(ctx context.Context, clientMsgID string, sessionType int32, subKey string) error

+ DeleteTokenByUidPid func(ctx context.Context, userID string, platformID int, fields []string) error

+ GetMessageTypeKeyValue func(ctx context.Context, clientMsgID string, sessionType int32, typeKey string) (string, error)

+ GetMessagesBySeq func(ctx context.Context, conversationID string, seqs []int64) (seqMsg []*sdkws.MsgData, failedSeqList []int64, err error)

+ GetOneMessageAllReactionList func(ctx context.Context, clientMsgID string, sessionType int32) (map[string]string, error)

+ GetSendMsgStatus func(ctx context.Context, id string) (int32, error)

+ GetTokensWithoutError func(ctx context.Context, userID string, platformID int) (map[string]int, error)

+ GetUserDelList func(ctx context.Context, userID, conversationID string) (seqs []int64, err error)

+ JudgeMessageReactionExist func(ctx context.Context, clientMsgID string, sessionType int32) (bool, error)

+ LockMessageTypeKey func(ctx context.Context, clientMsgID string, TypeKey string) error

+ SetMessageReactionExpire func(ctx context.Context, clientMsgID string, sessionType int32, ...) (bool, error)

+ SetMessageToCache func(ctx context.Context, conversationID string, msgs []*sdkws.MsgData) (int, error)

+ SetMessageTypeKeyValue func(ctx context.Context, clientMsgID string, sessionType int32, ...) error

+ SetSendMsgStatus func(ctx context.Context, id string, status int32) error

+ SetTokenMapByUidPid func(ctx context.Context, userID string, platformID int, m map[string]int) error

+ UnLockMessageTypeKey func(ctx context.Context, clientMsgID string, TypeKey string) error

+ UserDeleteMsgs func(ctx context.Context, conversationID string, seqs []int64, userID string) error

+ func NewMsgCacheModel(client redis.UniversalClient) MsgModel

+ type SeqCache interface

+ GetConversationUserMinSeq func(ctx context.Context, conversationID string, userID string) (int64, error)

+ GetConversationUserMinSeqs func(ctx context.Context, conversationID string, userIDs []string) (map[string]int64, error)

+ GetHasReadSeq func(ctx context.Context, userID string, conversationID string) (int64, error)

+ GetHasReadSeqs func(ctx context.Context, userID string, conversationIDs []string) (map[string]int64, error)

+ GetMaxSeq func(ctx context.Context, conversationID string) (int64, error)

+ GetMaxSeqs func(ctx context.Context, conversationIDs []string) (map[string]int64, error)

+ GetMinSeq func(ctx context.Context, conversationID string) (int64, error)

+ GetMinSeqs func(ctx context.Context, conversationIDs []string) (map[string]int64, error)

+ SetConversationUserMinSeq func(ctx context.Context, conversationID string, userID string, minSeq int64) error

+ SetConversationUserMinSeqs func(ctx context.Context, conversationID string, seqs map[string]int64) (err error)

+ SetHasReadSeq func(ctx context.Context, userID string, conversationID string, hasReadSeq int64) error

+ SetHasReadSeqs func(ctx context.Context, conversationID string, hasReadSeqs map[string]int64) error

+ SetMaxSeq func(ctx context.Context, conversationID string, maxSeq int64) error

+ SetMinSeq func(ctx context.Context, conversationID string, minSeq int64) error

+ SetMinSeqs func(ctx context.Context, seqs map[string]int64) error

+ SetUserConversationsMinSeqs func(ctx context.Context, userID string, seqs map[string]int64) error

+ UserSetHasReadSeqs func(ctx context.Context, userID string, hasReadSeqs map[string]int64) error

+ type UserCache interface

+ DelUsersGlobalRecvMsgOpt func(userIDs ...string) UserCache

+ DelUsersInfo func(userIDs ...string) UserCache

+ GetUserGlobalRecvMsgOpt func(ctx context.Context, userID string) (opt int, err error)

+ GetUserInfo func(ctx context.Context, userID string) (userInfo *relationtb.UserModel, err error)

+ GetUserStatus func(ctx context.Context, userIDs []string) ([]*user.OnlineStatus, error)

+ GetUsersInfo func(ctx context.Context, userIDs []string) ([]*relationtb.UserModel, error)

+ NewCache func() UserCache

+ SetUserStatus func(ctx context.Context, list []*user.OnlineStatus) error

+ func NewUserCacheRedis(rdb redis.UniversalClient, userDB relationtb.UserModelInterface, ...) UserCache

+ type UserCacheRedis struct

+ func (u *UserCacheRedis) DelUsersGlobalRecvMsgOpt(userIDs ...string) UserCache

+ func (u *UserCacheRedis) DelUsersInfo(userIDs ...string) UserCache

+ func (u *UserCacheRedis) GetUserGlobalRecvMsgOpt(ctx context.Context, userID string) (opt int, err error)

+ func (u *UserCacheRedis) GetUserInfo(ctx context.Context, userID string) (userInfo *relationtb.UserModel, err error)

+ func (u *UserCacheRedis) GetUserStatus(ctx context.Context, userIDs []string) ([]*user.OnlineStatus, error)

+ func (u *UserCacheRedis) GetUsersInfo(ctx context.Context, userIDs []string) ([]*relationtb.UserModel, error)

+ func (u *UserCacheRedis) NewCache() UserCache

+ func (u *UserCacheRedis) SetUserStatus(ctx context.Context, list []*user.OnlineStatus) error