work

Documentation

Index

• func Add(j worker)
• func Dispatch(j worker) error
• func Process(jobName string)
• func RegisterQueue()
• type Job
  • func (j *Job) Delay() zone.Duration
  • func (j *Job) Handle(paramPtr proto.Message) error
  • func (j *Job) Name() string
  • func (j *Job) ParamProto() proto.Message
  • func (j *Job) Retries() uint32
  • func (j *Job) SetDelay(delay zone.Duration)
  • func (j *Job) SetParam(paramPtr proto.Message)

Functions

func Add

func Add(j worker)

func Dispatch

func Dispatch(j worker) error

func Process

func Process(jobName string)

func RegisterQueue

func RegisterQueue()

Types

type Job

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

func (*Job) Delay

func (j *Job) Delay() zone.Duration

Delay default no delay

func (*Job) Handle

func (j *Job) Handle(paramPtr proto.Message) error

func (*Job) Name

func (j *Job) Name() string

func (*Job) ParamProto

func (j *Job) ParamProto() proto.Message

func (*Job) Retries

func (j *Job) Retries() uint32

Retries default retry 3 times

func (*Job) SetDelay

func (j *Job) SetDelay(delay zone.Duration)

SetDelay default no delay

func (*Job) SetParam

func (j *Job) SetParam(paramPtr proto.Message)