Struct AgentDirectory 

pub struct AgentDirectory { /* private fields */ }

Process-level registry for installed Agent connectors.

Connector IDs namespace session IDs. Two different Agents may therefore expose the same opaque session ID without colliding.

Implementations

impl AgentDirectory

pub fn new() -> Self

pub async fn register( &self, connector: Arc<dyn AgentConnector>, provider: Arc<dyn AgentProvider>, ) -> Result<(), AgentDirectoryError>

pub async fn register_with_journal( &self, connector: Arc<dyn AgentConnector>, provider: Arc<dyn AgentProvider>, journal: Arc<dyn AgentJournalStore>, ) -> Result<(), AgentDirectoryError>

pub async fn connectors(&self) -> Vec<AgentConnectorDescriptor>

pub async fn health( &self, connector_id: &AgentConnectorId, ) -> Result<AgentConnectorHealth, AgentDirectoryError>

pub async fn list_sessions( &self, connector_id: &AgentConnectorId, query: AgentSessionListQuery, ) -> Result<AgentSessionPage, AgentDirectoryError>

pub async fn read_session( &self, connector_id: &AgentConnectorId, session_id: &AgentSessionId, ) -> Result<AgentSessionDetail, AgentDirectoryError>

pub async fn read_session_page( &self, connector_id: &AgentConnectorId, session_id: &AgentSessionId, query: AgentSessionReadQuery, ) -> Result<AgentSessionDetail, AgentDirectoryError>

pub async fn subscribe_session_changes( &self, connector_id: &AgentConnectorId, session_id: &AgentSessionId, ) -> Result<Receiver<AgentSessionChange>, AgentDirectoryError>

pub async fn resolve_request( &self, connector_id: &AgentConnectorId, request: ResolveAgentSessionRequest, ) -> Result<(), AgentDirectoryError>

pub async fn create_session( &self, connector_id: &AgentConnectorId, request: CreateAgentSessionRequest, ) -> Result<AgentSessionSummary, AgentDirectoryError>

pub async fn invoke_action( &self, connector_id: &AgentConnectorId, request: InvokeAgentSessionActionRequest, ) -> Result<AgentSessionActionOutcome, AgentDirectoryError>

pub async fn start_text( &self, connector_id: &AgentConnectorId, session_id: &AgentSessionId, run_id: Option<RunId>, input: impl Into<String>, ) -> Result<AgentRunHandle, AgentDirectoryError>

Start one Agent Protocol Run against a connector-owned session.

pub async fn start_content( &self, connector_id: &AgentConnectorId, session_id: &AgentSessionId, run_id: Option<RunId>, input: Vec<Content>, ) -> Result<AgentRunHandle, AgentDirectoryError>

Start one Agent Protocol Run with provider-neutral Content blocks.

pub async fn start_content_with_extensions( &self, connector_id: &AgentConnectorId, session_id: &AgentSessionId, run_id: Option<RunId>, input: Vec<Content>, extensions: Extensions, ) -> Result<AgentRunHandle, AgentDirectoryError>

Starts a Run with digest-bound, namespaced Host metadata. The directory keeps this provider-neutral and forwards the immutable extensions through the shared Agent Protocol controller.

pub async fn agent_api( &self, connector_id: &AgentConnectorId, ) -> Result<AgentApi, AgentDirectoryError>

Trait Implementations

impl Default for AgentDirectory

fn default() -> AgentDirectory

Returns the “default value” for a type.