Struct PilotServiceImpl 

pub struct PilotServiceImpl {
    atlas: AtlasClient,
    provider_id: String,
    vlm: VlmClient,
    histories: Arc<Mutex<HashMap<String, Arc<Mutex<Vec<Message>>>>>>,
    cancels: Arc<Mutex<HashMap<String, Sender<bool>>>>,
}

Fields

atlas: AtlasClient

AtlasClient is cheap to clone (its inner channel is just a handle); each Stream RPC clones it to discover executor concurrently without serialising on a single mutex.

provider_id: String

Pilot’s own provider_id; passed to atlas as consumer_id on every ConnectCapability so the channel record reflects who is using the executor.

vlm: VlmClient

histories: Arc<Mutex<HashMap<String, Arc<Mutex<Vec<Message>>>>>>

cancels: Arc<Mutex<HashMap<String, Sender<bool>>>>

Per-session cancellation senders. abort_turn Task signals this without holding the history lock.

Implementations

impl PilotServiceImpl

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

async fn get_or_create_history( &self, session_id: &str, ) -> Arc<Mutex<Vec<Message>>>

Trait Implementations

impl RobonixSystemPilot for PilotServiceImpl

type SubmitTaskStream = ReceiverStream<Result<PilotEvent, Status>>

Server streaming response type for the SubmitTask method.

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

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