dao

Documentation

Index

• type Dao
  • func New(c *config.Config) *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)

Types

type Dao

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

func New

func New(c *config.Config) *Dao

func (*Dao) AddConnSeqIndex

func (d *Dao) AddConnSeqIndex(cid string, seq int32, item *logH.ConnSeqItem) error

func (*Dao) BatchPushPublish

func (d *Dao) BatchPushPublish(ctx context.Context, key, fromId string) (err error)

PushMsg push a message to databus.

func (*Dao) ClearConnSeq

func (d *Dao) ClearConnSeq(cid string) error

func (*Dao) GetAllJoinedGroups

func (d *Dao) GetAllJoinedGroups(ctx context.Context, uid string) (groups []int64, err error)

func (*Dao) GetConnSeqIndex

func (d *Dao) GetConnSeqIndex(cid string, seq int32) (*logH.ConnSeqItem, error)

func (*Dao) GetGroupSession

func (d *Dao) GetGroupSession(cid string, seq int32) (session string, err error)

func (*Dao) GetLogId

func (d *Dao) GetLogId(ctx context.Context) (id int64, err error)

Receive receive a message.

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

func (d *Dao) PublishOfflineMsg(ctx context.Context, fromId string, b []byte) (err error)

func (*Dao) SyncPublish

func (d *Dao) SyncPublish(ctx context.Context, key, fromId string, mid int64) (err error)

PushMsg push a message to databus.