Struct LocalFleet 

pub struct LocalFleet { /* private fields */ }

caliband-over-Unix-sockets backend — wraps today’s FleetManager verbatim.

Implementations

impl LocalFleet

pub fn new(inner: FleetManager) -> Self

pub fn manager(&self) -> &FleetManager

Access the underlying manager (session plane, API handlers still use it directly in P1).

Trait Implementations

impl Clone for LocalFleet

fn clone(&self) -> LocalFleet

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl FleetAdmin for LocalFleet

fn add_workspace<'life0, 'async_trait>( &'life0 self, name: String, root: PathBuf, config: WorkspaceConfig, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Register a workspace and persist it. root is the LocalFleet checkout path; k8s ignores it and uses config.sources instead.

fn remove_workspace<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Unregister a workspace; returns whether one existed.

fn set_workspace_config<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, config: WorkspaceConfig, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Replace a workspace’s configuration (local: restarts its caliband; k8s: patches the Workspace CR, operator reconciles).

fn list_workspaces<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkspaceInfo>>> + Send + 'async_trait>>

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

List configured workspaces with reconciliation status, for the read side (GET /api/workspaces). The default returns empty: backends whose workspaces already appear in the fleet snapshot (local) need not duplicate them here. K8sWorkspaceAdmin overrides this to return its Workspace CRs, so a configured-but-agentless workspace is still visible with its status. (#142)

fn workspace_ops_are_async(&self) -> bool

Whether workspace create/config completes asynchronously (the caller should treat success as accepted, reconciling rather than done). Local applies config synchronously (false); the k8s config plane hands off to the operator’s reconcile loop (true → the API answers 202).

impl FleetProvider for LocalFleet

fn ensure_agent<'life0, 'async_trait>( &'life0 self, spec: TaskSpec, ) -> Pin<Box<dyn Future<Output = Result<AgentHandle>> + Send + 'async_trait>>

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

Ensure an agent for spec exists and is attachable. Idempotent.

fn watch_fleet(&self) -> BoxStream<'static, FleetChange>

Observe the fleet: an initial listing followed by live change events.

fn stop_agent<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 AgentId, drain: DrainPolicy, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Stop an agent per drain policy.

fn restart_agent<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 AgentId, ) -> Pin<Box<dyn Future<Output = Result<AgentId>> + Send + 'async_trait>>

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

Restart an agent; returns the (possibly new) id.

fn remove_agent<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 AgentId, force: bool, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Forget an agent entirely (local: remove from caliband’s registry; k8s: delete its CalibanTask CR). (#76)

fn snapshot<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = FleetSnapshot> + Send + 'async_trait>>

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

A point-in-time view of the whole fleet. Local builds it from the poll snapshot; k8s projects the live CalibanTasks. (#76)

fn readiness<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Readiness> + Send + 'async_trait>>

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

Readiness of the backend + its store. Local reports store-writability + per-workspace poll health; k8s reports store-writability + kube API reachability. (#76)

fn metrics(&self) -> MetricsSnapshot

Backend counters for /api/metrics. (#76)

fn send_input<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 AgentId, input: AttachInbound, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Steer an interactive agent: deliver an inbound frame to its session plane (local: over the per-agent Unix socket; k8s: dial the agent’s caliband endpoint over the network). (#76)