store

Documentation

Index

• type Option
  • func Logger(s logger.Logger) Option
  • func Name(s string) Option
• type Options
  • func DefaultOptions() Options
• type Store

Types

type Option

type Option func(o *Options)

Option Option

func Logger

func Logger(s logger.Logger) Option

func Name

func Name(s string) Option

type Options

type Options struct {
	Name   string
	Logger logger.Logger
}

func DefaultOptions

func DefaultOptions() Options

DefaultOptions default options

type Store

type Store interface {
	Push(t *task.Task) error   //添加任务
	Pop(t *task.Task) error    //剔除任务
	Clear(key string) error    //清空任务
	Update(t *task.Task) error //更新任务--重复调用Push其实就是update了。感觉这个有点多余
	//获取单个执行任务。
	ReadTask(key string) (*task.Task, error)

	//拉取所有任务队列.返回任务名称
	FetchJob(step int64) ([]string, error)
}

type Store struct {
	store StoreInterface
}