Struct SingleFlight 

pub struct SingleFlight { /* private fields */ }

Guard for a single-flight fill, returned by CacheKit::single_flight.

Holds the per-key in-process lock for its whole lifetime, and the distributed fill lock (if one was acquired) until Self::release. Dropping without release is safe: the in-process lock frees immediately and a distributed lock expires server-side after its timeout.

Implementations

impl SingleFlight

pub async fn wait_for_fill(&mut self) -> bool

true while another worker may still be filling this key — re-check the cache after every true before computing yourself:

• Leader: immediately false (compute, don’t re-read your own miss).
• Queued behind a local leader: true exactly once.
• Contested cross-process: sleeps one poll interval per call, true until the poll budget is spent.

pub async fn release(self)

Release the flight. Best-effort: frees the distributed fill lock (if held) so other processes stop waiting early; errors are ignored — the lock expires server-side regardless.