runner

Documentation

Index

• type JHF
  • func (jhf JHF) Run(job *Job) *model.JobR
• type Job
• type JobHandler
• type PanicHandler
• type Runner
  • func New(namespace string, model model.Model) *Runner
  • func (r *Runner) AddJobHandler(jobType string, handler JobHandler) error
  • func (r *Runner) Namespace() string
  • func (r *Runner) RunJob(job *model.Job, logger logger.Logger) (jr *model.JobR)
  • func (r *Runner) SetPanicHandler(panicHandler PanicHandler)

Types

type JHF

type JHF func(job *Job) *model.JobR

func (JHF) Run

func (jhf JHF) Run(job *Job) *model.JobR

Run AFAIRE.

type Job

type Job struct {
	*model.Job
	Logger  logger.Logger
	Factory *factory.Factory
}

Job AFAIRE.

type JobHandler

type JobHandler interface {
	Run(job *Job) *model.JobR
}

JobHandler AFAIRE.

type PanicHandler

type PanicHandler func(job *model.Job, logger logger.Logger, data interface{}, stack []byte) *model.JobR

PanicHandler AFAIRE.

type Runner

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

Runner AFAIRE.

func New

func New(namespace string, model model.Model) *Runner

New AFAIRE.

func (*Runner) AddJobHandler

func (r *Runner) AddJobHandler(jobType string, handler JobHandler) error

AddJobHandler AFAIRE.

func (*Runner) Namespace

func (r *Runner) Namespace() string

Namespace AFAIRE.

func (*Runner) RunJob

func (r *Runner) RunJob(job *model.Job, logger logger.Logger) (jr *model.JobR)

RunJob AFAIRE.

func (*Runner) SetPanicHandler

func (r *Runner) SetPanicHandler(panicHandler PanicHandler)

SetPanicHandler AFAIRE.