runner

Documentation

Index

• func HandleExecute(ctx web.Context) error
• func HandleSplit(ctx web.Context) error
• func Register(name string, handler Handler)
• func RegisterFunc(name string, handler func(job *contract.Job) error)
• func Serve(ws *web.Server) func(ctx *app.Context) error
• type Handler
• type HandlerFunc
  • func (f HandlerFunc) Handle(job *contract.Job) error
• type ParallelHandler
• type PostFilter
• type PreFilter

Functions

func HandleExecute

func HandleExecute(ctx web.Context) error

func HandleSplit

func HandleSplit(ctx web.Context) error

func Register

func Register(name string, handler Handler)

func RegisterFunc

func RegisterFunc(name string, handler func(job *contract.Job) error)

func Serve

func Serve(ws *web.Server) func(ctx *app.Context) error

Types

type Handler

type Handler interface {
	Handle(job *contract.Job) error
}

type HandlerFunc

type HandlerFunc func(job *contract.Job) error

func (HandlerFunc) Handle

func (f HandlerFunc) Handle(job *contract.Job) error

type ParallelHandler

type ParallelHandler interface {
	Handler
	Split(job *contract.Job) ([]*contract.Batch, error)
}

type PostFilter

type PostFilter func(job *contract.Job, err error)

type PreFilter

type PreFilter func(job *contract.Job) error