redis

Documentation

Index

• Variables
• type DB
  • func New(address string, password redis.DialOption, sendPassword bool) *DB
  • func (d DB) Close() error
  • func (d DB) Delete(id string) error
  • func (d DB) Get(id string) (*job.Job, error)
  • func (d DB) GetAll() ([]*job.Job, error)
  • func (d DB) Save(j *job.Job) error

Variables

var (
	// HashKey is the hash key where jobs are persisted.
	HashKey = "kala:jobs"
)

Types

type DB

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

DB is concrete implementation of the JobDB interface, that uses Redis for persistence.

func New

func New(address string, password redis.DialOption, sendPassword bool) *DB

New instantiates a new DB.

func (DB) Close

func (d DB) Close() error

Close closes the connection to Redis.

func (DB) Delete

func (d DB) Delete(id string) error

Delete deletes a persisted Job.

func (DB) Get

func (d DB) Get(id string) (*job.Job, error)

Get returns a persisted Job.

func (DB) GetAll

func (d DB) GetAll() ([]*job.Job, error)

GetAll returns all persisted Jobs.

func (DB) Save

func (d DB) Save(j *job.Job) error

Save persists a Job.