CmdWrapper wraps command.

ContainsIntInIntSlice check whether int in the slice.

DefaultPath returns PATH variable.

DoApi REST calls via communicators.

DoApiCall for the jobs stages TODO: add custom headers.

GetAPIParamsFromSection of the configuration.

GetParamsFromSection from stage & with sub-param Example stage = `jobs.logstream` and param `params` in the following config: with `GetParamsFromSection("jobs.logstream", "params")` var yamlExample = []byte(` jobs: logstream: &update url: "localhost" method: post params: "job_uid": "job_uid" "run_uid": "1".

GetSliceParamsFromSection from stage & with sub-param Example stage = `jobs.logstream` and param `params` in the following config: with `GetParamsFromSection("jobs.logstream", "resend-params")` var yamlExample = []byte(` jobs: logstream: &update url: "localhost" method: post resend-params: - "job_uid" - "run_uid" - "extra_run_id".

IsTerminalStatus returns true if status is terminal: - Failed - Canceled - Successful.

MergeEnvVars merges enviroments variables.

NewJob return Job with defaults.

Returns new Processes Tree.

NewRegistry returns a new Registry.

NewRemoteApiRequest perform request to API.

NewTestJob return Job with defaults for test.

ReinitializeConfig on load or config file changes.

StoreKey returns Job unique store key.

FetchNewJobAPIMethod is Http METHOD for fetch Jobs API.

FetchNewJobAPIParams is used in eqch requesto for a new job.

FetchNewJobAPIURL is URL for pulling new jobs.

StreamingAPIMethod is Http METHOD for streaming log API.

StreamingAPIURL is URL for uploading log steams.

Job public structure.

Process stores information about a UNIX process.

Registry holds all Job Records.

Tree is a tree of processes.

Jobber defines a job interface.