indexdb

package
v3.8.1-rc.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 15, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Rendered for js/wasm

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Black 

type Black struct {
	// contains filtered or unexported fields
}

func NewBlack 

func NewBlack(loginUserID string) *Black

func (Black) DeleteBlack 

func (i Black) DeleteBlack(ctx context.Context, blockUserID string) error

DeleteBlack removes a blocked user from the database

func (Black) GetBlackInfoByBlockUserID 

func (i Black) GetBlackInfoByBlockUserID(ctx context.Context, blockUserID string) (result *model_struct.LocalBlack, err error)

GetBlackInfoByBlockUserID gets the information of a blocked user by their user ID

func (Black) GetBlackInfoList 

func (i Black) GetBlackInfoList(ctx context.Context, blockUserIDList []string) (result []*model_struct.LocalBlack, err error)

GetBlackInfoList gets the information of multiple blocked users by their user IDs

func (Black) GetBlackListDB 

func (i Black) GetBlackListDB(ctx context.Context) (result []*model_struct.LocalBlack, err error)

GetBlackListDB gets the blacklist list from the database

func (Black) GetBlackListUserID 

func (i Black) GetBlackListUserID(ctx context.Context) (result []string, err error)

GetBlackListUserID gets the list of blocked user IDs

func (Black) InsertBlack 

func (i Black) InsertBlack(ctx context.Context, black *model_struct.LocalBlack) error

InsertBlack inserts a new blocked user into the database

func (Black) UpdateBlack 

func (i Black) UpdateBlack(ctx context.Context, black *model_struct.LocalBlack) error

UpdateBlack updates the information of a blocked user in the database

type Friend 

type Friend struct {
	// contains filtered or unexported fields
}

func NewFriend 

func NewFriend(loginUserID string) *Friend

func (*Friend) BatchInsertFriend added in v3.8.0 

func (i *Friend) BatchInsertFriend(ctx context.Context, friendList []*model_struct.LocalFriend) error

func (*Friend) DeleteAllFriend added in v3.8.0 

func (i *Friend) DeleteAllFriend(ctx context.Context) error

func (*Friend) DeleteFriendDB 

func (i *Friend) DeleteFriendDB(ctx context.Context, friendUserID string) error

func (*Friend) GetAllFriendList 

func (i *Friend) GetAllFriendList(ctx context.Context) (result []*model_struct.LocalFriend, err error)

func (*Friend) GetFriendInfoByFriendUserID 

func (i *Friend) GetFriendInfoByFriendUserID(ctx context.Context, FriendUserID string) (*model_struct.LocalFriend, error)

func (*Friend) GetFriendInfoList 

func (i *Friend) GetFriendInfoList(ctx context.Context, friendUserIDList []string) (result []*model_struct.LocalFriend, err error)

func (*Friend) GetFriendListCount added in v3.8.0 

func (i *Friend) GetFriendListCount(ctx context.Context) (int64, error)

func (*Friend) GetPageFriendList 

func (i *Friend) GetPageFriendList(ctx context.Context, offset, count int) (result []*model_struct.LocalFriend, err error)

func (*Friend) InsertFriend 

func (i *Friend) InsertFriend(ctx context.Context, friend *model_struct.LocalFriend) error

func (*Friend) SearchFriendList 

func (i *Friend) SearchFriendList(ctx context.Context, keyword string, isSearchUserID, isSearchNickname, isSearchRemark bool) (result []*model_struct.LocalFriend, err error)

func (*Friend) UpdateColumnsFriend added in v3.5.0 

func (i *Friend) UpdateColumnsFriend(ctx context.Context, friendIDs []string, args map[string]interface{}) error

func (*Friend) UpdateFriend 

func (i *Friend) UpdateFriend(ctx context.Context, friend *model_struct.LocalFriend) error

type FriendRequest 

type FriendRequest struct {
	// contains filtered or unexported fields
}

func NewFriendRequest 

func NewFriendRequest(loginUserID string) *FriendRequest

func (FriendRequest) DeleteFriendRequestBothUserID 

func (i FriendRequest) DeleteFriendRequestBothUserID(ctx context.Context, fromUserID, toUserID string) error

func (FriendRequest) GetBothFriendReq 

func (i FriendRequest) GetBothFriendReq(ctx context.Context, fromUserID, toUserID string) (result []*model_struct.LocalFriendRequest, err error)

func (FriendRequest) GetFriendApplicationByBothID 

func (i FriendRequest) GetFriendApplicationByBothID(ctx context.Context, fromUserID, toUserID string) (*model_struct.LocalFriendRequest, error)

func (FriendRequest) GetRecvFriendApplication 

func (i FriendRequest) GetRecvFriendApplication(ctx context.Context) (result []*model_struct.LocalFriendRequest, err error)

func (FriendRequest) GetSendFriendApplication 

func (i FriendRequest) GetSendFriendApplication(ctx context.Context) (result []*model_struct.LocalFriendRequest, err error)

func (FriendRequest) InsertFriendRequest 

func (i FriendRequest) InsertFriendRequest(ctx context.Context, friendRequest *model_struct.LocalFriendRequest) error

func (FriendRequest) UpdateFriendRequest 

func (i FriendRequest) UpdateFriendRequest(ctx context.Context, friendRequest *model_struct.LocalFriendRequest) error

type IndexDB 

type IndexDB struct {
	LocalUsers
	LocalConversations
	*LocalChatLogs
	LocalSuperGroup
	LocalConversationUnreadMessages
	LocalGroups
	LocalGroupMember
	LocalGroupRequest
	LocalCacheMessage
	LocalStrangers
	LocalUserCommand
	*FriendRequest
	*Black
	*Friend
	LocalChatLogReactionExtensions
	// contains filtered or unexported fields
}

