Struct PgDatasetReservation 

pub struct PgDatasetReservation<'connection> { /* private fields */ }

An accepted writer holds process exclusion until its last synchronous effect returns. Dropping it leaves the durable reservation for reconciliation.

Implementations

impl PgDatasetReservation<'_>

pub fn attempt_id(&self) -> Uuid

pub fn requires_output_cleanup(&self) -> bool

pub fn bind_version( &mut self, asset: &AssetRecord, version: &AssetVersionRecord, ) -> Result<(), CoreError>

Binds version coordinates chosen after reservation, before any Lake effect.

pub fn release_after_cleanup(self) -> Result<(), CoreError>

Called only after this attempt’s source and physical output cleanup have completed. Consuming the writer excludes subsequent effects through it.

Trait Implementations

impl DatasetOutputAuthority for PgDatasetReservation<'_>

fn authorize_scratch_root(&mut self, identity: &str) -> Result<(), CoreError>

Bind or verify the opaque configured source-root identity before cleanup.

fn attempt_id(&self) -> Uuid

fn output_version(&self) -> Result<&DatasetOutputVersion, CoreError>

fn ensure_current(&mut self) -> Result<(), CoreError>

impl DatasetWriteAuthority for PgDatasetReservation<'_>

fn record_creation_intent(&mut self) -> Result<(), CoreError>

Persist possible output creation before issuing its Lake statement.

impl Debug for PgDatasetReservation<'_>

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

Formats the value using the given formatter.