Struct QueueOwner 

pub struct QueueOwner { /* private fields */ }

The queue owner process — owns the ACP bridge and multiplexes incoming prompts from IPC clients, executing them sequentially.

Implementations

impl QueueOwner

pub async fn new( bridge: AcpBridge, listener: UnixListener, session_key: &str, ttl_secs: u64, ) -> Result<Self>

Create a new queue owner.

The caller must have already written the lease file and started the IPC server (UnixListener).

pub async fn run(self) -> Result<()>

Run the owner event loop.

Uses tokio::select! to concurrently handle:

1. New client connections from the Unix socket.
2. Bridge events (forwarded to the active prompt’s client).
3. Heartbeat timer (updates lease file every 5 seconds).
4. Idle timeout (shuts down after ttl_secs with an empty queue).