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

commonMsgDatabase

Browse Source
This commit is contained in:
wangchuxiao 2023-05-04 16:51:50 +08:00
parent 5d617cc240
commit cfa543802e
1 changed files with 31 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
pkg/common/db/controller/common_msg.go Normal file
View File

@ -0,0 +1,31 @@
package controller
import (
"context"
"github.com/OpenIMSDK/Open-IM-Server/pkg/proto/sdkws"
)
// sourceID 可以是通知也可以是conversation
type commonMsgDatabase interface {
BatchInsertChat2DB(ctx context.Context, sourceID string, msgs []*sdkws.MsgData, currentMaxSeq int64) error
DeleteMessageFromCache(ctx context.Context, sourceID string, msgs []*sdkws.MsgData) error
GetMsgBySeqs(ctx context.Context, sourceID string, seqs []int64) (seqMsg []*sdkws.MsgData, err error)
GetMsgBySeqsRange(ctx context.Context, sourceID string, begin, end, num int64) (seqMsg []*sdkws.MsgData, err error)
CleanUpUserMsg(ctx context.Context, sourceID string) error
DelMsgsBySeqs(ctx context.Context, sourceID string, seqs []int64) (totalUnExistSeqs []int64, err error)
DelMsgsAndResetMinSeq(ctx context.Context, sourceID string, userIDs []string, remainTime int64) error
GetMinMaxSeqInMongoAndCache(ctx context.Context, sourceID string) (minSeqMongo, maxSeqMongo, minSeqCache, maxSeqCache int64, err error)
GetMaxSeq(ctx context.Context, sourceID string) (int64, error)
GetMinSeq(ctx context.Context, sourceID string) (int64, error)
SetMaxSeq(ctx context.Context, sourceID string, seq int64) error
SetMinSeq(ctx context.Context, sourceID string, seq int64) error
MsgToMQ(ctx context.Context, sourceID string, msg2mq *sdkws.MsgData) error
MsgToModifyMQ(ctx context.Context, sourceID string, messages []*sdkws.MsgData) error
MsgToPushMQ(ctx context.Context, sourceID string, msg2mq *sdkws.MsgData) (int32, int64, error)
MsgToMongoMQ(ctx context.Context, sourceID string, messages []*sdkws.MsgData, lastSeq int64) error
}