Struct Singleflight 

pub struct Singleflight { /* private fields */ }

Singleflight coalescing layer.

Tracks in-flight queries by key. Concurrent identical queries share results.

Implementations

impl Singleflight

pub fn new() -> Self

Create a new singleflight coalescing layer.

pub fn try_join(&self, key: u64) -> FlightResult

Try to join an in-flight query group, or become the leader.

key should be a hash of (sql_hash, parameter bytes).

pub fn wait_for_result( state: &FlightState, ) -> Option<Arc<Result<Arc<OwnedResultSnapshot>, BsqlError>>>

Wait for a flight result as a follower.

Blocks until the leader calls complete(), is dropped, or the 30-second timeout expires. Returns None if the leader was dropped without completing (e.g., panic) or if the wait timed out.

pub fn compute_key(sql_hash: u64, params: &[&(dyn Encode + Sync)]) -> u64

Compute a singleflight key from sql_hash and parameter data.

Uses rapidhash to combine the sql_hash with a hash of all parameter bytes (including actual encoded values). Two queries with the same SQL and same parameter values produce the same key.

Trait Implementations

impl Default for Singleflight

fn default() -> Self

Returns the “default value” for a type.