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. Artificial clock time if the operation’s clock is artificial
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 as_executor(&mut self) -> &mut PgConnection

Returns the sqlx::Executor implementation. The desired way to represent this would actually be as a GAT:

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

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.

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

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