Struct AcpServer 

pub struct AcpServer { /* private fields */ }

Implementations

impl AcpServer

pub fn new(config: Config, acp_config: AcpServerConfig) -> AcpServer

pub fn new_with_writer( config: Config, acp_config: AcpServerConfig, writer_tx: Sender<String>, ) -> AcpServer

pub fn new_with_store( config: Config, acp_config: AcpServerConfig, store: Arc<AcpSessionStore>, ) -> AcpServer

pub fn new_with_writer_and_store( config: Config, acp_config: AcpServerConfig, writer_tx: Sender<String>, store: Arc<AcpSessionStore>, ) -> AcpServer

pub fn new_with_live_config_and_writer( live_config: Arc<RwLock<RawRwLock, Config>>, acp_config: AcpServerConfig, writer_tx: Sender<String>, ) -> AcpServer

Create a gateway-backed ACP server without durable session storage.

The server retains no parallel Config clone and resolves an on-demand view whenever it handles a request.

pub fn new_with_live_config_and_writer_and_store( live_config: Arc<RwLock<RawRwLock, Config>>, acp_config: AcpServerConfig, writer_tx: Sender<String>, store: Arc<AcpSessionStore>, ) -> AcpServer

Create a gateway-backed ACP server with durable session storage.

The server retains no parallel Config clone and resolves an on-demand view whenever it handles a request.

pub fn with_connection_default_agent(self, alias: Option<String>) -> AcpServer

Set the connection-scoped default agent alias (?agent= query param on the gateway ACP endpoint). Blank values are treated as absent. The alias is validated at session/new with the same dispatchable-agent checks as an explicit agentAlias. Restore paths ignore this value.

pub fn with_canvas_store(self, canvas_store: CanvasStore) -> AcpServer

Attach the shared gateway CanvasStore so that agents created by this server write canvas frames to the same store that the /ws/canvas/:id WebSocket endpoint serves.

pub fn with_sop_engine( self, sop_engine: Option<Arc<Mutex<SopEngine>>>, sop_audit: Option<Arc<SopAuditLogger>>, ) -> AcpServer

Attach the shared SOP engine from the daemon so that agents created by this server share a single SOP engine with the rest of the daemon.

pub async fn run(self: Arc<AcpServer>) -> Result<(), Error>

Run the ACP server, reading JSON-RPC requests from stdin and writing responses/notifications to stdout.

pub async fn run_messages( self: Arc<AcpServer>, input_rx: Receiver<String>, ) -> Result<(), Error>