Documentation ¶
Index ¶
- type DB
- type Service
- func (s *Service) AddRecordFocus(uid string, mid int64, time uint64) error
- func (s *Service) AppendGroupCastSignal(mid, target string, signalType xproto.SignalType, content []byte, ...) error
- func (s *Service) AppendGroupMsg(isSelfRead bool, p *xproto.Common) error
- func (s *Service) AppendMsg(isSelfRead bool, p *xproto.Common) error
- func (s *Service) AppendUniCastSignal(mid, target string, signalType xproto.SignalType, content []byte, ...) error
- func (s Service) Config() *config.Config
- func (s *Service) DealConn(ctx context.Context, m *record.RecordDeal) error
- func (s *Service) DealStore(ctx context.Context, m *record.PushMsg) error
- func (s *Service) DelRecord(tp xproto.Channel, mid int64) error
- func (s *Service) GetRecordsAfterMid(tp xproto.Channel, fromId, targetId string, mid int64, recordCount int64) ([]*model.MsgContent, error)
- func (s *Service) GetSpecifyRecord(tp xproto.Channel, mid int64) (*model.MsgContent, error)
- func (s *Service) GetSyncMsg(key, uid string, startMid, count int64) ([][]byte, error)
- func (s *Service) GetSyncMsgJustBizLevel(key, uid string, startMid, count int64) ([][]byte, error)
- func (s *Service) ListenMQ()
- func (s *Service) MarkReceived(tp, uid string, mid int64) error
- func (s *Service) PushMem(p *xproto.Common) error
- func (s *Service) SendSyncMsg(key, uid string, startMid int64) error
- func (s *Service) SendUnReadMsg(key, uid string) error
- func (s *Service) Shutdown(ctx context.Context)
- func (s *Service) StatisticRecordFocusNumber(mid int64) (int32, error)
- func (s *Service) StoreGroupMsg(deviceType xproto.Device, pro *xproto.Common) error
- func (s *Service) StoreMsg(deviceType xproto.Device, pro *xproto.Common) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func (*Service) AddRecordFocus ¶
AddRecordFocus 添加消息关注记录
func (*Service) AppendGroupCastSignal ¶
func (*Service) AppendGroupMsg ¶
func (*Service) AppendUniCastSignal ¶
func (*Service) GetRecordsAfterMid ¶
func (s *Service) GetRecordsAfterMid(tp xproto.Channel, fromId, targetId string, mid int64, recordCount int64) ([]*model.MsgContent, error)
GetPriRecord 所有聊天记录
func (*Service) GetSpecifyRecord ¶
GetPriRecord 所有聊天记录
func (*Service) GetSyncMsg ¶
func (*Service) GetSyncMsgJustBizLevel ¶ added in v0.1.0
func (*Service) SendUnReadMsg ¶
func (*Service) StatisticRecordFocusNumber ¶
StatisticRecordFocusNumber 统计消息关注数
func (*Service) StoreGroupMsg ¶
Click to show internal directories.
Click to hide internal directories.