task_api

type Action ¶

type Action interface {
	Handle(arg string, log io.Writer) error
}

type Job ¶

type Job struct {
	Id          string
	PlanName    string
	Arg         string
	State       string
	Final       bool
	Error       bool
	StartedAt   int64
	CompletedAt int64
	Logs        []JobLogEntry
}

A Job holds the runtime state of a specific job.

func NewJob(plan *Plan, arg string) *Job

func (j *Job) Log(msg string)

type JobLogEntry ¶

type JobLogEntry struct {
	Stamp int64
	Msg   string
}

type Plan ¶

type Plan struct {
	Name         string
	InitialState string
	M            map[string]StateMachineOutput
}

A Plan is a declarative definition of a finite state machine, expressed in terms of the possible state transitions. There is only one final state and it's represented by the empty string.

func NewPlan(name string, initialState string, planMap map[string][]string) *Plan

type StateMachineOutput ¶

type StateMachineOutput struct {
	Ok  string
	Err string
}