Struct PmStorage 

pub struct PmStorage { /* private fields */ }

Implementations

impl PmStorage

pub async fn new(config: PmStorageConfig) -> Result<Self, String>

pub async fn save_ticket_map( &self, graph_id: &str, map: &HashMap<String, String>, ) -> Result<(), String>

Insert or replace all ticket→node mappings for a graph.

pub async fn get_ticket_map( &self, graph_id: &str, ) -> Result<HashMap<String, String>, String>

Fetch the ticket_id→node_id map for a graph.

pub async fn list_ticket_maps( &self, limit: usize, ) -> Result<Vec<(String, i64)>, String>

List all known graph IDs ordered by first insertion time descending. Returns Vec<(graph_id, created_at)>.

pub async fn save_ticket_source( &self, graph_id: &str, source: &str, ) -> Result<(), String>

Save the raw ticket source for a graph.

pub async fn get_ticket_source( &self, graph_id: &str, ) -> Result<Option<String>, String>

Fetch the raw ticket source for a graph.

pub async fn get_ticket_for_node( &self, graph_id: &str, node_id: &str, ) -> Result<Option<String>, String>

Reverse lookup: node_id → ticket_id.

pub async fn append_node_log( &self, graph_id: &str, node_id: &str, ticket_id: Option<&str>, seq: i64, event_type: &str, event_data: &str, ) -> Result<(), String>

Append a single log entry for a node execution event.

event_type is one of: “prompt”, “start”, “tool_use”, “tool_result”, “complete”, “error”, “passthrough”, “outcome”. event_data is a JSON string.

pub async fn get_node_log( &self, graph_id: &str, node_id: &str, ) -> Result<Vec<NodeLogEntry>, String>

Fetch all log entries for a (graph_id, node_id) pair, ordered by seq.