Struct BatchStore 

pub struct BatchStore { /* private fields */ }

Disk-backed store for batch jobs.

All methods are synchronous — they are intended to be called from a tokio::task::spawn_blocking context or from the background batch worker.

Implementations

impl BatchStore

pub fn new(dir: PathBuf) -> Result<Self>

Open (or create) the spool directory.

Returns an error if the directory cannot be created.

pub fn job_dir(&self, job_id: &str) -> PathBuf

Path to a job’s subdirectory.

pub fn create_job( &self, job_id: &str, input_jsonl: &str, endpoint: &str, total_lines: u32, ) -> Result<BatchJobMeta>

Create a new job on disk.

Writes input.jsonl with the supplied content and writes an initial status.json atomically.

Returns an error if a job with the same ID already exists.

pub fn update_status(&self, job_id: &str, status: &BatchJobMeta) -> Result<()>

Overwrite status.json atomically.

pub fn read_status(&self, job_id: &str) -> Result<BatchJobMeta>

Read status.json for a job.

pub fn append_output(&self, job_id: &str, line: &str) -> Result<()>

Append a single JSONL line to output.jsonl.

The line must NOT contain a trailing newline — one will be added.

pub fn append_error(&self, job_id: &str, line: &str) -> Result<()>

Append a single JSONL error record to errors.jsonl.

pub fn read_input_lines(&self, job_id: &str) -> Result<Vec<String>>

Read all lines from input.jsonl.

pub fn read_output_lines(&self, job_id: &str) -> Result<Vec<String>>

Read all output lines from output.jsonl.

pub fn list_jobs(&self) -> Result<Vec<String>>

List all job IDs under the spool directory.

pub fn in_progress_jobs(&self) -> Result<Vec<String>>

Return job IDs whose status is InProgress or Pending.

Used at startup to re-enqueue jobs that survived a restart.