Struct PendingRows 

pub struct PendingRows(/* private fields */);

Rows queued on an open transaction for one batched multi-row INSERT at flush/commit time, instead of one INSERT per write. Cheap to clone — it shares the same underlying buffer, which matters when a nested transaction() call reuses its parent’s queue.

Implementations

impl PendingRows

pub fn new() -> Self

pub async fn push( &self, tenant: &TenantId, project: &ProjectId, author: &UserTokenClaims, fhir_version: &SupportedFHIRVersions, resource: Resource, deleted: bool, request_method: &'static str, fhir_method: FHIRMethod, )

Buffers a row. Unlike [insert], resource must be an owned copy — this data has to outlive the call that queued it, until flush runs.

pub async fn flush( &self, tx: &Arc<Mutex<Transaction<'static, Postgres>>>, ) -> Result<(), OperationOutcomeError>

Drains and inserts every buffered row, so a subsequent read on the same transaction observes prior writes that haven’t reached Postgres yet. The internal lock is released before tx is locked, so the two are never held simultaneously.

Errors

Returns an OperationOutcomeError if inserting the buffered rows into Postgres fails.

Trait Implementations

impl Clone for PendingRows

fn clone(&self) -> PendingRows

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PendingRows

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

Formats the value using the given formatter.

impl Default for PendingRows

fn default() -> PendingRows

Returns the “default value” for a type.