func (IndexDB) Close 

func (i IndexDB) Close(ctx context.Context) error

func (IndexDB) InitDB 

func (i IndexDB) InitDB(ctx context.Context, userID string, dataDir string) error

func (IndexDB) SetChatLogFailedStatus 

func (i IndexDB) SetChatLogFailedStatus(ctx context.Context)

type LocalAppSDKVersion added in v3.8.0 

type LocalAppSDKVersion struct {
}

func NewLocalAppSDKVersion added in v3.8.0 

func NewLocalAppSDKVersion() *LocalAppSDKVersion

func (*LocalAppSDKVersion) GetAppSDKVersion added in v3.8.0 

func (i *LocalAppSDKVersion) GetAppSDKVersion(ctx context.Context) (*model_struct.LocalAppSDKVersion, error)

func (*LocalAppSDKVersion) SetAppSDKVersion added in v3.8.0 

func (i *LocalAppSDKVersion) SetAppSDKVersion(ctx context.Context, appVersion *model_struct.LocalAppSDKVersion) error

type LocalCacheMessage 

type LocalCacheMessage struct {
}

func NewLocalCacheMessage 

func NewLocalCacheMessage() *LocalCacheMessage

func (*LocalCacheMessage) BatchInsertTempCacheMessageList 

func (i *LocalCacheMessage) BatchInsertTempCacheMessageList(ctx context.Context, MessageList []*model_struct.TempCacheLocalChatLog) error

func (*LocalCacheMessage) InsertTempCacheMessage 

func (i *LocalCacheMessage) InsertTempCacheMessage(ctx context.Context, Message *model_struct.TempCacheLocalChatLog) error

type LocalChatLogReactionExtensions 

type LocalChatLogReactionExtensions struct {
	ExtKey  string `json:"ext_key"`
	ExtVal  string `json:"ext_val"`
	ExtKey2 string `json:"ext_key2"`
	ExtVal2 string `json:"ext_val2"`
}

func NewLocalChatLogReactionExtensions 

func NewLocalChatLogReactionExtensions() *LocalChatLogReactionExtensions

func (*LocalChatLogReactionExtensions) DeleteMessageReactionExtension 

func (i *LocalChatLogReactionExtensions) DeleteMessageReactionExtension(ctx context.Context, msgID string) error

func (*LocalChatLogReactionExtensions) GetMessageReactionExtension 

func (i *LocalChatLogReactionExtensions) GetMessageReactionExtension(ctx context.Context, clientMsgID string) (result *model_struct.LocalChatLogReactionExtensions, err error)

func (*LocalChatLogReactionExtensions) GetMultipleMessageReactionExtension 

func (i *LocalChatLogReactionExtensions) GetMultipleMessageReactionExtension(ctx context.Context, msgIDList []string) (result []*model_struct.LocalChatLogReactionExtensions, err error)
func (i *LocalChatLogReactionExtensions) GetAndUpdateMessageReactionExtension(ctx context.Context, clientMsgID string, m map[string]*sdkws.KeyValue) error {
	_, err := exec.Exec(clientMsgID, utils.StructToJsonString(m))
	return err
}

func (i *LocalChatLogReactionExtensions) DeleteAndUpdateMessageReactionExtension(ctx context.Context, clientMsgID string, m map[string]*sdkws.KeyValue) error {
	_, err := exec.Exec(clientMsgID, utils.StructToJsonString(m))
	return err
}

func (*LocalChatLogReactionExtensions) InsertMessageReactionExtension 

func (i *LocalChatLogReactionExtensions) InsertMessageReactionExtension(ctx context.Context, messageReactionExtension *model_struct.LocalChatLogReactionExtensions) error

func (*LocalChatLogReactionExtensions) UpdateMessageReactionExtension 

func (i *LocalChatLogReactionExtensions) UpdateMessageReactionExtension(ctx context.Context, c *model_struct.LocalChatLogReactionExtensions) error

type LocalChatLogs 

type LocalChatLogs struct {
	// contains filtered or unexported fields
}

func NewLocalChatLogs 

func NewLocalChatLogs(loginUserID string) *LocalChatLogs

NewLocalChatLogs creates a new LocalChatLogs

func (*LocalChatLogs) BatchInsertExceptionMsg 

func (i *LocalChatLogs) BatchInsertExceptionMsg(ctx context.Context, MessageList []*model_struct.LocalErrChatLog) error

Batch insert exception messages into the chat logs

func (*LocalChatLogs) BatchInsertMessageList 

func (i *LocalChatLogs) BatchInsertMessageList(ctx context.Context, conversationID string, messageList []*model_struct.LocalChatLog) error

UpdateMessageStatus updates the message status in the database

func (*LocalChatLogs) CheckConversationNormalMsgSeq added in v3.8.0 

func (i *LocalChatLogs) CheckConversationNormalMsgSeq(ctx context.Context, conversationID string) (int64, error)

func (*LocalChatLogs) DeleteAllMessage 

func (i *LocalChatLogs) DeleteAllMessage(ctx context.Context) error

DeleteAllMessage deletes all messages from the local chat log.

func (*LocalChatLogs) DeleteConversationAllMessages 

func (i *LocalChatLogs) DeleteConversationAllMessages(ctx context.Context, conversationID string) error

DeleteConversationAllMessages deletes all messages of the session

func (*LocalChatLogs) DeleteConversationMsgs 

func (i *LocalChatLogs) DeleteConversationMsgs(ctx context.Context, conversationID string, msgIDs []string) error

DeleteConversationMsgs deletes messages of the session

func (*LocalChatLogs) DeleteConversationMsgsBySeqs 

