Struct FlushOp 

pub struct FlushOp<'a>(/* private fields */);

Restricted view of the batch op handed to flush — everything an AtomicOperation can do, and nothing else.

Committing belongs to the runner: after flush returns Ok, the checkpoint is written and the transaction commits — items, work and pointer land atomically. There is no access to the raw es_entity::DbOp, mirroring BatchOp/IsolatedOp’s sealing.

Trait Implementations

impl AtomicOperation for FlushOp<'_>

Full delegation to the inner es_entity::DbOp — see the notes on BatchOp’s impl for why every provided method is delegated too. add_commit_hook delegation is what lets a flush body publish onto the batch op (e.g. publish_all_persisted) with the events buffered on the runner’s commit.

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.