Struct PilotServiceImpl 

pub struct PilotServiceImpl {
    atlas: AtlasClient,
    provider_id: String,
    vlm: VlmClient,
    soma_prompt_block: Arc<String>,
    histories: Arc<Mutex<HashMap<String, Arc<Mutex<Vec<Message>>>>>>,
    task_states: Arc<Mutex<HashMap<String, Arc<Mutex<Option<TaskState>>>>>>,
    cancels: Arc<Mutex<HashMap<String, Sender<bool>>>>,
    steers: Arc<Mutex<HashMap<String, ActiveTurnInput>>>,
    seen_task_ids: Arc<Mutex<HashMap<String, VecDeque<String>>>>,
    plan_seq: Arc<AtomicU64>,
}

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

soma_prompt_block: Arc<String>

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

task_states: Arc<Mutex<HashMap<String, Arc<Mutex<Option<TaskState>>>>>>

Harness-owned standing goal per session. It survives a transport turn that pauses for user input, so the next message cannot silently replace unfinished work with a model-authored summary.

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

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

steers: Arc<Mutex<HashMap<String, ActiveTurnInput>>>

Per-session steer queues. A Task submitted while a turn is already running for that session is pushed here as a mid-task steer instead of starting a second turn; the running run_turn drains it.

seen_task_ids: Arc<Mutex<HashMap<String, VecDeque<String>>>>

Recently accepted task ids, scoped by session. A client retry with the same id is acknowledged exactly once and never starts or steers a turn twice. The bounded queue prevents an unbounded session-lifetime set.

plan_seq: Arc<AtomicU64>

Process-global RTDL plan-id counter. Executor’s active table is global, so ids must be unique across sessions as well as turns.

Implementations

impl PilotServiceImpl

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

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

async fn get_or_create_task_state( &self, session_id: &str, ) -> Arc<Mutex<Option<TaskState>>>

async fn accept_task_id_once(&self, session_id: &str, task_id: &str) -> bool

Trait Implementations

impl Clone for PilotServiceImpl

fn clone(&self) -> PilotServiceImpl

Returns a duplicate of the value.

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

Performs copy-assignment from source.

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,

impl RobonixSystemPilotGetHealth for PilotServiceImpl

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,