redis

Documentation

Index

• Constants
• type Driver
  • func NewDriver(server string) Driver
  • func (r Driver) Close() error
  • func (r Driver) Delete(jobID int64) (err error)
  • func (r Driver) Get(jobID int64) (job driver.Job, err error)
  • func (r Driver) GetOne(Func string, jobName string) (job driver.Job, err error)
  • func (r Driver) NewIterator(Func []byte) driver.Iterator
  • func (r Driver) Save(job *driver.Job, force ...bool) (err error)
• type Iterator
  • func (iter *Iterator) Close()
  • func (iter *Iterator) Error() error
  • func (iter *Iterator) Next() bool
  • func (iter *Iterator) Value() driver.Job

Constants

const PREFIX = "periodic:job:"

PREFIX the redis key prefix

Types

type Driver

type Driver struct {
	RWLocker *sync.Mutex
	// contains filtered or unexported fields
}

Driver define a redis store driver

func NewDriver

func NewDriver(server string) Driver

NewDriver create a redis driver

func (Driver) Close

func (r Driver) Close() error

Close the redis driver

func (Driver) Delete

func (r Driver) Delete(jobID int64) (err error)

Delete a job with job id.

func (Driver) Get

func (r Driver) Get(jobID int64) (job driver.Job, err error)

Get a job with job id.

func (Driver) GetOne

func (r Driver) GetOne(Func string, jobName string) (job driver.Job, err error)

GetOne get a job with func and name.

func (Driver) NewIterator

func (r Driver) NewIterator(Func []byte) driver.Iterator

NewIterator create a job Iterator with func or nil.

func (Driver) Save

func (r Driver) Save(job *driver.Job, force ...bool) (err error)

Save job. when job is exists update it, other create one.

type Iterator

type Iterator struct {
	Func []byte
	// contains filtered or unexported fields
}

Iterator define the job iterator

func (*Iterator) Close

func (iter *Iterator) Close()

Close the iterator

func (*Iterator) Error

func (iter *Iterator) Error() error

Error returns the current error.

func (*Iterator) Next

func (iter *Iterator) Next() bool

Next advances the iterator to the next value, which will then be available through then the Value method. It returns false if no further advancement is possible.

func (*Iterator) Value

func (iter *Iterator) Value() driver.Job

Value returns the current job.