Struct ContainerState 

pub struct ContainerState { /* private fields */ }

Always-present container-domain state: cache and cross-host pending operations. Separate from ContainerSession, which is the per-host overlay session state.

Implementations

impl ContainerState

pub fn cache(&self) -> &HashMap<String, ContainerCacheEntry>

pub fn set_cache(&mut self, cache: HashMap<String, ContainerCacheEntry>)

pub fn cache_entry(&self, alias: &str) -> Option<&ContainerCacheEntry>

pub fn cache_entry_mut( &mut self, alias: &str, ) -> Option<&mut ContainerCacheEntry>

pub fn cache_contains(&self, alias: &str) -> bool

pub fn cache_len(&self) -> usize

pub fn insert_cache_entry(&mut self, alias: String, entry: ContainerCacheEntry)

pub fn remove_cache_entry(&mut self, alias: &str)

pub fn clear_cache(&mut self)

pub fn pending_exec_request(&self) -> Option<&ContainerExecRequest>

pub fn pending_logs_request(&self) -> Option<&ContainerLogsRequest>

pub fn has_pending_fetches(&self) -> bool

pub fn pending_actions_len(&self) -> usize

pub fn take_pending_exec(&mut self) -> Option<ContainerExecRequest>

pub fn take_pending_logs(&mut self) -> Option<ContainerLogsRequest>

pub fn pop_next_action(&mut self) -> Option<ContainerActionRequest>

pub fn pending_actions_iter( &self, ) -> impl Iterator<Item = &ContainerActionRequest>

pub fn pending_actions_at(&self, idx: usize) -> Option<&ContainerActionRequest>

pub fn pending_fetch_aliases(&self) -> &[String]

pub fn extend_pending_fetches<I: IntoIterator<Item = String>>( &mut self, iter: I, )

pub fn queue_logs(&mut self, req: ContainerLogsRequest)

Queue a logs request for the main loop to drain. Replaces any previous pending logs request and logs the displaced alias so a dropped request is traceable.

pub fn queue_exec(&mut self, req: ContainerExecRequest)

Queue an exec request for the main loop to drain. Same replace and log semantics as queue_logs.

pub fn queue_action(&mut self, req: ContainerActionRequest)

Queue a non-interactive container action for the worker thread. Actions are FIFO via VecDeque::push_back; multiple actions against the same alias process in order.

pub fn queue_fetch(&mut self, alias: String)

Enqueue an alias for the initial container-cache fetch. Drained by the main loop on the next tick via drain_pending_fetches.

pub fn drain_pending_fetches(&mut self) -> Vec<String>

Take the full fetch queue, leaving it empty.

pub fn prune_orphans(&mut self, valid_aliases: &HashSet<&str>) -> bool

Drop cache entries whose host alias is no longer in valid_aliases. Returns true when anything was dropped so the caller can persist the trimmed cache via containers::save_container_cache. The cache is also the source of valid container IDs for downstream inspect/logs pruning.

pub fn migrate_alias(&mut self, old: &str, new: &str) -> bool

Move a cache entry from old to new on host rename. Returns true when the cache changed so the caller can persist. No-op (returns false) when old == new or no entry exists under old.

Trait Implementations

impl Debug for ContainerState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ContainerState

fn default() -> ContainerState

Returns the “default value” for a type.