mysql

Documentation

Index

• type Dao
  • func New(c *conf.Config) (dao *Dao)
  • func (d *Dao) Close()
  • func (d *Dao) ConsumerOff(c context.Context, opt *common.BaseOptions) (err error)
  • func (d *Dao) ConsumerOn(c context.Context, opt *common.BaseOptions) (err error)
  • func (d *Dao) ConsumerStat(c context.Context, bizid, flowid int64) (items []*modtask.WatchItem, err error)
  • func (d *Dao) CountPersonal(c context.Context, opt *common.BaseOptions) (count int64, err error)
  • func (d *Dao) DBDispatch(c context.Context, opt *modtask.NextOptions) (tasks []*modtask.Task, count int64, err error)
  • func (d *Dao) Delay(c context.Context, opt *modtask.DelayOptions) (rows int64, err error)
  • func (d *Dao) DispatchByID(c context.Context, mtasks map[int64]*modtask.Task, ids []int64, ...) (missids map[int64]struct{}, err error)
  • func (d *Dao) IsConsumerOn(c context.Context, opt *common.BaseOptions) (on bool, err error)
  • func (d *Dao) ListCheckDelay(c context.Context, mtasks map[int64]*modtask.Task, ids []int64, ...) (missids map[int64]struct{}, err error)
  • func (d *Dao) ListCheckSeized(c context.Context, mtasks map[int64]*modtask.Task, ids []int64, ...) (missids map[int64]struct{}, err error)
  • func (d *Dao) ListCheckUnSeized(c context.Context, mtasks map[int64]*modtask.Task, ids []int64, ...) (missids map[int64]struct{}, err error)
  • func (d *Dao) ListTasks(c context.Context, opt *modtask.ListOptions) (tasks []*modtask.Task, count int64, err error)
  • func (d *Dao) MoniBizRules(c context.Context, bid int64) (rules []*monitor.Rule, err error)
  • func (d *Dao) MoniRule(c context.Context, rid int64) (rule *monitor.Rule, err error)
  • func (d *Dao) Onlines(c context.Context, opt *common.BaseOptions) (uids map[int64]time.Time, err error)
  • func (d *Dao) Ping(c context.Context) error
  • func (d *Dao) QueryForSeize(c context.Context, businessID, flowID, uid, seizecount int64) (hitids []int64, err error)
  • func (d *Dao) QueryTask(c context.Context, state int8, mtime time.Time, id, limit int64) (tasks []*modtask.Task, lastid int64, err error)
  • func (d *Dao) Release(c context.Context, opt *common.BaseOptions, delay bool) (rows int64, err error)
  • func (d *Dao) Seize(c context.Context, mapids map[int64]int64) (count int64, err error)
  • func (d *Dao) TaskFromDB(c context.Context, id int64) (task *modtask.Task, err error)

Types

type Dao

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

Dao dao

func New

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

New init mysql db

func (*Dao) Close

func (d *Dao) Close()

Close close the resource.

func (*Dao) ConsumerOff

func (d *Dao) ConsumerOff(c context.Context, opt *common.BaseOptions) (err error)

ConsumerOff .

func (*Dao) ConsumerOn

func (d *Dao) ConsumerOn(c context.Context, opt *common.BaseOptions) (err error)

ConsumerOn .

func (*Dao) ConsumerStat

func (d *Dao) ConsumerStat(c context.Context, bizid, flowid int64) (items []*modtask.WatchItem, err error)

ConsumerStat 24小时内有活动或者在线的用户

func (*Dao) CountPersonal

func (d *Dao) CountPersonal(c context.Context, opt *common.BaseOptions) (count int64, err error)

CountPersonal count personal task

func (*Dao) DBDispatch

func (d *Dao) DBDispatch(c context.Context, opt *modtask.NextOptions) (tasks []*modtask.Task, count int64, err error)

DBDispatch 直接数据库派遣

func (*Dao) Delay

func (d *Dao) Delay(c context.Context, opt *modtask.DelayOptions) (rows int64, err error)

Delay 延迟任务

func (*Dao) DispatchByID

func (d *Dao) DispatchByID(c context.Context, mtasks map[int64]*modtask.Task, ids []int64, args ...interface{}) (missids map[int64]struct{}, err error)

DispatchByID 派遣任务,更新gtime

func (*Dao) IsConsumerOn

func (d *Dao) IsConsumerOn(c context.Context, opt *common.BaseOptions) (on bool, err error)

IsConsumerOn .

func (*Dao) ListCheckDelay

func (d *Dao) ListCheckDelay(c context.Context, mtasks map[int64]*modtask.Task, ids []int64, args ...interface{}) (missids map[int64]struct{}, err error)

ListCheckDelay .

func (*Dao) ListCheckSeized

func (d *Dao) ListCheckSeized(c context.Context, mtasks map[int64]*modtask.Task, ids []int64, args ...interface{}) (missids map[int64]struct{}, err error)

ListCheckSeized .

func (*Dao) ListCheckUnSeized

func (d *Dao) ListCheckUnSeized(c context.Context, mtasks map[int64]*modtask.Task, ids []int64, args ...interface{}) (missids map[int64]struct{}, err error)

ListCheckUnSeized .

func (*Dao) ListTasks

func (d *Dao) ListTasks(c context.Context, opt *modtask.ListOptions) (tasks []*modtask.Task, count int64, err error)

ListTasks .

func (*Dao) MoniBizRules

func (d *Dao) MoniBizRules(c context.Context, bid int64) (rules []*monitor.Rule, err error)

MoniBizRules 获取监控业务的所有配置

func (*Dao) MoniRule

func (d *Dao) MoniRule(c context.Context, rid int64) (rule *monitor.Rule, err error)

MoniRule 根据id获取监控规则

func (*Dao) Onlines

func (d *Dao) Onlines(c context.Context, opt *common.BaseOptions) (uids map[int64]time.Time, err error)

Onlines 在线列表

func (*Dao) Ping

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

Ping dao ping

func (*Dao) QueryForSeize

func (d *Dao) QueryForSeize(c context.Context, businessID, flowID, uid, seizecount int64) (hitids []int64, err error)

QueryForSeize 查询当前可抢占的任务

func (*Dao) QueryTask

func (d *Dao) QueryTask(c context.Context, state int8, mtime time.Time, id, limit int64) (tasks []*modtask.Task, lastid int64, err error)

QueryTask .

func (*Dao) Release

func (d *Dao) Release(c context.Context, opt *common.BaseOptions, delay bool) (rows int64, err error)

Release 释放任务

func (*Dao) Seize

func (d *Dao) Seize(c context.Context, mapids map[int64]int64) (count int64, err error)

Seize 抢占任务

func (*Dao) TaskFromDB

func (d *Dao) TaskFromDB(c context.Context, id int64) (task *modtask.Task, err error)

TaskFromDB .