func (i *LocalChatLogs) DeleteConversationMsgsBySeqs(ctx context.Context, conversationID string, seqs []int64) error

DeleteConversationMsgsBySeqs deletes messages of the session

func (*LocalChatLogs) GetAbnormalMsgSeq 

func (i *LocalChatLogs) GetAbnormalMsgSeq(ctx context.Context) (int64, error)

Get the abnormal message sequence number

func (*LocalChatLogs) GetAbnormalMsgSeqList 

func (i *LocalChatLogs) GetAbnormalMsgSeqList(ctx context.Context) (result []int64, err error)

Get the list of abnormal message sequence numbers

func (*LocalChatLogs) GetAlreadyExistSeqList 

func (i *LocalChatLogs) GetAlreadyExistSeqList(ctx context.Context, conversationID string, lostSeqList []int64) (result []int64, err error)

GetAlreadyExistSeqList get already exist seq list

func (*LocalChatLogs) GetConversationAbnormalMsgSeq 

func (i *LocalChatLogs) GetConversationAbnormalMsgSeq(ctx context.Context, groupID string) (int64, error)

GetConversationAbnormalMsgSeq gets the maximum abnormal seq of the session

func (*LocalChatLogs) GetConversationNormalMsgSeq 

func (i *LocalChatLogs) GetConversationNormalMsgSeq(ctx context.Context, conversationID string) (int64, error)

GetConversationNormalMsgSeq gets the maximum seq of the session

func (*LocalChatLogs) GetConversationPeerNormalMsgSeq 

func (i *LocalChatLogs) GetConversationPeerNormalMsgSeq(ctx context.Context, conversationID string) (int64, error)

GetConversationPeerNormalMsgSeq gets the maximum seq of the peer in the session

func (*LocalChatLogs) GetLostMsgSeqList 

func (i *LocalChatLogs) GetLostMsgSeqList(ctx context.Context, minSeqInSvr uint32) (result []uint32, err error)

GetLostMsgSeqList gets lost message seq list.

func (*LocalChatLogs) GetMessage 

func (i *LocalChatLogs) GetMessage(ctx context.Context, conversationID, clientMsgID string) (*model_struct.LocalChatLog, error)

GetMessage gets the message from the database

func (*LocalChatLogs) GetMessageBySeq 

func (i *LocalChatLogs) GetMessageBySeq(ctx context.Context, conversationID string, seq int64) (*model_struct.LocalChatLog, error)

GetMessagesBySeq get message by seq

func (*LocalChatLogs) GetMessageList 

func (i *LocalChatLogs) GetMessageList(ctx context.Context, conversationID string, count int, startTime int64, isReverse bool) (result []*model_struct.LocalChatLog, err error)

GetMessageList retrieves a list of messages from the local chat log.

func (*LocalChatLogs) GetMessageListNoTime 

func (i *LocalChatLogs) GetMessageListNoTime(ctx context.Context, conversationID string, count int, isReverse bool) (result []*model_struct.LocalChatLog, err error)

GetMessageListNoTime retrieves a list of messages from the local chat log without specifying a start time.

func (*LocalChatLogs) GetMessagesByClientMsgIDs 

func (i *LocalChatLogs) GetMessagesByClientMsgIDs(ctx context.Context, conversationID string, msgIDs []string) (result []*model_struct.LocalChatLog, err error)

func (*LocalChatLogs) GetMessagesBySeqs 

func (i *LocalChatLogs) GetMessagesBySeqs(ctx context.Context, conversationID string, seqs []int64) (result []*model_struct.LocalChatLog, err error)

GetMessagesBySeqs gets messages by seqs

func (*LocalChatLogs) GetMsgSeqByClientMsgID 

func (i *LocalChatLogs) GetMsgSeqByClientMsgID(ctx context.Context, clientMsgID string) (uint32, error)

Get the message sequence number by client message ID

func (*LocalChatLogs) GetMsgSeqListByGroupID 

func (i *LocalChatLogs) GetMsgSeqListByGroupID(ctx context.Context, groupID string) (result []uint32, err error)

Get the message sequence number list by group ID

func (*LocalChatLogs) GetMsgSeqListByPeerUserID 

func (i *LocalChatLogs) GetMsgSeqListByPeerUserID(ctx context.Context, userID string) (result []uint32, err error)

Get the message sequence number list by peer user ID

func (*LocalChatLogs) GetMsgSeqListBySelfUserID 

func (i *LocalChatLogs) GetMsgSeqListBySelfUserID(ctx context.Context, userID string) (result []uint32, err error)

Get the message sequence number list by self user ID

func (*LocalChatLogs) GetMultipleMessage 

func (i *LocalChatLogs) GetMultipleMessage(ctx context.Context, msgIDList []string) (result []*model_struct.LocalChatLog, err error)

GetMultipleMessage gets multiple messages from the local chat log.

func (*LocalChatLogs) GetSuperGroupAbnormalMsgSeq 

func (i *LocalChatLogs) GetSuperGroupAbnormalMsgSeq(ctx context.Context, groupID string) (uint32, error)

GetSuperGroupAbnormalMsgSeq get super group abnormal msg seq

func (*LocalChatLogs) GetTestMessage 

func (i *LocalChatLogs) GetTestMessage(ctx context.Context, seq uint32) (*model_struct.LocalChatLog, error)

GetTestMessage gets test message.

func (*LocalChatLogs) GetUnreadMessage 

func (i *LocalChatLogs) GetUnreadMessage(ctx context.Context, conversationID string) (result []*model_struct.LocalChatLog, err error)

func (*LocalChatLogs) InsertMessage 

