Struct Pm 

pub struct Pm { /* private fields */ }

Implementations

impl Pm

pub fn new( pm_storage: Arc<PmStorage>, lattice_storage: Arc<LatticeStorage>, ) -> Self

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

Save ticket→node mappings for a graph (called by Orcha after build).

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_all_graph_ids(&self) -> Result<Vec<String>, String>

Return all graph IDs known to PM (regardless of status), most-recent first.

Used by the startup recovery pass to find graphs that should be re-watched.

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

Save the raw ticket source for a graph (called by run_tickets / run_tickets_async).

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

Fetch the raw ticket source for a graph.

pub async fn log_node_event( &self, graph_id: &str, node_id: &str, ticket_id: Option<&str>, seq: i64, event_type: &str, event_data: Value, )

Append a single event to the node execution log.

Called from dispatch_task for each ChatEvent and the final outcome.

impl Pm

pub const NAMESPACE: &'static str = "pm"

pub const PLUGIN_ID: Uuid

Stable plugin instance ID for handle routing

pub fn plugin_id(&self) -> Uuid

Get the plugin’s stable instance ID

Trait Implementations

impl Activation for Pm

type Methods = PmMethod

fn namespace(&self) -> &str

fn version(&self) -> &str

fn description(&self) -> &str

Short description (max 15 words)

fn long_description(&self) -> Option<&str>

Long description (optional, for detailed documentation)

fn methods(&self) -> Vec<&str>

fn method_help(&self, method: &str) -> Option<String>

fn call<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, method: &'life1 str, params: Value, auth: Option<&'life2 AuthContext>, raw_ctx: Option<&'life3 RawRequestContext>, ) -> Pin<Box<dyn Future<Output = Result<PlexusStream, PlexusError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn into_rpc_methods(self) -> Methods

fn plugin_schema(&self) -> PluginSchema

Return this activation’s schema (methods + optional children)

fn plugin_id(&self) -> Uuid

Stable activation instance ID for handle routing By default generates a deterministic UUID from namespace+major_version Using major version only ensures handles survive minor/patch upgrades (semver)

fn resolve_handle<'life0, 'life1, 'async_trait>( &'life0 self, _handle: &'life1 Handle, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = PlexusStreamItem> + Send>>, PlexusError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

impl ChildRouter for Pm

fn router_namespace(&self) -> &str

Get the namespace of this router (for error messages)

fn router_call<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, method: &'life1 str, params: Value, auth: Option<&'life2 AuthContext>, raw_ctx: Option<&'life3 RawRequestContext>, ) -> Pin<Box<dyn Future<Output = Result<PlexusStream, PlexusError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Call a method on this router

fn get_child<'life0, 'life1, 'async_trait>( &'life0 self, _name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Option<Box<dyn ChildRouter>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get a child activation instance by name for nested routing

impl Clone for Pm

fn clone(&self) -> Pm

Returns a duplicate of the value.

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

Performs copy-assignment from source.