Struct ProcessWorkObserver 

pub struct ProcessWorkObserver { /* private fields */ }

Implementations

impl ProcessWorkObserver

pub fn new(registry: Arc<dyn ProcessRegistry>) -> Self

pub async fn snapshot_for_session( &self, session_id: impl Into<String>, ) -> Result<ProcessWorkSnapshot, PluginError>

pub async fn snapshot_all( &self, filter: &ProcessListFilter, ) -> Result<Vec<ObservedWorkItem>, PluginError>

Snapshot every process matching filter, including the bounded event tail used by host work rails. Unlike Self::snapshot_for_session, this is the runtime-wide observation surface: it does not depend on a session handle grant and therefore continues to expose processes whose originating session has been deleted. Because grants are bypassed, the host must authorize access; routing identity is not authorization.

pub async fn process(&self, process_id: &str) -> Option<ObservedProcess>

pub async fn list( &self, filter: &ProcessListFilter, ) -> Result<Vec<ObservedProcess>, PluginError>

pub async fn list_granted_to( &self, scope: &SessionScope, filter: &ProcessListFilter, ) -> Result<Vec<ObservedProcess>, PluginError>

List processes a session may address — the grant filter (ADR 0019 / process design grill). “Granted to” is the security lens: a process is visible here only if scope holds a handle grant for it. This is the single home for the grant-scoped view; the session facade sugar is a thin caller of this method, never a parallel implementation.

pub async fn list_originated_by( &self, scope: &SessionScope, filter: &ProcessListFilter, ) -> Result<Vec<ObservedProcess>, PluginError>

List processes a session originated — the provenance filter (ADR 0019 / process design grill). “Originated by” is the lineage lens, distinct from the grant lens: a process matches when its recorded originator is a session whose id equals scope.session_id (and its agent frame, when scope names one), regardless of who currently holds a grant.

pub async fn events_after( &self, process_id: &str, after_sequence: u64, ) -> Result<Vec<ObservedProcessEvent>, PluginError>

Trait Implementations

impl Clone for ProcessWorkObserver

fn clone(&self) -> ProcessWorkObserver

Returns a duplicate of the value.

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

Performs copy-assignment from source.