func (i *LocalChatLogs) InsertMessage(ctx context.Context, conversationID string, message *model_struct.LocalChatLog) error

InsertMessage inserts a message into the local chat log.

func (*LocalChatLogs) IsExistsInErrChatLogBySeq 

func (i *LocalChatLogs) IsExistsInErrChatLogBySeq(ctx context.Context, seq int64) bool

IsExistsInErrChatLogBySeq check if message exists in error chat log by seq

func (*LocalChatLogs) MarkConversationAllMessageAsRead 

func (i *LocalChatLogs) MarkConversationAllMessageAsRead(ctx context.Context, conversationID string) (rowsAffected int64, err error)

func (*LocalChatLogs) MarkConversationMessageAsReadBySeqs 

func (i *LocalChatLogs) MarkConversationMessageAsReadBySeqs(ctx context.Context, conversationID string, seqs []int64) (rowsAffected int64, err error)

func (*LocalChatLogs) MarkConversationMessageAsReadDB 

func (i *LocalChatLogs) MarkConversationMessageAsReadDB(ctx context.Context, conversationID string, msgIDs []string) (rowsAffected int64, err error)

func (*LocalChatLogs) MarkDeleteConversationAllMessages 

func (i *LocalChatLogs) MarkDeleteConversationAllMessages(ctx context.Context, conversationID string) error

MarkDeleteConversationAllMessages marks all messages of the session as deleted

func (*LocalChatLogs) MessageIfExists 

func (i *LocalChatLogs) MessageIfExists(ctx context.Context, clientMsgID string) (bool, error)

MessageIfExists check if message exists

func (*LocalChatLogs) MessageIfExistsBySeq 

func (i *LocalChatLogs) MessageIfExistsBySeq(ctx context.Context, seq int64) (bool, error)

MessageIfExistsBySeq check if message exists by seq

func (*LocalChatLogs) SearchAllMessageByContentType 

func (i *LocalChatLogs) SearchAllMessageByContentType(ctx context.Context, conversationID string, contentType int) (result []*model_struct.LocalChatLog, err error)

Search all messages by content type

func (*LocalChatLogs) SearchMessageByContentType 

func (i *LocalChatLogs) SearchMessageByContentType(ctx context.Context, contentType []int, conversationID string, startTime, endTime int64, offset, count int) (messages []*model_struct.LocalChatLog, err error)

SearchMessageByContentType searches for messages in the local chat log by content type.

func (*LocalChatLogs) SearchMessageByContentTypeAndKeyword 

func (i *LocalChatLogs) SearchMessageByContentTypeAndKeyword(ctx context.Context, contentType []int, conversationID string, keywordList []string, keywordListMatchType int, startTime, endTime int64) (result []*model_struct.LocalChatLog, err error)

SearchMessageByKeyword searches for messages in the local chat log by keyword.

func (*LocalChatLogs) SearchMessageByKeyword 

func (i *LocalChatLogs) SearchMessageByKeyword(ctx context.Context, contentType []int, keywordList []string, keywordListMatchType int, conversationID string, startTime, endTime int64, offset, count int) (result []*model_struct.LocalChatLog, err error)

Get the message by message ID

func (*LocalChatLogs) UpdateColumnsMessage 

func (i *LocalChatLogs) UpdateColumnsMessage(ctx context.Context, conversationID, clientMsgID string, args map[string]interface{}) error

UpdateColumnsMessage updates a column of a message in the local chat log.

func (*LocalChatLogs) UpdateColumnsMessageList 

func (i *LocalChatLogs) UpdateColumnsMessageList(ctx context.Context, clientMsgIDList []string, args map[string]interface{}) error

UpdateColumnsMessageList updates multiple columns of a message in the local chat log.

func (*LocalChatLogs) UpdateGroupMessageHasRead 

func (i *LocalChatLogs) UpdateGroupMessageHasRead(ctx context.Context, msgIDList []string, sessionType int32) error

Update the message status to read in the chat logs

func (*LocalChatLogs) UpdateMessage 

func (i *LocalChatLogs) UpdateMessage(ctx context.Context, conversationID string, c *model_struct.LocalChatLog) error

UpdateMessage updates the message in the database

func (*LocalChatLogs) UpdateMessageBySeq 

func (i *LocalChatLogs) UpdateMessageBySeq(ctx context.Context, conversationID string, c *model_struct.LocalChatLog) error

UpdateMessageBySeq update message

func (*LocalChatLogs) UpdateMessageStatusBySourceID 

func (i *LocalChatLogs) UpdateMessageStatusBySourceID(ctx context.Context, sourceID string, status, sessionType int32) error

UpdateMessageStatusBySourceID updates the status of a message in the local chat log by its source ID.

func (*LocalChatLogs) UpdateMessageTimeAndStatus 

func (i *LocalChatLogs) UpdateMessageTimeAndStatus(ctx context.Context, conversationID, clientMsgID string, serverMsgID string, sendTime int64, status int32) error

UpdateMessageTimeAndStatus updates the time and status of a message in the local chat log.

func (*LocalChatLogs) UpdateMsgSenderFaceURL 

func (i *LocalChatLogs) UpdateMsgSenderFaceURL(ctx context.Context, sendID, faceURL string, sType int) error

Update the sender's face URL in the chat logs

func (*LocalChatLogs) UpdateMsgSenderFaceURLAndSenderNickname 

func (i *LocalChatLogs) UpdateMsgSenderFaceURLAndSenderNickname(ctx context.Context, conversationID, sendID, faceURL, nickname string) error

Update the sender's face URL and nickname in the chat logs

func (*LocalChatLogs) UpdateMsgSenderNickname 

