Struct ExecutorServiceImpl 

pub struct ExecutorServiceImpl {
    atlas: AtlasClient,
    provider_id: String,
}

AtlasClient is cheap to clone — each Execute RPC clones it so per-plan dispatch runs without serialising on a single mutex.

Fields

atlas: AtlasClient

provider_id: String

Executor’s own provider_id. Two roles:

1. consumer_id passed to atlas on every ConnectCapability so the channel record reflects who is using each downstream provider.
2. self-detection: when a CapabilityCall in the plan targets this provider_id, dispatch short-circuits to the in-process builtin handlers instead of going through MCP loopback.

Implementations

impl ExecutorServiceImpl

pub fn new(atlas: AtlasClient, provider_id: String) -> Self

Trait Implementations

impl Clone for ExecutorServiceImpl

fn clone(&self) -> ExecutorServiceImpl

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl RobonixSystemExecutor for ExecutorServiceImpl

type ExecuteStream = ReceiverStream<Result<CapabilityCallEvent, Status>>

Server streaming response type for the Execute method.

fn execute<'life0, 'async_trait>( &'life0 self, request: Request<Plan>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::ExecuteStream>, Status>> + Send + 'async_trait>>

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