job

Documentation

Index

• type Job
  • func (j Job) Process() error
  • func (j Job) Result(err error)
  • func (j Job) String() string

Types

type Job

type Job struct {
	Name       string
	Wg         *sync.WaitGroup
	Rnd        *rand.Rand
	Event      *common.MapStr
	JobQueue   chan worker.Job
	RandomFail bool
	Retries    int
	Attempts   int
}

Job represents the job to be run

func (Job) Process

func (j Job) Process() error

func (Job) Result

func (j Job) Result(err error)

func (Job) String

func (j Job) String() string