Struct Locked 

pub struct Locked<'a> { /* private fields */ }

Lock-holding handle returned by LocalFsStore::transact. All mutator methods on this type skip lock acquisition; the lock is held by the enclosing transact scope and released on its return.

Mutators on this handle reject writes whose embedded environment_id (or runtime environment_id) does not match the env the transaction is scoped to — the lock guards exactly one env’s state, so accidentally writing a different env’s payload inside the closure would bypass that env’s flock entirely.

Implementations

impl<'a> Locked<'a>

pub fn env_id(&self) -> &EnvId

pub fn load(&self) -> Result<Environment, StoreError>

pub fn save(&self, env: &Environment) -> Result<(), StoreError>

pub fn load_runtime(&self) -> Result<Option<EnvironmentRuntime>, StoreError>

pub fn save_runtime( &self, runtime: &EnvironmentRuntime, ) -> Result<(), StoreError>

pub fn load_update_channel( &self, ) -> Result<Option<UpdateChannelConfig>, StoreError>

pub fn save_update_channel( &self, cfg: &UpdateChannelConfig, ) -> Result<(), StoreError>

pub fn load_pack_answers( &self, slot: CapabilitySlot, ) -> Result<Option<Value>, StoreError>

pub fn save_pack_answers( &self, slot: CapabilitySlot, answers: &Value, ) -> Result<(), StoreError>

pub fn delete_pack_answers( &self, slot: CapabilitySlot, ) -> Result<(), StoreError>

pub fn refresh_runtime_config( &self, env: &Environment, ) -> Result<(), StoreError>

Re-materialize runtime-config.json from env’s current traffic splits. Call with the just-saved env after any mutation that can change the TrafficSplit set, inside the same transact scope, so the file greentic-start boots from stays in lock-step with environment.json. Writes the projection, or deletes the file when no split routes a revision — greentic-start rejects a config with an empty revisions list, so absence is the correct “nothing live” signal.

pub fn refresh_messaging_projection( &self, env: &Environment, ) -> Result<(), StoreError>

Reconcile <env_dir>/messaging/ against the just-saved env. Call after any mutation that can change Environment.messaging_endpoints (M1.2 add/update/remove verbs). Writes one file per endpoint plus an index.json enumerator; per-endpoint files for ids no longer in the env are pruned (with backup) and index.json is removed when the env has zero endpoints.

Trait Implementations

impl<'a> Debug for Locked<'a>

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

Formats the value using the given formatter.