func (i *LocalChatLogs) UpdateMsgSenderNickname(ctx context.Context, sendID, nickname string, sType int) error

Update the sender's nickname in the chat logs

func (*LocalChatLogs) UpdateSingleMessageHasRead 

func (i *LocalChatLogs) UpdateSingleMessageHasRead(ctx context.Context, sendID string, msgIDList []string) error

UpdateSingleMessageHasRead updates the hasRead field of a single message in the local chat log.

type LocalConversationUnreadMessages 

type LocalConversationUnreadMessages struct {
}

func NewLocalConversationUnreadMessages 

func NewLocalConversationUnreadMessages() *LocalConversationUnreadMessages

func (*LocalConversationUnreadMessages) BatchInsertConversationUnreadMessageList 

func (i *LocalConversationUnreadMessages) BatchInsertConversationUnreadMessageList(ctx context.Context, messageList []*model_struct.LocalConversationUnreadMessage) error

func (*LocalConversationUnreadMessages) DeleteConversationUnreadMessageList 

func (i *LocalConversationUnreadMessages) DeleteConversationUnreadMessageList(ctx context.Context, conversationID string, sendTime int64) int64

type LocalConversations 

type LocalConversations struct {
}

func NewLocalConversations 

func NewLocalConversations() *LocalConversations

func (*LocalConversations) BatchInsertConversationList 

func (i *LocalConversations) BatchInsertConversationList(ctx context.Context, conversationList []*model_struct.LocalConversation) error

func (*LocalConversations) BatchUpdateConversationList 

func (i *LocalConversations) BatchUpdateConversationList(ctx context.Context, conversationList []*model_struct.LocalConversation) error

func (*LocalConversations) ClearAllConversation 

func (i *LocalConversations) ClearAllConversation(ctx context.Context) error

func (*LocalConversations) ClearConversation 

func (i *LocalConversations) ClearConversation(ctx context.Context, conversationID string) error

func (*LocalConversations) ConversationIfExists 

func (i *LocalConversations) ConversationIfExists(ctx context.Context, conversationID string) (bool, error)

func (*LocalConversations) DecrConversationUnreadCount 

func (i *LocalConversations) DecrConversationUnreadCount(ctx context.Context, conversationID string, count int64) error

func (*LocalConversations) DeleteAllConversation added in v3.8.0 

func (i *LocalConversations) DeleteAllConversation(ctx context.Context) error

func (*LocalConversations) DeleteConversation 

func (i *LocalConversations) DeleteConversation(ctx context.Context, conversationID string) error

func (*LocalConversations) GetAllConversationIDList 

func (i *LocalConversations) GetAllConversationIDList(ctx context.Context) ([]string, error)

func (*LocalConversations) GetAllConversationListDB 

func (i *LocalConversations) GetAllConversationListDB(ctx context.Context) (result []*model_struct.LocalConversation, err error)

func (*LocalConversations) GetAllConversations 

func (i *LocalConversations) GetAllConversations(ctx context.Context) (result []*model_struct.LocalConversation, err error)

func (*LocalConversations) GetAllSingleConversationIDList 

func (i *LocalConversations) GetAllSingleConversationIDList(ctx context.Context) (result []string, err error)

func (*LocalConversations) GetConversation 

func (i *LocalConversations) GetConversation(ctx context.Context, conversationID string) (*model_struct.LocalConversation, error)

func (*LocalConversations) GetConversationByUserID 

func (i *LocalConversations) GetConversationByUserID(ctx context.Context, userID string) (*model_struct.LocalConversation, error)

func (*LocalConversations) GetConversationListSplitDB 

func (i *LocalConversations) GetConversationListSplitDB(ctx context.Context, offset, count int) (result []*model_struct.LocalConversation, err error)

func (*LocalConversations) GetHiddenConversationList 

func (i *LocalConversations) GetHiddenConversationList(ctx context.Context) (result []*model_struct.LocalConversation, err error)

func (*LocalConversations) GetMultipleConversationDB 

func (i *LocalConversations) GetMultipleConversationDB(ctx context.Context, conversationIDList []string) (result []*model_struct.LocalConversation, err error)

func (*LocalConversations) GetTotalUnreadMsgCountDB 

func (i *LocalConversations) GetTotalUnreadMsgCountDB(ctx context.Context) (totalUnreadCount int32, err error)

func (*LocalConversations) IncrConversationUnreadCount 

func (i *LocalConversations) IncrConversationUnreadCount(ctx context.Context, conversationID string) error

func (*LocalConversations) InsertConversation 

func (i *LocalConversations) InsertConversation(ctx context.Context, conversationList *model_struct.LocalConversation) error

func (*LocalConversations) RemoveConversationDraft 

func (i *LocalConversations) RemoveConversationDraft(ctx context.Context, conversationID, draftText string) error

func (*LocalConversations) ResetAllConversation 

func (i *LocalConversations) ResetAllConversation(ctx context.Context) error

func (*LocalConversations) ResetConversation 

func (i *LocalConversations) ResetConversation(ctx context.Context, conversationID string) error

func (*LocalConversations) SearchConversations added in v3.5.0 

func (i *LocalConversations) SearchConversations(ctx context.Context, searchParam string) ([]*model_struct.LocalConversation, error)

func (*LocalConversations) SetConversationDraftDB 

func (i *LocalConversations) SetConversationDraftDB(ctx context.Context, conversationID, draftText string) error

func (*LocalConversations) SetMultipleConversationRecvMsgOpt 

func (i *LocalConversations) SetMultipleConversationRecvMsgOpt(ctx context.Context, conversationIDList []string, opt int) (err error)

func (*LocalConversations) UnPinConversation 

func (i *LocalConversations) UnPinConversation(ctx context.Context, conversationID string, isPinned int) error

