taskmanager

type DataStore interface {
	LoadWorkflowRunner(string) (workflow.Runner, error)
	DumpWorkflowRunner(workflow.Runner) error
	LoadWorkflow(string) (workflow.Workflow, error)
}

type JobManager struct {
	// Map job aliases to functions providing that job.
	// Jobs receive a notification providing data from the queue and return
	// maps for json to handle
	JobList map[string]func(JobNotification) (map[string]interface{}, error)
}

type JobNotification struct {
	Context  map[string]string
	Name     string
	Register string
	Type     string
	UUID     string
}

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

type TaskManager interface {
	Consume(string) (map[string]interface{}, error)
}