Struct RunDirectory 

pub struct RunDirectory { /* private fields */ }

Manages the filesystem layout for a single pipeline run.

Implementations

impl RunDirectory

pub fn create(base_dir: &Path, run_id: &str) -> Result<Self>

Create a new run directory.

Creates the directory structure if it doesn’t exist.

pub fn open(base_dir: &Path, run_id: &str) -> Result<Self>

Open an existing run directory.

pub fn root(&self) -> &Path

Get the root path of this run directory.

pub fn checkpoint_path(&self) -> PathBuf

Get the checkpoint file path.

pub fn manifest_path(&self) -> PathBuf

Get the manifest file path.

pub fn node_dir(&self, node_id: &str) -> Result<PathBuf>

Get the node directory path, creating it if needed.

pub fn write_prompt(&self, node_id: &str, prompt: &str) -> Result<()>

Write the prompt for a node.

pub fn write_response(&self, node_id: &str, response: &str) -> Result<()>

Write the response for a node.

pub fn write_status(&self, node_id: &str, status: &Value) -> Result<()>

Write node status.

pub fn write_manifest(&self, manifest: &RunManifest) -> Result<()>

Write the run manifest.

pub fn read_manifest(&self) -> Result<RunManifest>

Read the run manifest.

pub fn write_artifact(&self, name: &str, content: &[u8]) -> Result<PathBuf>

Write an artifact file.

pub fn read_response(&self, node_id: &str) -> Result<String>

Read the response for a node.

Trait Implementations

impl Clone for RunDirectory

fn clone(&self) -> RunDirectory

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RunDirectory

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.