dao

Documentation

Index

• type Dao
  • func New(c config.Config, plugin plugin.MessagePlugin) *Dao
  • func (d *Dao) GetOffsetDateBackwardHistoryMessages(ctx context.Context, userId int64, peer *mtproto.PeerUtil, ...) (messages []*mtproto.MessageBox)
  • func (d *Dao) GetOffsetDateForwardHistoryMessages(ctx context.Context, userId int64, peer *mtproto.PeerUtil, ...) (messages []*mtproto.MessageBox)
  • func (d *Dao) GetOffsetIdBackwardHistoryMessages(ctx context.Context, userId int64, peer *mtproto.PeerUtil, ...) (messages []*mtproto.MessageBox)
  • func (d *Dao) GetOffsetIdBackwardUnreadMentions(ctx context.Context, userId int64, peer *mtproto.PeerUtil, ...) (messages []*mtproto.MessageBox)
  • func (d *Dao) GetOffsetIdForwardHistoryMessages(ctx context.Context, userId int64, peer *mtproto.PeerUtil, ...) (messages []*mtproto.MessageBox)
  • func (d *Dao) GetOffsetIdForwardUnreadMentions(ctx context.Context, userId int64, peer *mtproto.PeerUtil, ...) (messages []*mtproto.MessageBox)
  • func (d *Dao) MakeMessageBox(ctx context.Context, selfUserId int64, do *dataobject.MessagesDO) (box *mtproto.MessageBox)
• type Mysql

Types

type Dao

type Dao struct {
	*Mysql
	sqlc.CachedConn
	Plugin plugin.MessagePlugin
}

Dao dao.

func New

func New(c config.Config, plugin plugin.MessagePlugin) *Dao

New new a dao and return.

func (*Dao) GetOffsetDateBackwardHistoryMessages

func (d *Dao) GetOffsetDateBackwardHistoryMessages(ctx context.Context, userId int64, peer *mtproto.PeerUtil, offsetDate, minId, maxId, limit int32, hash int64) (messages []*mtproto.MessageBox)

func (*Dao) GetOffsetDateForwardHistoryMessages

func (d *Dao) GetOffsetDateForwardHistoryMessages(ctx context.Context, userId int64, peer *mtproto.PeerUtil, offsetDate, minId, maxId, limit int32, hash int64) (messages []*mtproto.MessageBox)

func (*Dao) GetOffsetIdBackwardHistoryMessages

func (d *Dao) GetOffsetIdBackwardHistoryMessages(ctx context.Context, userId int64, peer *mtproto.PeerUtil, offsetId, minId, maxId, limit int32, hash int64) (messages []*mtproto.MessageBox)

GetOffsetIdBackwardHistoryMessages offset

func (*Dao) GetOffsetIdBackwardUnreadMentions

func (d *Dao) GetOffsetIdBackwardUnreadMentions(ctx context.Context, userId int64, peer *mtproto.PeerUtil, offsetId, minId, maxId, limit int32) (messages []*mtproto.MessageBox)

GetOffsetIdBackwardUnreadMentions GetOffsetIdBackwardUnreadMentions

func (*Dao) GetOffsetIdForwardHistoryMessages

func (d *Dao) GetOffsetIdForwardHistoryMessages(ctx context.Context, userId int64, peer *mtproto.PeerUtil, offsetId, minId, maxId, limit int32, hash int64) (messages []*mtproto.MessageBox)

func (*Dao) GetOffsetIdForwardUnreadMentions

func (d *Dao) GetOffsetIdForwardUnreadMentions(ctx context.Context, userId int64, peer *mtproto.PeerUtil, offsetId, minId, maxId, limit int32) (messages []*mtproto.MessageBox)

func (*Dao) MakeMessageBox

func (d *Dao) MakeMessageBox(ctx context.Context, selfUserId int64, do *dataobject.MessagesDO) (box *mtproto.MessageBox)

type Mysql

type Mysql struct {
	*sqlx.DB
	*mysql_dao.MessagesDAO
	*mysql_dao.HashTagsDAO
	*sqlx.CommonDAO
}