block

Documentation

Index

• type Dao
  • func New(conf *conf.Config, mc *memcache.Pool, db *xsql.DB, client *bm.Client, ...) (dao *Dao)
  • func (d *Dao) AccountNotify(c context.Context, mid int64) (err error)
  • func (d *Dao) BeginTX(c context.Context) (tx *xsql.Tx, err error)
  • func (d *Dao) Close()
  • func (d *Dao) DeleteUserCache(c context.Context, mid int64) (err error)
  • func (d *Dao) InsertExtra(c context.Context, ex *model.DBExtra) (err error)
  • func (d *Dao) Ping(c context.Context) (err error)
  • func (d *Dao) SendSysMsg(c context.Context, code string, mids []int64, title string, content string, ...) (err error)
  • func (d *Dao) SetSyncBlockTypeID(c context.Context, id int64) (err error)
  • func (d *Dao) SyncBlockTypeID(c context.Context) (id int64, err error)
  • func (d *Dao) TxInsertHistory(c context.Context, tx *xsql.Tx, h *model.DBHistory) (err error)
  • func (d *Dao) TxUpsertExtra(c context.Context, tx *xsql.Tx, ex *model.DBExtra) (err error)
  • func (d *Dao) TxUpsertUser(c context.Context, tx *xsql.Tx, mid int64, status model.BlockStatus) (count int64, err error)
  • func (d *Dao) UpsertAddBlockCount(c context.Context, mid int64) (err error)
  • func (d *Dao) UserExtra(c context.Context, mid int64) (ex *model.DBExtra, err error)
  • func (d *Dao) UserLastHistory(c context.Context, mid int64) (his *model.DBHistory, err error)
  • func (d *Dao) UserStatusList(c context.Context, status model.BlockStatus, startID int64, limit int) (maxID int64, mids []int64, err error)

Types

type Dao

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

Dao dao

func New

func New(conf *conf.Config, mc *memcache.Pool, db *xsql.DB, client *bm.Client, notifyFunc notifyFunc) (dao *Dao)

New init mysql db

func (*Dao) AccountNotify

func (d *Dao) AccountNotify(c context.Context, mid int64) (err error)

AccountNotify is

func (*Dao) BeginTX

func (d *Dao) BeginTX(c context.Context) (tx *xsql.Tx, err error)

BeginTX is.

func (*Dao) Close

func (d *Dao) Close()

Close close the resource.

func (*Dao) DeleteUserCache

func (d *Dao) DeleteUserCache(c context.Context, mid int64) (err error)

DeleteUserCache is.

func (*Dao) InsertExtra

func (d *Dao) InsertExtra(c context.Context, ex *model.DBExtra) (err error)

InsertExtra is.

func (*Dao) Ping

func (d *Dao) Ping(c context.Context) (err error)

Ping dao ping

func (*Dao) SendSysMsg

func (d *Dao) SendSysMsg(c context.Context, code string, mids []int64, title string, content string, remoteIP string) (err error)

SendSysMsg send sys msg.

func (*Dao) SetSyncBlockTypeID

func (d *Dao) SetSyncBlockTypeID(c context.Context, id int64) (err error)

SetSyncBlockTypeID is.

func (*Dao) SyncBlockTypeID

func (d *Dao) SyncBlockTypeID(c context.Context) (id int64, err error)

SyncBlockTypeID is.

func (*Dao) TxInsertHistory

func (d *Dao) TxInsertHistory(c context.Context, tx *xsql.Tx, h *model.DBHistory) (err error)

TxInsertHistory is.

func (*Dao) TxUpsertExtra

func (d *Dao) TxUpsertExtra(c context.Context, tx *xsql.Tx, ex *model.DBExtra) (err error)

TxUpsertExtra is.

func (*Dao) TxUpsertUser

func (d *Dao) TxUpsertUser(c context.Context, tx *xsql.Tx, mid int64, status model.BlockStatus) (count int64, err error)

TxUpsertUser is.

func (*Dao) UpsertAddBlockCount

func (d *Dao) UpsertAddBlockCount(c context.Context, mid int64) (err error)

UpsertAddBlockCount is.

func (*Dao) UserExtra

func (d *Dao) UserExtra(c context.Context, mid int64) (ex *model.DBExtra, err error)

UserExtra is.

func (*Dao) UserLastHistory

func (d *Dao) UserLastHistory(c context.Context, mid int64) (his *model.DBHistory, err error)

UserLastHistory is.

func (*Dao) UserStatusList

func (d *Dao) UserStatusList(c context.Context, status model.BlockStatus, startID int64, limit int) (maxID int64, mids []int64, err error)

UserStatusList is.