schedule

Documentation

Index

• func RegisterSchedule(name string, builder func(*config.Config) Schedule)
• type ChanSchedule
  • func (d *ChanSchedule) Close()
  • func (d *ChanSchedule) Count() int
  • func (d *ChanSchedule) Pop() (*model.Request, bool)
  • func (d *ChanSchedule) Push(req *model.Request)
  • func (d *ChanSchedule) PushMulti(reqs []*model.Request)
• type RedisSchedule
  • func (r *RedisSchedule) Close()
  • func (r *RedisSchedule) Count() int
  • func (r *RedisSchedule) CronCount(flushTime int)
  • func (r *RedisSchedule) Pop() (*model.Request, bool)
  • func (r *RedisSchedule) Push(req *model.Request)
  • func (r *RedisSchedule) PushMulti(reqs []*model.Request)
• type Schedule
  • func GetSchedule(c *config.Config) Schedule
  • func NewChanSchedule(config *config.Config) Schedule
  • func NewRedisSchedule(config *config.Config) Schedule

Functions

func RegisterSchedule

func RegisterSchedule(name string, builder func(*config.Config) Schedule)

Types

type ChanSchedule

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

func (*ChanSchedule) Close

func (d *ChanSchedule) Close()

func (*ChanSchedule) Count

func (d *ChanSchedule) Count() int

func (*ChanSchedule) Pop

func (d *ChanSchedule) Pop() (*model.Request, bool)

func (*ChanSchedule) Push

func (d *ChanSchedule) Push(req *model.Request)

func (*ChanSchedule) PushMulti

func (d *ChanSchedule) PushMulti(reqs []*model.Request)

type RedisSchedule

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

func (*RedisSchedule) Close

func (r *RedisSchedule) Close()

func (*RedisSchedule) Count

func (r *RedisSchedule) Count() int

func (*RedisSchedule) CronCount

func (r *RedisSchedule) CronCount(flushTime int)

func (*RedisSchedule) Pop

func (r *RedisSchedule) Pop() (*model.Request, bool)

func (*RedisSchedule) Push

func (r *RedisSchedule) Push(req *model.Request)

func (*RedisSchedule) PushMulti

func (r *RedisSchedule) PushMulti(reqs []*model.Request)

type Schedule

type Schedule interface {
	Push(req *model.Request)
	PushMulti(reqs []*model.Request)
	Pop() (*model.Request, bool)
	Count() int
	Close()
}

func GetSchedule

func GetSchedule(c *config.Config) Schedule

func NewChanSchedule

func NewChanSchedule(config *config.Config) Schedule

func NewRedisSchedule

func NewRedisSchedule(config *config.Config) Schedule