Struct ExecutorServiceImpl 

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

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.

runtime: PlanRuntime

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 RobonixSystemExecutorCancelAllPlans for ExecutorServiceImpl

fn cancel_all<'life0, 'async_trait>( &'life0 self, _request: Request<CancelAllRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CancelAllResponse>, Status>> + Send + 'async_trait>>

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

impl RobonixSystemExecutorControlPlan for ExecutorServiceImpl

fn control_plan<'life0, 'async_trait>( &'life0 self, request: Request<ControlPlanRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ControlPlanResponse>, Status>> + Send + 'async_trait>>

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

impl RobonixSystemExecutorExecute for ExecutorServiceImpl

type ExecuteStream = ReceiverStream<Result<RtdlEvent, 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,

impl RobonixSystemExecutorGetHealth for ExecutorServiceImpl

fn get_module_health<'life0, 'async_trait>( &'life0 self, _request: Request<GetModuleHealthRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetModuleHealthResponse>, Status>> + Send + 'async_trait>>

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

impl RobonixSystemExecutorListActivePlans for ExecutorServiceImpl

fn list_active_plans<'life0, 'async_trait>( &'life0 self, _request: Request<ListActivePlansRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListActivePlansResponse>, Status>> + Send + 'async_trait>>

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