Struct OpWithTime 

pub struct OpWithTime<'a, Op: AtomicOperation + ?Sized> { /* private fields */ }

Wrapper that guarantees time is available, borrowing the underlying operation.

Implementations

impl<'a, Op: AtomicOperation + ?Sized> OpWithTime<'a, Op>

pub async fn cached_or_db_time(op: &'a mut Op) -> Result<Self, Error>

Wraps an operation, using existing time if present, otherwise fetching from DB.

Priority order:

1. Cached time from operation
2. Manual clock time if the operation’s clock is manual
3. Database time via SELECT NOW()

pub fn cached_or_time(op: &'a mut Op, time: DateTime<Utc>) -> Self

Wraps with a specific time (uses existing if present).

pub fn cached_or_clock_time(op: &'a mut Op) -> Self

Wraps using system time (uses existing if present).

Uses cached time if present, otherwise uses the operation’s clock.

pub fn now(&self) -> DateTime<Utc>

Trait Implementations

impl<'a, Op: AtomicOperation + ?Sized> AtomicOperation for OpWithTime<'a, Op>

fn maybe_now(&self) -> Option<DateTime<Utc>>

Function for querying when the operation is taking place - if it is cached.

fn clock(&self) -> &ClockHandle

Returns the clock handle for time operations.

fn connection(&mut self) -> &mut Connection

Returns the raw underlying connection. The desired way to represent this would actually be as a GAT:

fn add_commit_hook_dyn( &mut self, type_id: TypeId, hook: Box<dyn DynHook>, ) -> Result<(), Box<dyn DynHook>>

Object-safe, type-erased form of add_commit_hook.

fn commit_hook_dyn(&self, type_id: TypeId) -> Option<&dyn DynHook>

Object-safe, type-erased form of commit_hook.

fn supports_hooks(&self) -> bool

Whether this operation supports commit hooks.

fn savepoint_parts(&mut self) -> (&mut Connection, HookSlot<'_>)

Simultaneous access to the connection and the commit-hook buffer a nested SAVEPOINT folds into when released. Implementing this is the only thing an operation must do to get the whole of SavepointOperation — with_savepoint, begin_savepoint, and arbitrary-depth nesting — for free.

fn as_executor(&mut self) -> OneTimeExecutor<'_, &mut Connection>

Returns the sqlx::Executor implementation that statements should be executed through.

fn add_commit_hook<H: CommitHook>(&mut self, hook: H) -> Result<(), H>

where Self: Sized,

Registers a commit hook that will run pre_commit before and post_commit after the transaction commits. Returns Ok(()) if the hook was registered, Err(hook) if hooks are not supported.

fn commit_hook<H: CommitHook>(&self) -> Option<&H>

where Self: Sized,

Typed shared access to the currently-accumulating commit hook of type H, if this operation supports commit hooks and one is registered. Returns the hook a subsequent add_commit_hook::<H> call would merge into.

impl<'a, Op: AtomicOperation + ?Sized> AtomicOperationWithTime for OpWithTime<'a, Op>

fn now(&self) -> DateTime<Utc>