From creates []GetterFunc from a mix of getters or bare values.

Input creates a getter returning inputs[index] value, or error if index is out of range.

Inputs creates a getter returning array of Result.Value (or Result.Error where not nil).

JSONWithVarExprs creates a getter that unmarshals jsExpr string as JSON, and interpolates all variables expressions found in jsExpr from Vars.

NewInterval creates Interval for specified duration.

NewJSONPathParam returns a new JSONPathParam using the given separator, or the default if empty.

NewKeypathFromString creates a new Keypath from the given string.

NewMaybeBigIntParam creates a new instance of MaybeBigIntParam.

NewMaybeInt32Param creates new instance of MaybeInt32Param.

NewMaybeUint64Param creates new instance of MaybeUint64Param.

NewRestrictedHTTPClient returns a secure HTTP Client (queries to certain local addresses are blocked).

NewUnrestrictedClient returns a HTTP Client with no Transport restrictions.

NewVarsFrom creates new Vars from the given map.

NonemptyString creates a getter to ensure the string is non-empty.

ValidDurationInSeconds creates a getter to ensure the string is a valid duration and return duration in seconds.

VarExpr creates a getter interpolating expr value using the given Vars.

RunStatusCompleted is used for when a run has successfully completed execution.

RunStatusErrored is used for when a run has errored and will not complete.

RunStatusRunning is used for when a run is actively being executed.

RunStatusSuspended is used when a run is paused and awaiting further results.

RunStatusUnknown is the when the run status cannot be determined.

Duration is a non-negative time duration.

When a task panics, we catch the panic and wrap it in an error for reporting to the scheduler.

FinalResult is the result of a Run.

tree fulfills the graph.DirectedGraph interface, which makes it possible for us to `dot.Unmarshal(...)` a DOT string directly into it.

HTTPRequest holds the request and Config struct for a http request.

HTTPRequestConfig holds the configurable settings for a http request.

Keypath contains keypath parsed by NewKeypathFromString.

ObjectParam represents a kind of any type that could be used by the memo task.

Result is the result of a TaskRun.

RunInfo contains additional information about the finished TaskRun.

Wraps the input Task for the given dependent task along with a bool variable PropagateResult, which Indicates whether result of InputTask should be propagated to its dependent task.

TaskRunResult describes the result of a task run, suitable for database update or insert.

ConfigTask.

GetterFunc is a function that either returns a value or an error.

InitTask.

Interval represents a time.Duration stored as a Postgres interval type.

MapParam accepts maps or JSON-encoded strings.

RunStatus represents the status of a run.

TaskRunResults represents a collection of results for all task runs for one pipeline run.