Struct AdminDisableStore 

pub struct AdminDisableStore { /* private fields */ }

A single-document, atomically-persisted store of current AdminDisableRecords keyed by worker id. Same corruption tolerance as BypassRecordStore: a missing or unreadable file yields an empty store and never blocks daemon startup (the failure mode is “worker rejoins until re-disabled”, the pre-existing behavior).

Implementations

impl AdminDisableStore

pub fn with_path(path: impl Into<PathBuf>) -> Self

An empty store bound to path (nothing read from disk).

pub fn load(path: impl Into<PathBuf>) -> Self

Load the store from path; missing/corrupt files yield an empty store.

pub fn path(&self) -> &Path

The store file path.

pub fn get(&self, worker_id: &str) -> Option<&AdminDisableRecord>

The current record for a worker, if disabled.

pub fn all(&self) -> Vec<&AdminDisableRecord>

All current records, ordered by worker id.

pub fn upsert(&mut self, record: AdminDisableRecord) -> Result<()>

Record a worker disable and persist the store.

pub fn remove(&mut self, worker_id: &str) -> Result<Option<AdminDisableRecord>>

Remove a worker’s record (operator enable) and persist. Returns the removed record, if any.

Trait Implementations

impl Debug for AdminDisableStore

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

Formats the value using the given formatter.