Struct PostgresChunkTransactionManager 

pub struct PostgresChunkTransactionManager { /* private fields */ }

PostgreSQL same-resource chunk transaction manager.

Each launched chunk receives a single adapter-owned connection. Enlisted business statements and provider-produced checkpoint/context are committed with step counters and the optimistic version.

Implementations

impl PostgresChunkTransactionManager

pub const fn new( repository: PostgresJobRepository, state_provider: Arc<dyn PostgresChunkStateProvider>, ) -> Self

Constructs a same-resource transaction manager.

pub async fn load_committed_state( &self, context: ChunkTransactionContext, ) -> Result<PostgresDurableStepState, RepositoryError>

Reads the authoritative committed state through a healthy connection.

Errors

Returns a redacted repository failure when the execution is missing or its durable state cannot be validated.

Trait Implementations

impl ChunkTransactionManager for PostgresChunkTransactionManager

fn begin( &self, ) -> BoxFuture<'_, Result<Box<dyn ChunkTransaction + '_>, ChunkTransactionError>>

Starts one transaction for a bounded chunk attempt.

fn begin_for( &self, context: ChunkTransactionContext, ) -> BoxFuture<'_, Result<Box<dyn ChunkTransaction + '_>, ChunkTransactionError>>

Starts one transaction bound to a durable repository execution.

fn inherited_progress( &self, context: ChunkTransactionContext, ) -> BoxFuture<'_, Result<InheritedStepProgress, ChunkTransactionError>>

Returns the durable progress this step attempt inherits.

impl Clone for PostgresChunkTransactionManager

fn clone(&self) -> PostgresChunkTransactionManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresChunkTransactionManager

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

Formats the value using the given formatter.