Struct PersistentSubprocessController 

pub struct PersistentSubprocessController {
    tab_id: String,
    block_id: String,
    inner: Arc<Mutex<PersistentInner>>,
    broker: Option<Arc<Broker>>,
    event_bus: Option<Arc<EventBus>>,
    wstore: Option<Arc<WaveStore>>,
    filestore: Option<Arc<FileStore>>,
    health_monitor: Arc<HealthMonitor>,
}

PersistentSubprocessController keeps a long-running CLI process alive, sending user messages as NDJSON lines on stdin.

Fields

tab_id: String

block_id: String

inner: Arc<Mutex<PersistentInner>>

broker: Option<Arc<Broker>>

event_bus: Option<Arc<EventBus>>

wstore: Option<Arc<WaveStore>>

filestore: Option<Arc<FileStore>>

FileStore for write-through persistence of output lines (Phase 1.3).

health_monitor: Arc<HealthMonitor>

Implementations

impl PersistentSubprocessController

pub fn new( tab_id: String, block_id: String, broker: Option<Arc<Broker>>, event_bus: Option<Arc<EventBus>>, wstore: Option<Arc<WaveStore>>, filestore: Option<Arc<FileStore>>, ) -> Self

fn set_status(inner: &mut PersistentInner, status: &str)

fn get_status_snapshot(&self) -> BlockControllerRuntimeStatus

fn publish_status(&self)

fn is_running(&self) -> bool

pub fn send_message( &self, message: String, config: PersistentSpawnConfig, ) -> Result<(), String>

Send a user message to the running CLI process. If the process isn’t spawned yet, spawns it first.

fn spawn_process(&self, config: PersistentSpawnConfig) -> Result<(), String>

Spawn the persistent CLI process.

pub fn stop_process(&self, force: bool) -> Result<(), String>

pub fn session_id(&self) -> Option<String>

Trait Implementations

impl Controller for PersistentSubprocessController

fn start( &self, _block_meta: HashMap<String, Value>, _rt_opts: Option<Value>, _force: bool, ) -> Result<(), String>

Start the controller. May spawn background tasks. force restarts even if already running.

fn stop(&self, _graceful: bool, new_status: &str) -> Result<(), String>

Stop the controller. graceful waits for process to exit; new_status is the target state.

fn get_runtime_status(&self) -> BlockControllerRuntimeStatus

Get the current runtime status.

fn send_input( &self, _input: BlockInputUnion, _seq: Option<u64>, ) -> Result<(), String>

Send input (terminal data, signal, or resize) to the controller. seq is the per-TermViewModel monotonic counter; None means fire-and-forget (no ordering).

fn controller_type(&self) -> &str

Get the controller type (e.g., “shell”, “cmd”).

fn block_id(&self) -> &str

Get the block ID.

fn as_any(&self) -> &dyn Any

Downcast support for concrete controller types.