func (*LocalConversations) UpdateAllConversation 

func (i *LocalConversations) UpdateAllConversation(ctx context.Context, conversation *model_struct.LocalConversation) error

func (*LocalConversations) UpdateColumnsConversation 

func (i *LocalConversations) UpdateColumnsConversation(ctx context.Context, conversationID string, args map[string]interface{}) error

func (*LocalConversations) UpdateConversation 

func (i *LocalConversations) UpdateConversation(ctx context.Context, c *model_struct.LocalConversation) error

func (*LocalConversations) UpdateConversationForSync 

func (i *LocalConversations) UpdateConversationForSync(ctx context.Context, c *model_struct.LocalConversation) error

func (*LocalConversations) UpdateOrCreateConversations 

func (i *LocalConversations) UpdateOrCreateConversations(ctx context.Context, conversationList []*model_struct.LocalConversation) error

type LocalGroupMember 

type LocalGroupMember struct {
}

func NewLocalGroupMember 

func NewLocalGroupMember() *LocalGroupMember

func (*LocalGroupMember) BatchInsertGroupMember 

func (i *LocalGroupMember) BatchInsertGroupMember(ctx context.Context, groupMemberList []*model_struct.LocalGroupMember) error

func (*LocalGroupMember) DeleteGroupAllMembers 

func (i *LocalGroupMember) DeleteGroupAllMembers(ctx context.Context, groupID string) error

func (*LocalGroupMember) DeleteGroupMember 

func (i *LocalGroupMember) DeleteGroupMember(ctx context.Context, groupID, userID string) error

func (*LocalGroupMember) GetAllGroupMemberList 

