pub struct SessionProcessAdmin { /* private fields */ }Implementations§
Source§impl SessionProcessAdmin
Session-scoped view of the global process surface ([Processes]).
impl SessionProcessAdmin
Session-scoped view of the global process surface ([Processes]).
This is thin sugar, not a parallel surface (ADR 0019 grill): every read is
the global observer pre-filtered by this session’s grant scope (what the
session may address), and every mutation delegates to the same runtime
process path the global surface uses. It speaks the same [ObservedProcess]
vocabulary as [Processes]; start returns the
grant-entry handle row (lash_core::ProcessHandleSummary), the one row
type retained for the model/handle contract.
pub async fn start( &self, request: ProcessStartRequest, scoped_effect_controller: ScopedEffectController<'_>, ) -> Result<ProcessHandleSummary>
Sourcepub async fn list(&self) -> Result<Vec<ObservedProcess>>
pub async fn list(&self) -> Result<Vec<ObservedProcess>>
Running processes this session may address.
Sourcepub async fn list_all(&self) -> Result<Vec<ObservedProcess>>
pub async fn list_all(&self) -> Result<Vec<ObservedProcess>>
Every process (any status) this session may address.
Sourcepub async fn get(&self, process_id: &str) -> Result<Option<ObservedProcess>>
pub async fn get(&self, process_id: &str) -> Result<Option<ObservedProcess>>
One process this session may address, if present.
pub async fn events( &self, process_id: &str, after_sequence: u64, ) -> Result<Vec<ObservedProcessEvent>>
pub async fn await_output(&self, process_id: &str) -> Result<ProcessAwaitOutput>
pub async fn signal( &self, process_id: &str, signal_name: impl Into<String>, signal_id: impl Into<String>, payload: Value, scoped_effect_controller: ScopedEffectController<'_>, ) -> Result<ProcessEvent>
pub async fn cancel( &self, process_id: &str, scoped_effect_controller: ScopedEffectController<'_>, ) -> Result<ProcessCancelSummary>
pub async fn cancel_all( &self, scoped_effect_controller: ScopedEffectController<'_>, ) -> Result<Vec<ProcessCancelSummary>>
Sourcepub async fn transfer(
&self,
to_session_id: &str,
process_ids: Vec<String>,
scoped_effect_controller: ScopedEffectController<'_>,
) -> Result<()>
pub async fn transfer( &self, to_session_id: &str, process_ids: Vec<String>, scoped_effect_controller: ScopedEffectController<'_>, ) -> Result<()>
Move this session’s handle grants for process_ids to another session.
Re-homes the addressing grant only; the process itself is global.
Sourcepub async fn request_abandon(
&self,
process_id: &str,
reason: Option<String>,
) -> Result<ObservedProcess>
pub async fn request_abandon( &self, process_id: &str, reason: Option<String>, ) -> Result<ObservedProcess>
Record an Abandon Request (ADR 0019) against a process this session
owns: an authorization the recovery sweep reconciles into Abandoned
once the owner’s lease lapses. Returns the process as observed after.
Trait Implementations§
Source§impl Clone for SessionProcessAdmin
impl Clone for SessionProcessAdmin
Source§fn clone(&self) -> SessionProcessAdmin
fn clone(&self) -> SessionProcessAdmin
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read more