Struct Bounded 

pub struct Bounded<B> { /* private fields */ }

A RelationalBackend whose every call is cut off after bound.

Implementations

impl<B> Bounded<B>

pub fn new(inner: B, bound: Duration) -> Self

Wrap inner so that no call waits longer than bound.

pub fn inner(&self) -> &B

The wrapped backend (its calls are not bounded).

pub fn bound(&self) -> Duration

The per-call bound.

Trait Implementations

impl<B: Clone> Clone for Bounded<B>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<B: Debug> Debug for Bounded<B>

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

Formats the value using the given formatter.

impl<B: RelationalBackend> RelationalBackend for Bounded<B>

type Tx<'a> = BoundedTx<<B as RelationalBackend>::Tx<'a>> where Self: 'a

A transaction on this backend. Dropping it without commit rolls it back.

fn backend(&self) -> &str

The backend’s name as it appears in matrix rows (postgres).

fn version(&self) -> &str

The server version string as it appears in matrix rows (16.15).

fn dialect(&self) -> Dialect

The dialect statements must be written in.

async fn execute(&self, sql: &str, params: &[Value]) -> Result<u64, RelError>

Run a statement that returns no rows; the result is the number of rows affected.

async fn query(&self, sql: &str, params: &[Value]) -> Result<Vec<Row>, RelError>

Run a statement and return its rows.

async fn begin(&self, isolation: Isolation) -> Result<Self::Tx<'_>, RelError>

Begin a transaction at (at least) isolation.

fn call_bound(&self) -> Option<Duration>

The per-call timeout this backend enforces, if one is configured; None (the default) means a call waits as long as the server does. Every call that takes longer returns RelError::Timeout.

async fn with_lock_held<'a>( &'a self, lock_sql: &'a str, at_most: Duration, during: Pin<Box<dyn Future<Output = ()> + Send + 'a>>, ) -> Result<(), RelError>

Test support for kv.bounded_call: take lock_sql (a statement that locks a row) in a transaction of its own, drive during while that lock is held, then roll back. during is dropped, unfinished, after at_most, so a broken bound cannot hang the test. A backend that enforces no bound returns RelError::Unsupported.