Documentation ¶
Index ¶
- type Dao
- func (d *Dao) AddConnSeqIndex(cid string, seq int32, item *logH.ConnSeqItem) error
- func (d *Dao) BatchPushPublish(ctx context.Context, key, fromId string) (err error)
- func (d *Dao) ClearConnSeq(cid string) error
- func (d *Dao) GetAllJoinedGroups(ctx context.Context, uid string) (groups []int64, err error)
- func (d *Dao) GetConnSeqIndex(cid string, seq int32) (*logH.ConnSeqItem, error)
- func (d *Dao) GetGroupSession(cid string, seq int32) (session string, err error)
- func (d *Dao) GetLogId(ctx context.Context) (id int64, err error)
- func (d *Dao) MarkReadPublish(ctx context.Context, key, fromId string, tp imparse.FrameType, mids []int64) (err error)
- func (d *Dao) PublishOfflineMsg(ctx context.Context, fromId string, b []byte) (err error)
- func (d *Dao) SyncPublish(ctx context.Context, key, fromId string, mid int64) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dao ¶
type Dao struct {
// contains filtered or unexported fields
}
func (*Dao) AddConnSeqIndex ¶
func (*Dao) BatchPushPublish ¶
PushMsg push a message to databus.
func (*Dao) ClearConnSeq ¶
func (*Dao) GetAllJoinedGroups ¶
func (*Dao) GetConnSeqIndex ¶
func (*Dao) GetGroupSession ¶
func (*Dao) MarkReadPublish ¶
func (d *Dao) MarkReadPublish(ctx context.Context, key, fromId string, tp imparse.FrameType, mids []int64) (err error)
PushMsg push a message to databus.
func (*Dao) PublishOfflineMsg ¶
Click to show internal directories.
Click to hide internal directories.