job

type Enqueuer struct {
	Handler GenericHandler
	// contains filtered or unexported fields
}

type Error struct {
	Execution uint   `json:"execution"`
	Message   string `json:"message"`
}

type GenericHandler func(args interface{}) error

type Job struct {
	ID          string         `json:"id"`               // Unique job ID
	Deployment  string         `json:"deployment"`       // Deployment used for scoping jobs.
	Type        string         `json:"type"`             // The type of job
	Status      Status         `json:"status"`           // The response of the current job with details for execution counts etc..
	State       State          `json:"state"`            // Current state of a job (running | complete)
	StartTime   int64          `json:"start_time_epoch"` // Job Start time - epoch in seconds since 1970
	EndTime     int64          `json:"end_time_epoch"`   // Job end time - epoch in seconds since 1970
	RetryPolicy uint           `json:"retry_policy"`     // Job retry policy
	Args        interface{}    `json:"-"`                // Arguments passed down to job handlers
	Setup       GenericHandler `json:"-"`                // Setup is the initial execution fn for a job typically to setup arguments
	Run         GenericHandler `json:"-"`                // Run is the main executor fn for a job
	Finally     GenericHandler `json:"-"`                // Final fn is the final execution fn for a job
}

type NJobs [][]Job

type SortOrder func(Job, Job) bool

type State string

type Status struct {
	ExecutionCount uint    `json:"execution_count"`
	FailureCount   uint    `json:"failure_count"`
	Failures       []Error `json:"failures"`
}

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

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

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