redis

Documentation

Index

• type Dao
  • func New(c *conf.Config) (dao *Dao)
  • func (d *Dao) Close()
  • func (d *Dao) CountPersonalTask(c context.Context, opt *common.BaseOptions) (count int64, err error)
  • func (d *Dao) DelMulti(c context.Context, keys ...string) (err error)
  • func (d *Dao) GetTask(c context.Context, ids []int64) (tasks []*modtask.Task, err error)
  • func (d *Dao) MGet(c context.Context, keys ...string) (dest []string, err error)
  • func (d *Dao) MoniRuleOids(c context.Context, id, min, max int64) (oidMap map[int64]int, err error)
  • func (d *Dao) MoniRuleStats(c context.Context, id, min, max int64) (stats *monitor.Stats, err error)
  • func (d *Dao) Ping(c context.Context) error
  • func (d *Dao) PopPublicTask(c context.Context, businessID, flowID, count int64) (ids []int64, err error)
  • func (d *Dao) PushDelayTask(c context.Context, opt *common.BaseOptions, ids ...interface{}) (err error)
  • func (d *Dao) PushPersonalTask(c context.Context, opt *common.BaseOptions, ids ...interface{}) (err error)
  • func (d *Dao) PushPublicTask(c context.Context, tasks ...*modtask.Task) (err error)
  • func (d *Dao) RangeDealyTask(c context.Context, opt *modtask.ListOptions) (tasks map[int64]*modtask.Task, count int64, hitids, missids []int64, err error)
  • func (d *Dao) RangePersonalTask(c context.Context, opt *modtask.ListOptions) (tasks map[int64]*modtask.Task, count int64, hitids, missids []int64, err error)
  • func (d *Dao) RangePublicTask(c context.Context, opt *modtask.ListOptions) (tasks map[int64]*modtask.Task, count int64, hitids, missids []int64, err error)
  • func (d *Dao) Release(c context.Context, opt *common.BaseOptions, delay bool) (err error)
  • func (d *Dao) RemoveDelayTask(c context.Context, opt *common.BaseOptions, ids ...interface{}) (err error)
  • func (d *Dao) RemovePersonalTask(c context.Context, opt *common.BaseOptions, ids ...interface{}) (err error)
  • func (d *Dao) RemovePublicTask(c context.Context, opt *common.BaseOptions, ids ...interface{}) (err error)
  • func (d *Dao) SeizeTask(c context.Context, businessID, flowID, uid, count int64) (hitids []int64, missids []int64, others map[int64]int64, err error)
  • func (d *Dao) SetMulti(c context.Context, kvs map[string]string) (err error)
  • func (d *Dao) SetTask(c context.Context, tasks ...*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) CountPersonalTask

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

CountPersonalTask 统计个数

func (*Dao) DelMulti

func (d *Dao) DelMulti(c context.Context, keys ...string) (err error)

DelMulti del redis keys

func (*Dao) GetTask

func (d *Dao) GetTask(c context.Context, ids []int64) (tasks []*modtask.Task, err error)

GetTask .

func (*Dao) MGet

func (d *Dao) MGet(c context.Context, keys ...string) (dest []string, err error)

MGet get multi key value

func (*Dao) MoniRuleOids

func (d *Dao) MoniRuleOids(c context.Context, id, min, max int64) (oidMap map[int64]int, err error)

MoniRuleOids 获取监控符合报警时长的

func (*Dao) MoniRuleStats

func (d *Dao) MoniRuleStats(c context.Context, id, min, max int64) (stats *monitor.Stats, err error)

MoniRuleStats 获取监控统计

func (*Dao) Ping

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

Ping dao ping

func (*Dao) PopPublicTask

func (d *Dao) PopPublicTask(c context.Context, businessID, flowID, count int64) (ids []int64, err error)

PopPublicTask 从实时任务池取出来

func (*Dao) PushDelayTask

func (d *Dao) PushDelayTask(c context.Context, opt *common.BaseOptions, ids ...interface{}) (err error)

PushDelayTask 延迟任务队列

func (*Dao) PushPersonalTask

func (d *Dao) PushPersonalTask(c context.Context, opt *common.BaseOptions, ids ...interface{}) (err error)

PushPersonalTask 放入本人任务池

func (*Dao) PushPublicTask

func (d *Dao) PushPublicTask(c context.Context, tasks ...*modtask.Task) (err error)

PushPublicTask 放入实时任务池

func (*Dao) RangeDealyTask

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

RangeDealyTask .

func (*Dao) RangePersonalTask

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

RangePersonalTask 从本人的任务池取

func (*Dao) RangePublicTask

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

RangePublicTask .

func (*Dao) Release

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

Release 清空个人任务 直接删除key

func (*Dao) RemoveDelayTask

func (d *Dao) RemoveDelayTask(c context.Context, opt *common.BaseOptions, ids ...interface{}) (err error)

RemoveDelayTask 延迟任务完成

func (*Dao) RemovePersonalTask

func (d *Dao) RemovePersonalTask(c context.Context, opt *common.BaseOptions, ids ...interface{}) (err error)

RemovePersonalTask 任务延迟或完成

func (*Dao) RemovePublicTask

func (d *Dao) RemovePublicTask(c context.Context, opt *common.BaseOptions, ids ...interface{}) (err error)

RemovePublicTask 移除

func (*Dao) SeizeTask

func (d *Dao) SeizeTask(c context.Context, businessID, flowID, uid, count int64) (hitids []int64, missids []int64, others map[int64]int64, err error)

SeizeTask .

func (*Dao) SetMulti

func (d *Dao) SetMulti(c context.Context, kvs map[string]string) (err error)

SetMulti setex key expire val, kvs as multi key val

func (*Dao) SetTask

func (d *Dao) SetTask(c context.Context, tasks ...*modtask.Task) (err error)

SetTask .