Documentation ¶
Index ¶
- Constants
- func NewServer(opts ...config.Option) *rpcxServer
- type GetLast30MsgFromDbArgs
- type GetLast30MsgFromDbReply
- type GetLastOneMsgFromDbArgs
- type GetLastOneMsgFromDbReply
- type GetMsgFromDbInRangeArgs
- type GetMsgFromDbInRangeReply
- type GetThe30MsgAfterTheIdArgs
- type GetThe30MsgAfterTheIdReply
- type GetThe30MsgBeforeTheIdArgs
- type GetThe30MsgBeforeTheIdReply
- type SaveMsgToDbArgs
- type SaveMsgToDbReply
Constants ¶
View Source
const ( SERVER_NAME = "PERSISTENCE_SVC" SERVICE_SAVE_MSG_TO_DB = "SaveMsgToDb" SERVICE_GET_MSG_FROM_DB_IN_RANGE = "GetMsgFromDbInRange" SERVICE_GET_LAST30_MSG_FROM_DB = "GetLast30MsgFromDb" SERVICE_GET_THE_30MSG_BEFORE_THE_ID = "GetThe30MsgBeforeTheId" SERVICE_GET_THE_30MSG_AFTER_THE_ID = "GetThe30MsgAfterTheId" SERVICE_GET_LASTONE_MSG = "GetLastOneMsgFromDb" )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type GetLast30MsgFromDbArgs ¶
获取会话最后30条消息
type GetLast30MsgFromDbReply ¶
type GetLastOneMsgFromDbArgs ¶
获取会话最后一条消息
type GetMsgFromDbInRangeArgs ¶
type GetMsgFromDbInRangeArgs struct { ConversationID string StartMsgId string EndMsgId string Sort contant.Sort }
根据范围会获取消息消息
type GetThe30MsgAfterTheIdArgs ¶
获取指定消息id之后30条消息
type GetThe30MsgBeforeTheIdArgs ¶
获取指定消息id之前30条消息
type SaveMsgToDbReply ¶
type SaveMsgToDbReply struct {
Failed []string
}
Click to show internal directories.
Click to hide internal directories.