storage

Documentation

Index

• func New(rdc *redis.Client, opts ...store.Option) store.Store
• type Redis
  • func (e *Redis) Clear(key string) error
  • func (e *Redis) FetchJob(step int64) ([]string, error)
  • func (e *Redis) Pop(t *task.Task) error
  • func (e *Redis) Push(t *task.Task) error
  • func (e *Redis) ReadTask(key string) (*task.Task, error)
  • func (e *Redis) Update(t *task.Task) error
• type RedisConfig

Functions

func New

func New(rdc *redis.Client, opts ...store.Option) store.Store

Types

type Redis

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

func (*Redis) Clear

func (e *Redis) Clear(key string) error

redis里面，有序集合新增，即可实现update

func (*Redis) FetchJob

func (e *Redis) FetchJob(step int64) ([]string, error)

func (*Redis) Pop

func (e *Redis) Pop(t *task.Task) error

func (*Redis) Push

func (e *Redis) Push(t *task.Task) error

添加任务

func (*Redis) ReadTask

func (e *Redis) ReadTask(key string) (*task.Task, error)

func (*Redis) Update

func (e *Redis) Update(t *task.Task) error

redis里面，有序集合新增，即可实现update

type RedisConfig

type RedisConfig struct {
}

预留redis的配置