job

package

v0.4.0-alpha Latest Latest Go to latest Published: Apr 29, 2019 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

func Add(j jobber)

func Dispatch(j jobber) error

func Process(jobName string)

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

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

func (j *Job) Name() string

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

func (j *Job) Retries() uint32

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