Package riverworkflow provides workflow helpers for River Pro's workflow engine.
Most of the core workflow functionality is exposed through the [riverpro.Workflow] type and in the [riverpro] package. See homepage and docs.
This section is empty.
This section is empty.
DepsFromJobRow extracts the dependency task names from a job row.
DepsFromMetadata extracts the dependency task names directly from a job's metadata.
IDFromJobRow extracts the workflow ID from a job row.
IDFromMetadata extracts the workflow ID directly from a job's metadata.
func JobListParams(job *rivertype.JobRow, params *river.JobListParams) (*river.JobListParams, error)
JobListParams extracts the workflow ID from a job row and returns a river.JobListParams with the workflow ID set in order to filter the job list by workflow.
func JobListParamsByID(workflowID string, params *river.JobListParams) (*river.JobListParams, error)
JobListParamsByID returns a river.JobListParams with the workflow ID set in order to filter the job list by workflow.
NameFromJobRow extracts the workflow's name from a job row.
NameFromMetadata extracts the workflow's name directly from a job's metadata.
TaskFromJobRow extracts the workflow task's name from a job row.
This section is empty.