Struct QueryGate 

pub struct QueryGate { /* private fields */ }

Single-flight gate keyed by session id.

Implementations

impl QueryGate

pub fn new() -> Self

Create a gate.

pub async fn acquire(&self, session_id: &str) -> Result<(), ErrQueryBusy>

Acquire exclusive query slot.

pub async fn cancel(&self, _session_id: &str)

Mark cancelled (slot still held until release).

pub async fn release(&self, session_id: &str)

Release exclusive slot.

Trait Implementations

impl Clone for QueryGate

fn clone(&self) -> QueryGate

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for QueryGate

fn default() -> QueryGate

Returns the “default value” for a type.