pub struct NoopSubagentSpawnStore;Expand description
No-op spawn store — used when no durable store is configured (dev/test).
Always claims (no dedup); settle and register are no-ops.
Trait Implementations§
Source§impl SubagentSpawnStore for NoopSubagentSpawnStore
impl SubagentSpawnStore for NoopSubagentSpawnStore
Source§fn try_claim_spawn<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
_parent_session_id: SessionId,
_tool_call_id: &'life1 str,
_subagent_name: &'life2 str,
_subagent_task: &'life3 str,
claim_token: Uuid,
) -> Pin<Box<dyn Future<Output = Result<SpawnClaimResult>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
fn try_claim_spawn<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
_parent_session_id: SessionId,
_tool_call_id: &'life1 str,
_subagent_name: &'life2 str,
_subagent_task: &'life3 str,
claim_token: Uuid,
) -> Pin<Box<dyn Future<Output = Result<SpawnClaimResult>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
Attempt to claim a spawn slot for
(parent_session_id, tool_call_id). Read moreSource§fn register_child_session<'life0, 'async_trait>(
&'life0 self,
_spawn_handle_id: Uuid,
_claim_token: Uuid,
_child_session_id: SessionId,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn register_child_session<'life0, 'async_trait>(
&'life0 self,
_spawn_handle_id: Uuid,
_claim_token: Uuid,
_child_session_id: SessionId,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Register the actual child session ID after it has been created. Read more
Source§fn settle_spawn<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
_parent_session_id: SessionId,
_tool_call_id: &'life1 str,
_claim_token: Uuid,
_terminal_status: &'life2 str,
_terminal_result: &'life3 str,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
fn settle_spawn<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
_parent_session_id: SessionId,
_tool_call_id: &'life1 str,
_claim_token: Uuid,
_terminal_status: &'life2 str,
_terminal_result: &'life3 str,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
Record the terminal result once the child has completed. Read more
Auto Trait Implementations§
impl Freeze for NoopSubagentSpawnStore
impl RefUnwindSafe for NoopSubagentSpawnStore
impl Send for NoopSubagentSpawnStore
impl Sync for NoopSubagentSpawnStore
impl Unpin for NoopSubagentSpawnStore
impl UnsafeUnpin for NoopSubagentSpawnStore
impl UnwindSafe for NoopSubagentSpawnStore
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request