Struct MemorySearchDispatcher 

pub struct MemorySearchDispatcher { /* private fields */ }

Tool dispatcher that provides the memory_search tool.

Wraps an Arc<dyn MemoryStore> and exposes semantic search as an agent-callable tool. Created by the factory when the memory-store-session feature is enabled.

Implementations

impl MemorySearchDispatcher

pub fn new(store: Arc<dyn MemoryStore>, scope: MemorySearchScope) -> Self

Create a new memory search dispatcher backed by the given store.

pub fn for_session(store: Arc<dyn MemoryStore>, session_id: SessionId) -> Self

Create a dispatcher scoped to the canonical memory owner for a session.

Trait Implementations

impl AgentToolDispatcher for MemorySearchDispatcher

fn tools(&self) -> Arc<[Arc<ToolDef>]>

Get available tool definitions

fn dispatch<'life0, 'life1, 'async_trait>( &'life0 self, call: ToolCallView<'life1>, ) -> Pin<Box<dyn Future<Output = Result<ToolDispatchOutcome, ToolError>> + Send + 'async_trait>>

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

Execute a tool call, returning the transcript result and any async operations.

fn tool_catalog_capabilities(&self) -> ToolCatalogCapabilities

Query exact catalog support for this dispatcher.

fn tool_catalog(&self) -> Arc<[ToolCatalogEntry]>

Return the precedence-resolved tool catalog for this dispatcher.

fn execution_binding_epoch(&self, _tool_name: &str) -> u64

Live generation for one logical tool binding.

fn execution_binding_fingerprint( &self, tool_name: &str, ) -> Result<EphemeralToolBindingFingerprint, ToolExecutionResolutionError>

Snapshot the current live logical binding advertised for tool_name.

fn resolve_execution_plan( &self, call: ToolCallView<'_>, _dispatch_context: &ToolDispatchContext, resolution_context: &ToolExecutionResolutionContext, ) -> Result<ResolvedToolExecutionPlan, ToolExecutionResolutionError>

Resolve the exact execution class and deadline chain before dispatch.

fn validate_resolved_execution_plan( &self, call: ToolCallView<'_>, resolution_context: &ToolExecutionResolutionContext, plan: &ResolvedToolExecutionPlan, ) -> Result<(), ToolExecutionResolutionError>

Validate a resolved plan against both the caller-owned deadline prefix and this dispatcher’s live advertised catalog contract.

fn pending_catalog_sources(&self) -> Arc<[String]>

Return non-draining pending source names for exact-catalog discovery.

fn dispatch_with_context<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, call: ToolCallView<'life1>, _context: &'life2 ToolDispatchContext, ) -> Pin<Box<dyn Future<Output = Result<ToolDispatchOutcome, ToolError>> + Send + 'async_trait>>

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

Execute a tool call with the current turn’s typed dispatch context.

fn dispatch_resolved_with_context<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, call: ToolCallView<'life1>, context: &'life2 ToolDispatchContext, plan: &'life3 ResolvedToolExecutionPlan, ) -> Pin<Box<dyn Future<Output = Result<ToolDispatchOutcome, ToolError>> + Send + 'async_trait>>

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

Execute a previously resolved plan without re-selecting its mode.

fn poll_external_updates<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ExternalToolUpdate> + Send + 'async_trait>>

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

Poll for external tool updates from background operations (e.g. async MCP loading).

fn external_tool_surface_snapshot(&self) -> Option<ExternalToolSurfaceSnapshot>

Snapshot the live external tool-surface machine state, if supported.

fn capabilities(&self) -> DispatcherCapabilities

Query which optional bindings this dispatcher supports.

fn bind_ops_lifecycle( self: Arc<Self>, _registry: Arc<dyn OpsLifecycleRegistry>, _owner_bridge_session_id: SessionId, ) -> Result<BindOutcome, OpsLifecycleBindError>

Bind a session-canonical ops registry into this dispatcher.

fn completion_enrichment(&self) -> Option<Arc<dyn CompletionEnrichmentProvider>>

Return the completion enrichment provider, if available.

fn bind_mcp_server_lifecycle_handle( &self, _handle: Arc<dyn McpServerLifecycleHandle>, )

Bind a session-scoped MCP server lifecycle handle (Phase 5G / T5g).

fn bind_external_tool_surface_handle( &self, _handle: Arc<dyn ExternalToolSurfaceHandle>, )

Bind the session-canonical external tool-surface handle.