Documentation ¶
Index ¶
Constants ¶
View Source
const ( STEP_VALIDATE_INPUT = "validate-input.json" STEP_VALIDATE_OUTPUT = "validate-output.json" )
Variables ¶
This section is empty.
Functions ¶
func ListProcessors ¶
* An abstract "Processor" actually processes a Task or an Event. Given a * list of base paths, each subdirectory defines a task action or an event * handler. If two base paths contain the same subdir name, the processor * counts as one.
Types ¶
type Processor ¶
type Processor struct { Status string `json:"status"` Progress int `json:"progress"` Steps []Step `json:"-"` }
func CreateEventHandler ¶
func CreateOneStepProcessor ¶
func CreateTaskProcessor ¶
func (*Processor) SetProgressAtStep ¶
func (*Processor) SetStepWeight ¶
type Task ¶
type Task struct { ID string `json:"id" structs:"id"` Action string `json:"action" structs:"action"` Data interface{} `json:"data" structs:"data"` Extra interface{} `json:"extra" structs:"extra"` Queue string `json:"queue" structs:"queue"` User string `json:"user" structs:"user"` Timestamp time.Time `json:"timestamp" structs:"timestamp"` Parent string `json:"parent" structs:"parent"` }
Click to show internal directories.
Click to hide internal directories.