jobber

Documentation

Index

• type Handler
• type Jobber
• type RedisJobber
  • func (p *RedisJobber) Push(queue string, args interface{}) error
  • func (p *RedisJobber) Register(queue string, handler Handler)
  • func (p *RedisJobber) Start() error

Types

type Handler

type Handler func(args []byte) error

Handler job handler

type Jobber

type Jobber interface {
	Push(queue string, args interface{}) error
	Register(queue string, handler Handler)
	Start() error
}

Jobber background job

type RedisJobber

type RedisJobber struct {
	Redis  *redis.Pool     `inject:""`
	Logger *logging.Logger `inject:""`

	Timeout  int
	Handlers map[string]Handler
}

RedisJobber job by readis store

func (*RedisJobber) Push

func (p *RedisJobber) Push(queue string, args interface{}) error

Push add a job task

func (*RedisJobber) Register

func (p *RedisJobber) Register(queue string, handler Handler)

Register register a job-handler

func (*RedisJobber) Start

func (p *RedisJobber) Start() error

Start start to process job