Struct Conductor 

pub struct Conductor<Link: ConductorLink> { /* private fields */ }

The conductor manages the proxy chain lifecycle and message routing.

It maintains connections to all components in the chain and routes messages bidirectionally between the editor, components, and agent.

Implementations

impl<Link: ConductorLink> Conductor<Link>

pub fn new( link: Link, name: impl ToString, instantiator: Link::Instantiator, mcp_bridge_mode: McpBridgeMode, ) -> Self

impl Conductor<ConductorToClient>

pub fn new_agent( name: impl ToString, instantiator: impl InstantiateProxiesAndAgent + 'static, mcp_bridge_mode: McpBridgeMode, ) -> Self

Create a conductor in agent mode (the last component is an agent).

impl Conductor<ConductorToConductor>

pub fn new_proxy( name: impl ToString, instantiator: impl InstantiateProxies + 'static, mcp_bridge_mode: McpBridgeMode, ) -> Self

Create a conductor in proxy mode (forwards to another conductor).

impl<Link: ConductorLink> Conductor<Link>

pub fn trace_to(self, dest: impl WriteEvent) -> Self

Enable trace logging to a custom destination.

Use sacp-trace-viewer to view the trace as an interactive sequence diagram.

pub fn trace_to_path(self, path: impl AsRef<Path>) -> Result<Self>

Enable trace logging to a file path.

Events will be written as newline-delimited JSON (.jsons format). Use sacp-trace-viewer to view the trace as an interactive sequence diagram.

pub fn with_trace_writer(self, writer: TraceWriter) -> Self

Enable trace logging with an existing TraceWriter.

pub fn into_connection_builder( self, ) -> JrConnectionBuilder<impl JrMessageHandler<Link = Link>, impl JrResponder<Link>>

pub async fn run( self, transport: impl Component<Link::ConnectsTo> + 'static, ) -> Result<(), Error>

Convenience method to run the conductor with a transport.

This is equivalent to:

conductor.into_connection_builder()
    .connect_to(transport)
    .serve()
    .await

Trait Implementations

impl<Link: ConductorLink> Component<<Link as ConductorLink>::Speaks> for Conductor<Link>

async fn serve( self, client: impl Component<Link::ConnectsTo>, ) -> Result<(), Error>

Serve this component by forwarding to a client component.

fn into_server( self, ) -> (Channel, Pin<Box<dyn Future<Output = Result<(), Error>> + Send>>)

where Self: Sized,

Convert this component into a channel endpoint and server future.