func (i *LocalGroupMember) GetAllGroupMemberList(ctx context.Context) ([]model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetAllGroupMemberUserIDList 

func (i *LocalGroupMember) GetAllGroupMemberUserIDList(ctx context.Context) ([]model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupAdminID 

func (i *LocalGroupMember) GetGroupAdminID(ctx context.Context, groupID string) ([]string, error)

func (*LocalGroupMember) GetGroupMemberCount 

func (i *LocalGroupMember) GetGroupMemberCount(ctx context.Context, groupID string) (int32, error)

func (*LocalGroupMember) GetGroupMemberInfoByGroupIDUserID 

func (i *LocalGroupMember) GetGroupMemberInfoByGroupIDUserID(ctx context.Context, groupID, userID string) (*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupMemberInfoIfOwnerOrAdmin 

func (i *LocalGroupMember) GetGroupMemberInfoIfOwnerOrAdmin(ctx context.Context) ([]*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupMemberListByGroupID 

func (i *LocalGroupMember) GetGroupMemberListByGroupID(ctx context.Context, groupID string) ([]*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupMemberListByUserIDs added in v3.8.0 

func (i *LocalGroupMember) GetGroupMemberListByUserIDs(ctx context.Context, groupID string, filter int32, userIDs []string) ([]*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupMemberListSplit 

func (i *LocalGroupMember) GetGroupMemberListSplit(ctx context.Context, groupID string, filter int32, offset, count int) ([]*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupMemberListSplitByJoinTimeFilter 

func (i *LocalGroupMember) GetGroupMemberListSplitByJoinTimeFilter(ctx context.Context, groupID string, offset, count int, joinTimeBegin, joinTimeEnd int64, userIDList []string) ([]*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupMemberOwner 

func (i *LocalGroupMember) GetGroupMemberOwner(ctx context.Context, groupID string) (*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupMemberOwnerAndAdminDB 

func (i *LocalGroupMember) GetGroupMemberOwnerAndAdminDB(ctx context.Context, groupID string) ([]*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupMemberUIDListByGroupID 

func (i *LocalGroupMember) GetGroupMemberUIDListByGroupID(ctx context.Context, groupID string) (result []string, err error)

func (*LocalGroupMember) GetGroupOwnerAndAdminByGroupID 

func (i *LocalGroupMember) GetGroupOwnerAndAdminByGroupID(ctx context.Context, groupID string) ([]*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupSomeMemberInfo 

func (i *LocalGroupMember) GetGroupSomeMemberInfo(ctx context.Context, groupID string, userIDList []string) ([]*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetUserJoinedGroupIDs 

func (i *LocalGroupMember) GetUserJoinedGroupIDs(ctx context.Context, userID string) (result []string, err error)

func (*LocalGroupMember) InsertGroupMember 

func (i *LocalGroupMember) InsertGroupMember(ctx context.Context, groupMember *model_struct.LocalGroupMember) error

func (*LocalGroupMember) SearchGroupMembersDB 

func (i *LocalGroupMember) SearchGroupMembersDB(ctx context.Context, keyword string, groupID string, isSearchMemberNickname, isSearchUserID bool, offset, count int) (result []*model_struct.LocalGroupMember, err error)

func (*LocalGroupMember) UpdateGroupMember 

func (i *LocalGroupMember) UpdateGroupMember(ctx context.Context, groupMember *model_struct.LocalGroupMember) error

func (*LocalGroupMember) UpdateGroupMemberField 

func (i *LocalGroupMember) UpdateGroupMemberField(ctx context.Context, groupID, userID string, args map[string]interface{}) error

type LocalGroupRequest 

type LocalGroupRequest struct {
}

func NewLocalGroupRequest 

func NewLocalGroupRequest() *LocalGroupRequest

func (*LocalGroupRequest) DeleteAdminGroupRequest 

func (i *LocalGroupRequest) DeleteAdminGroupRequest(ctx context.Context, groupID, userID string) error

func (*LocalGroupRequest) DeleteGroupRequest 

func (i *LocalGroupRequest) DeleteGroupRequest(ctx context.Context, groupID, userID string) error

func (*LocalGroupRequest) GetAdminGroupApplication 

func (i *LocalGroupRequest) GetAdminGroupApplication(ctx context.Context) ([]*model_struct.LocalAdminGroupRequest, error)

func (*LocalGroupRequest) GetSendGroupApplication 

func (i *LocalGroupRequest) GetSendGroupApplication(ctx context.Context) ([]*model_struct.LocalGroupRequest, error)

func (*LocalGroupRequest) InsertAdminGroupRequest 

func (i *LocalGroupRequest) InsertAdminGroupRequest(ctx context.Context, groupRequest *model_struct.LocalAdminGroupRequest) error

func (*LocalGroupRequest) InsertGroupRequest 

func (i *LocalGroupRequest) InsertGroupRequest(ctx context.Context, groupRequest *model_struct.LocalGroupRequest) error

func (*LocalGroupRequest) UpdateAdminGroupRequest 

func (i *LocalGroupRequest) UpdateAdminGroupRequest(ctx context.Context, groupRequest *model_struct.LocalAdminGroupRequest) error

func (*LocalGroupRequest) UpdateGroupRequest 

func (i *LocalGroupRequest) UpdateGroupRequest(ctx context.Context, groupRequest *model_struct.LocalGroupRequest) error

type LocalGroups 

type LocalGroups struct{}

func NewLocalGroups 

func NewLocalGroups() *LocalGroups

func (*LocalGroups) AddMemberCount 

func (i *LocalGroups) AddMemberCount(ctx context.Context, groupID string) error

func (*LocalGroups) BatchInsertGroup added in v3.8.0 

func (i *LocalGroups) BatchInsertGroup(ctx context.Context, groupList []*model_struct.LocalGroup) error

func (*LocalGroups) DeleteAllGroup added in v3.8.0 

func (i *LocalGroups) DeleteAllGroup(ctx context.Context) error

func (*LocalGroups) DeleteGroup 

func (i *LocalGroups) DeleteGroup(ctx context.Context, groupID string) error

func (*LocalGroups) GetAllGroupInfoByGroupIDOrGroupName 

func (i *LocalGroups) GetAllGroupInfoByGroupIDOrGroupName(ctx context.Context, keyword string, isSearchGroupID bool, isSearchGroupName bool) (result []*model_struct.LocalGroup, err error)

func (*LocalGroups) GetGroupInfoByGroupID 

func (i *LocalGroups) GetGroupInfoByGroupID(ctx context.Context, groupID string) (*model_struct.LocalGroup, error)

func (*LocalGroups) GetGroupMemberAllGroupIDs 

func (i *LocalGroups) GetGroupMemberAllGroupIDs(ctx context.Context) (result []string, err error)

func (*LocalGroups) GetGroups 

func (i *LocalGroups) GetGroups(ctx context.Context, groupIDs []string) (result []*model_struct.LocalGroup, err error)

func (*LocalGroups) GetJoinedGroupListDB 

func (i *LocalGroups) GetJoinedGroupListDB(ctx context.Context) (result []*model_struct.LocalGroup, err error)

func (*LocalGroups) InsertGroup 

func (i *LocalGroups) InsertGroup(ctx context.Context, groupInfo *model_struct.LocalGroup) error

func (*LocalGroups) SubtractMemberCount 

func (i *LocalGroups) SubtractMemberCount(ctx context.Context, groupID string) error

func (*LocalGroups) UpdateGroup 

func (i *LocalGroups) UpdateGroup(ctx context.Context, groupInfo *model_struct.LocalGroup) error

this method need full update

type LocalSendingMessages added in v3.4.0 

type LocalSendingMessages struct {
}

func NewLocalSendingMessages added in v3.4.0 

func NewLocalSendingMessages() *LocalSendingMessages

func (*LocalSendingMessages) DeleteSendingMessage added in v3.4.0 

func (i *LocalSendingMessages) DeleteSendingMessage(ctx context.Context, conversationID, clientMsgID string) error

func (*LocalSendingMessages) GetAllSendingMessages added in v3.4.0 

func (i *LocalSendingMessages) GetAllSendingMessages(ctx context.Context) (result []*model_struct.LocalSendingMessages, err error)

func (*LocalSendingMessages) InsertSendingMessage added in v3.4.0 

func (i *LocalSendingMessages) InsertSendingMessage(ctx context.Context, message *model_struct.LocalSendingMessages) error

type LocalStrangers 

type LocalStrangers struct {
}

func NewLocalStrangers 

func NewLocalStrangers() *LocalStrangers

func (*LocalStrangers) GetStrangerInfo 

func (l *LocalStrangers) GetStrangerInfo(ctx context.Context, userIDs []string) (result []*model_struct.LocalStranger, err error)

func (*LocalStrangers) SetStrangerInfo 

func (l *LocalStrangers) SetStrangerInfo(ctx context.Context, strangerList []*model_struct.LocalStranger) error

type LocalSuperGroup 

type LocalSuperGroup struct{}

func NewLocalSuperGroup 

func NewLocalSuperGroup() *LocalSuperGroup

func (*LocalSuperGroup) DeleteAllSuperGroup 

func (i *LocalSuperGroup) DeleteAllSuperGroup(ctx context.Context) error

func (*LocalSuperGroup) DeleteSuperGroup 

func (i *LocalSuperGroup) DeleteSuperGroup(ctx context.Context, groupID string) error

func (*LocalSuperGroup) GetJoinedSuperGroupList 

func (i *LocalSuperGroup) GetJoinedSuperGroupList(ctx context.Context) (result []*model_struct.LocalGroup, err error)

func (*LocalSuperGroup) GetJoinedWorkingGroupIDList 

func (i *LocalSuperGroup) GetJoinedWorkingGroupIDList(ctx context.Context) ([]string, error)

func (*LocalSuperGroup) GetJoinedWorkingGroupList 

func (i *LocalSuperGroup) GetJoinedWorkingGroupList(ctx context.Context) (result []*model_struct.LocalGroup, err error)

func (*LocalSuperGroup) GetSuperGroupInfoByGroupID 

func (i *LocalSuperGroup) GetSuperGroupInfoByGroupID(ctx context.Context, groupID string) (*model_struct.LocalGroup, error)

func (*LocalSuperGroup) InsertSuperGroup 

func (i *LocalSuperGroup) InsertSuperGroup(ctx context.Context, groupInfo *model_struct.LocalGroup) error

func (*LocalSuperGroup) UpdateSuperGroup 

func (i *LocalSuperGroup) UpdateSuperGroup(ctx context.Context, g *model_struct.LocalGroup) error

type LocalTableMaster added in v3.8.0 

type LocalTableMaster struct {
}

func NewLocalTableMaster added in v3.8.0 

func NewLocalTableMaster() *LocalTableMaster

func (*LocalTableMaster) GetExistTables added in v3.8.0 

func (i *LocalTableMaster) GetExistTables(ctx context.Context) (result []string, err error)

type LocalUpload 

type LocalUpload struct{}

func NewLocalUpload 

func NewLocalUpload() *LocalUpload

func (*LocalUpload) DeleteExpireUpload 

func (i *LocalUpload) DeleteExpireUpload(ctx context.Context) error

func (*LocalUpload) DeleteUpload 

func (i *LocalUpload) DeleteUpload(ctx context.Context, partHash string) error

func (*LocalUpload) GetUpload 

func (i *LocalUpload) GetUpload(ctx context.Context, partHash string) (*model_struct.LocalUpload, error)

func (*LocalUpload) InsertUpload 

func (i *LocalUpload) InsertUpload(ctx context.Context, upload *model_struct.LocalUpload) error

func (*LocalUpload) UpdateUpload 

func (i *LocalUpload) UpdateUpload(ctx context.Context, upload *model_struct.LocalUpload) error

type LocalUserCommand added in v3.8.0 

type LocalUserCommand struct{}

func NewLocalUserCommand added in v3.8.0 

func NewLocalUserCommand() *LocalUserCommand

func (*LocalUserCommand) ProcessUserCommandAdd added in v3.8.0 

func (i *LocalUserCommand) ProcessUserCommandAdd(ctx context.Context, command *model_struct.LocalUserCommand) error

func (*LocalUserCommand) ProcessUserCommandDelete added in v3.8.0 

func (i *LocalUserCommand) ProcessUserCommandDelete(ctx context.Context, command *model_struct.LocalUserCommand) error

func (*LocalUserCommand) ProcessUserCommandGetAll added in v3.8.0 

func (i *LocalUserCommand) ProcessUserCommandGetAll(ctx context.Context) ([]*model_struct.LocalUserCommand, error)

func (*LocalUserCommand) ProcessUserCommandUpdate added in v3.8.0 

func (i *LocalUserCommand) ProcessUserCommandUpdate(ctx context.Context, command *model_struct.LocalUserCommand) error

type LocalUsers 

type LocalUsers struct {
}

func NewLocalUsers 

func NewLocalUsers() *LocalUsers

func (*LocalUsers) GetLoginUser 

func (l *LocalUsers) GetLoginUser(ctx context.Context, userID string) (*model_struct.LocalUser, error)

func (*LocalUsers) InsertLoginUser 

func (l *LocalUsers) InsertLoginUser(ctx context.Context, user *model_struct.LocalUser) error

func (*LocalUsers) UpdateLoginUser 

func (l *LocalUsers) UpdateLoginUser(ctx context.Context, user *model_struct.LocalUser) error

func (*LocalUsers) UpdateLoginUserByMap 

func (l *LocalUsers) UpdateLoginUserByMap(ctx context.Context, user *model_struct.LocalUser, args map[string]interface{}) error

type LocalVersionSync added in v3.8.0 

type LocalVersionSync struct {
}

func NewLocalVersionSync added in v3.8.0 

func NewLocalVersionSync() *LocalVersionSync

func (*LocalVersionSync) DeleteVersionSync added in v3.8.0 

func (i *LocalVersionSync) DeleteVersionSync(ctx context.Context, tableName, entityID string) error

func (*LocalVersionSync) GetVersionSync added in v3.8.0 

func (i *LocalVersionSync) GetVersionSync(ctx context.Context, tableName, entityID string) (*model_struct.LocalVersionSync, error)

func (*LocalVersionSync) SetVersionSync added in v3.8.0 

func (i *LocalVersionSync) SetVersionSync(ctx context.Context, lv *model_struct.LocalVersionSync) error

type NotificationSeqs 

type NotificationSeqs struct {
}

func NewNotificationSeqs 

func NewNotificationSeqs() *NotificationSeqs

func (*NotificationSeqs) BatchInsertNotificationSeq added in v3.8.0 

func (i *NotificationSeqs) BatchInsertNotificationSeq(ctx context.Context, notificationSeqs []*model_struct.NotificationSeqs) error

func (*NotificationSeqs) GetNotificationAllSeqs 

func (i *NotificationSeqs) GetNotificationAllSeqs(ctx context.Context) (result []*model_struct.NotificationSeqs, err error)

func (*NotificationSeqs) SetNotificationSeq 

func (i *NotificationSeqs) SetNotificationSeq(ctx context.Context, conversationID string, seq int64) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.