JobRunner.hpp File Reference

#include "reusex/core/stages.hpp"
#include "reusex/pipeline/stages.hpp"
#include <chrono>
#include <cstddef>
#include <cstdint>
#include <filesystem>
#include <functional>
#include <memory>
#include <mutex>
#include <optional>
#include <string>
#include <string_view>
#include <vector>

Include dependency graph for JobRunner.hpp:

Go to the source code of this file.

Classes
struct	reusex::pipeline::JobRecord
	A job as reported by the runner. Snapshot; never a live view. More...
struct	reusex::pipeline::JobEvent
	One notification about a job. More...
struct	reusex::pipeline::JobRunnerOptions
	Tuning knobs for the job store. More...
class	reusex::pipeline::JobRunner
	FIFO, single-worker, in-process pipeline job runner. More...

Namespaces
namespace	reusex
namespace	reusex::pipeline

Typedefs
using	reusex::pipeline::JobListener = std::function<void(const JobEvent &)>
	Listener callback.
using	reusex::pipeline::WriterLease = std::unique_lock<std::timed_mutex>
	Exclusive right to write to a runner's project.

Enumerations
enum class	reusex::pipeline::JobStatus {   reusex::pipeline::queued , reusex::pipeline::running , reusex::pipeline::succeeded , reusex::pipeline::failed ,   reusex::pipeline::cancelled }
	Lifecycle of a submitted job. More...

Functions
std::string_view	reusex::pipeline::to_string (JobStatus status)
	Canonical lower-case status name used on the wire.
std::optional< JobStatus >	reusex::pipeline::parse_job_status (std::string_view name)
	Parse a canonical status name. Returns nullopt for an unknown name.
bool	reusex::pipeline::is_terminal (JobStatus status)
	True for statuses a job can never leave.
std::string	reusex::pipeline::iso8601_utc_now ()
	UTC timestamp in ISO-8601 form (e.g. "2026-09-08T11:22:33Z").
std::string_view	reusex::pipeline::to_string (JobEvent::Type type)
	Canonical lower-case event-type name used on the wire.