dao

Documentation

Index

• type Dao
  • func New(c *conf.Config) (d *Dao)
  • func (d *Dao) AddTaskInfoCache(c context.Context, mid int64, ti *model.TaskInfo) (err error)
  • func (d *Dao) BeginTran(c context.Context) (*xsql.Tx, error)
  • func (d *Dao) Close()
  • func (d *Dao) DetailTask(c context.Context, taskID int64) (t *model.Task, err error)
  • func (d *Dao) Ping(c context.Context) (err error)
  • func (d *Dao) QueryTaskID(c context.Context, mid int64) (taskID int64, err error)
  • func (d *Dao) QueryUndoneTaskInfo(c context.Context, mid int64) (t *model.TaskInfo, err error)
  • func (d *Dao) RemoveTaskInfoCache(c context.Context, mid int64) (err error)
  • func (d *Dao) SendEmail(subject string, to string, body string) (err error)
  • func (d *Dao) TaskInfoCache(c context.Context, mid int64) (ti *model.TaskInfo, err error)
  • func (d *Dao) TxAddTaskLog(c context.Context, tx *xsql.Tx, taskID int64, mid int64, build string, ...) (insertID int64, err error)
  • func (d *Dao) TxUpdateTaskState(c context.Context, tx *xsql.Tx, state int, taskID int64) (rows int64, err error)

Types

type Dao

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

func New

func New(c *conf.Config) (d *Dao)

func (*Dao) AddTaskInfoCache

func (d *Dao) AddTaskInfoCache(c context.Context, mid int64, ti *model.TaskInfo) (err error)

AddTaskInfoCache add taskInfo cache

func (*Dao) BeginTran

func (d *Dao) BeginTran(c context.Context) (*xsql.Tx, error)

BeginTran BeginTran.

func (*Dao) Close

func (d *Dao) Close()

func (*Dao) DetailTask

func (d *Dao) DetailTask(c context.Context, taskID int64) (t *model.Task, err error)

func (*Dao) Ping

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

func (*Dao) QueryTaskID

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

func (*Dao) QueryUndoneTaskInfo

func (d *Dao) QueryUndoneTaskInfo(c context.Context, mid int64) (t *model.TaskInfo, err error)

func (*Dao) RemoveTaskInfoCache

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

RemoveTaskInfoCache remove taskInfo cache

func (*Dao) SendEmail

func (d *Dao) SendEmail(subject string, to string, body string) (err error)

func (*Dao) TaskInfoCache

func (d *Dao) TaskInfoCache(c context.Context, mid int64) (ti *model.TaskInfo, err error)

TaskInfoCache get taskInfo cache

func (*Dao) TxAddTaskLog

func (d *Dao) TxAddTaskLog(c context.Context, tx *xsql.Tx, taskID int64, mid int64, build string, platform int, taskState int, reason string) (insertID int64, err error)

func (*Dao) TxUpdateTaskState

func (d *Dao) TxUpdateTaskState(c context.Context, tx *xsql.Tx, state int, taskID int64) (rows int64, err error)