job

package
v1.0.18 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 13, 2020 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Add

func Add(j jobber)

func Dispatch

func Dispatch(j jobber) 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

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

default retry 3 times

func (*Job) SetDelay

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

default no delay

func (*Job) SetParam

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL