Struct InspectionFlags 

pub struct InspectionFlags<'a, S: ?Sized> { /* private fields */ }

Storage authority, not connected to pipeline or serving policy.

Implementations

impl<'a, S: NamespaceStore + ?Sized> InspectionFlags<'a, S>

pub fn new(store: &'a S, shards: &dyn ShardMap, repo: &'a RepoId) -> Self

Resolve the canonical repository-index partition.

pub async fn install_flags( &self, flags: &[FlagInstall], ) -> Result<u64, StoreError>

Atomically install at most 48 distinct flags; unseen sources advance the version. Replays remain no-ops across releases; history is bounded at 1024 and never pruned.

Errors Returns storage, input, corruption, overflow, or CAS contention errors.

pub async fn release_flag(&self, id: &Hash) -> Result<u64, StoreError>

Release this flag while retaining its origin, so delayed redelivery cannot reinstall it.

Errors Returns storage, corruption, overflow, or CAS contention errors.

pub async fn lookup(&self, ids: &[Hash]) -> Result<FlagLookup, StoreError>

Read at most 48 distinct ids; a version guard validates sequential reads and retries races.

Errors Returns invalid bounds, storage, corruption, or CAS contention errors.

pub async fn version(&self) -> Result<u64, StoreError>

Current version; an untouched repository is version zero.

Errors Returns storage or corrupt-version errors.

Trait Implementations

impl<'a, S: Debug + ?Sized> Debug for InspectionFlags<'a, S>

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

Formats the value using the given formatter.