Struct GraphPersistence 

pub struct GraphPersistence<S>
where
    S: RawGraphStore,
{ /* private fields */ }

Type-safe wrapper around RawGraphStore that handles TaskGraph serialization.

Consumers in zeph-core use this instead of RawGraphStore directly, so they never need to deal with JSON strings.

Storage layout

The task_graphs table stores both metadata columns (goal, status, created_at, finished_at) and the full graph_json blob. The metadata columns are summary/index data used for listing and filtering; graph_json is the authoritative source for full graph reconstruction. On load, only graph_json is deserialized — the columns are not consulted.

Implementations

impl<S> GraphPersistence<S>

where S: RawGraphStore,

pub fn new(store: S) -> GraphPersistence<S>

Create a new GraphPersistence wrapping the given store.

pub async fn save(&self, graph: &TaskGraph) -> Result<(), OrchestrationError>

Persist a TaskGraph (upsert).

Returns OrchestrationError::InvalidGraph if graph.goal exceeds MAX_GOAL_LEN (1024) characters.

Errors

Returns OrchestrationError::Persistence on serialization or database failure.

pub async fn load( &self, id: &GraphId, ) -> Result<Option<TaskGraph>, OrchestrationError>

Load a TaskGraph by its GraphId.

Returns None if not found.

Errors

Returns OrchestrationError::Persistence on database or deserialization failure.

pub async fn list( &self, limit: u32, ) -> Result<Vec<GraphSummary>, OrchestrationError>

List stored graphs (newest first).

Errors

Returns OrchestrationError::Persistence on database failure.

pub async fn delete(&self, id: &GraphId) -> Result<bool, OrchestrationError>

Delete a graph by its GraphId.

Returns true if a row was deleted.

Errors

Returns OrchestrationError::Persistence on database failure.