Struct IsolatedOp 

pub struct IsolatedOp<'inv> { /* private fields */ }

An op holding exactly this event’s work, fenced from the batch history. Implements AtomicOperation. The only exit is commit — isolation from future events is guaranteed by construction, and (as with BatchOp) no mutable access to the raw es_entity::DbOp exists, so the op can only land through the runner.

Implementations

impl<'inv> IsolatedOp<'inv>

pub fn commit(self) -> Handled<'inv>

Land my work and my checkpoint, atomically, when the invocation returns.

Methods from Deref<Target = DbOp<'static>>

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

Returns the optionally cached chrono::DateTime

Trait Implementations

impl AtomicOperation for IsolatedOp<'_>

Full delegation to the inner es_entity::DbOp — see the notes on BatchOp’s impl for why every provided method is delegated too, and why this is deliberately the only mutable surface (no DerefMut).

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 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>

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>

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.

fn supports_hooks(&self) -> bool

Whether this operation supports commit hooks.

impl Deref for IsolatedOp<'_>

type Target = DbOp<'static>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.