runner

Documentation

Index

• func Wrap(j interface{}) job.Interface
• type RedisJob
  • func NewRedisJob(job interface{}, ctx *env.Context, ctl lcm.Controller) *RedisJob
  • func (rj *RedisJob) Run(j *work.Job) (err error)

Functions

func Wrap

func Wrap(j interface{}) job.Interface

Wrap returns a new job.Interface based on the wrapped job handler reference.

Types

type RedisJob

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

RedisJob is a job wrapper to wrap the job.Interface to the style which can be recognized by the redis worker.

func NewRedisJob

func NewRedisJob(job interface{}, ctx *env.Context, ctl lcm.Controller) *RedisJob

NewRedisJob is constructor of RedisJob

func (*RedisJob) Run

func (rj *RedisJob) Run(j *work.Job) (err error)

Run the job