Struct EffectStateStorage 

pub struct EffectStateStorage { /* private fields */ }

Shared state storage for tracking applied effects. Stored on the filesystem implementation (e.g. DiskFileSystemInner).

Implementations

impl EffectStateStorage

pub fn matches_applied(&self, key: &[u8], target: u128) -> bool

Returns true if the per-key state holds Applied { value_hash == target, result: Ok(()) }.

Intended for use by Effect::capture to elide content materialization when the apply would dedup. Reading this from inside a turbo-tasks task is sound because Effects::apply re-checks at apply time and fires the producing task’s invalidator on mismatch (via the ApplyError::Retry / EffectsError::Retry pathway).

pub async fn run_apply<E, F, Fut>( &self, key: Box<[u8]>, value_hash: u128, body: Option<F>, ) -> Result<(), ApplyError>

where E: EffectError, F: FnOnce() -> Fut + Send, Fut: Future<Output = Result<(), E>> + Send,

Coordinate an apply for (key, value_hash) against the per-key state machine.

Dedup hits (state already Applied with a matching hash) return the cached result without running body. Otherwise body runs once under an InProgress guard and the result is stored. A None body (capture elided content because storage matched, but it no longer does) yields ApplyError::Retry.

Trait Implementations

impl Default for EffectStateStorage

fn default() -> EffectStateStorage

Returns the “default value” for a type.