Struct PgStore 

pub struct PgStore { /* private fields */ }

PostgreSQL-backed store for sync engine work.

Implementations

impl PgStore

pub async fn advance_checkpoint_if_greater( &self, stream_name: impl AsRef<str>, cursor_position: i64, cursor: impl AsRef<str>, ) -> Result<u64, ForceSyncError>

Advances a checkpoint only if the new position is greater than the stored one.

Returns the number of affected rows.

Errors

Returns an error if the database write fails.

pub async fn advance_checkpoint_if_greater_in_tx<C>( client: &C, stream_name: &str, cursor_position: i64, cursor: &str, ) -> Result<u64, ForceSyncError>

where C: GenericClient + Sync + ?Sized,

Advances a checkpoint in an existing transaction when the position increases.

Errors

Returns an error if the database write fails.

pub async fn get_checkpoint( &self, stream_name: impl AsRef<str>, ) -> Result<Option<CheckpointState>, ForceSyncError>

Loads the stored checkpoint for a stream, if one exists.

Errors

Returns an error if the database query fails.

impl PgStore

pub async fn insert_conflict( &self, conflict: &SyncConflict, ) -> Result<i64, ForceSyncError>

Inserts a conflict row and returns its database identifier.

Errors

Returns an error if the database write fails.

impl PgStore

pub async fn insert_dead_letter( &self, dead_letter: &DeadLetter, ) -> Result<i64, ForceSyncError>

Inserts a dead-letter row and returns its database identifier.

Errors

Returns an error if the database write fails.

impl PgStore

pub async fn append_journal( &self, envelope: &ChangeEnvelope, ) -> Result<i64, ForceSyncError>

Appends a journal entry and returns its database identifier.

Errors

Returns an error if the cursor is missing or the database write fails.

pub async fn append_journal_if_new( &self, envelope: &ChangeEnvelope, ) -> Result<AppendResult, ForceSyncError>

Appends a journal entry if the (source, source_cursor) pair is new.

Errors

Returns an error if the cursor is missing or the database write fails.

pub async fn append_journal_in_tx<C>( client: &C, envelope: &ChangeEnvelope, ) -> Result<i64, ForceSyncError>

where C: GenericClient + Sync + ?Sized,

Appends a journal row in an existing transaction.

This helper exists so same-transaction workflows can remain atomic without forcing the caller through another store method.

Errors

Returns an error if the cursor is missing or the database write fails.

pub async fn append_journal_if_new_in_tx<C>( client: &C, envelope: &ChangeEnvelope, ) -> Result<AppendResult, ForceSyncError>

where C: GenericClient + Sync + ?Sized,

Appends a journal row in an existing transaction, skipping duplicates.

Errors

Returns an error if the cursor is missing or the database write fails.

impl PgStore

pub async fn put_link(&self, link: &SyncLink) -> Result<i64, ForceSyncError>

Upserts a link row and returns the database identifier.

Errors

Returns an error if the database write fails.

pub async fn get_link( &self, tenant: &str, object_name: &str, external_id: &str, ) -> Result<Option<SyncLink>, ForceSyncError>

Loads a link row by canonical identity.

Errors

Returns an error if the database query fails.

impl PgStore

pub const fn new(pool: Pool) -> Self

Creates a new store wrapper around an existing connection pool.

pub const fn pool(&self) -> &Pool

Returns the backing PostgreSQL pool.

pub async fn with_client<T, F, Fut>(&self, f: F) -> Result<T, ForceSyncError>

where F: FnOnce(Client) -> Fut, Fut: Future<Output = Result<T, Error>>,

Runs an operation against a pooled PostgreSQL client.

Errors

Returns a pool or query error if the client cannot be acquired or the callback fails.

pub async fn with_transaction<T, F>(&self, f: F) -> Result<T, ForceSyncError>

where F: for<'a> FnOnce(&'a Transaction<'a>) -> BoxFuture<'a, Result<T, ForceSyncError>>,

Runs an operation inside a PostgreSQL transaction.

Errors

Returns a pool or query error if the transaction cannot be opened or the callback fails.

impl PgStore

pub async fn enqueue_apply_task( &self, journal_id: i64, priority: i32, ) -> Result<i64, ForceSyncError>

Enqueues an apply task for a journal row.

Errors

Returns an error if the database write fails.

pub async fn lease_ready_tasks( &self, worker_id: &str, limit: i64, lease_for: Duration, ) -> Result<Vec<LeasedTask>, ForceSyncError>

Leases ready tasks for a worker.

Errors

Returns an error if the lease duration is invalid or the database write fails.

pub async fn ack_task(&self, task_id: i64) -> Result<u64, ForceSyncError>

Acknowledges a completed task administratively, without lease-owner checks.

Errors

Returns an error if the database write fails.

pub async fn ack_task_for_worker( &self, worker_id: &str, task_id: i64, ) -> Result<u64, ForceSyncError>

Acknowledges a completed task for the current lease owner.

Returns 0 if the task is no longer leased by worker_id.

Errors

Returns an error if the database write fails.

pub async fn retry_task( &self, task_id: i64, next_attempt_at: DateTime<Utc>, error: impl AsRef<str>, ) -> Result<u64, ForceSyncError>

Marks a task for retry at a future time administratively, without lease-owner checks.

Errors

Returns an error if the database write fails.

pub async fn retry_task_for_worker( &self, worker_id: &str, task_id: i64, next_attempt_at: DateTime<Utc>, error: impl AsRef<str>, ) -> Result<u64, ForceSyncError>

Marks a task for retry for the current lease owner.

Returns 0 if the task is no longer leased by worker_id.

Errors

Returns an error if the database write fails.

pub async fn fail_task( &self, task_id: i64, error: impl AsRef<str>, ) -> Result<u64, ForceSyncError>

Marks a task as failed administratively, without lease-owner checks.

Errors

Returns an error if the database write fails.

pub async fn fail_task_for_worker( &self, worker_id: &str, task_id: i64, error: impl AsRef<str>, ) -> Result<u64, ForceSyncError>

Marks a task as failed for the current lease owner.

Returns 0 if the task is no longer leased by worker_id.

Errors

Returns an error if the database write fails.

pub async fn enqueue_apply_task_in_tx<C>( client: &C, journal_id: i64, priority: i32, ) -> Result<i64, ForceSyncError>

where C: GenericClient + Sync + ?Sized,

Enqueues an apply task inside an existing transaction.

Errors

Returns an error if the database write fails.

pub async fn lease_ready_tasks_in_tx<C>( client: &C, worker_id: &str, limit: i64, lease_for: Duration, ) -> Result<Vec<LeasedTask>, ForceSyncError>

where C: GenericClient + Sync + ?Sized,

Leases ready tasks inside an existing transaction.

Errors

Returns an error if the lease duration is invalid or the database write fails.

pub async fn ack_task_in_tx<C>( client: &C, task_id: i64, ) -> Result<u64, ForceSyncError>

where C: GenericClient + Sync + ?Sized,

Acknowledges a completed task inside an existing transaction.

Errors

Returns an error if the database write fails.

pub async fn retry_task_in_tx<C>( client: &C, task_id: i64, next_attempt_at: DateTime<Utc>, error: impl AsRef<str>, ) -> Result<u64, ForceSyncError>

where C: GenericClient + Sync + ?Sized,

Marks a task for retry inside an existing transaction.

Errors

Returns an error if the database write fails.

pub async fn fail_task_in_tx<C>( client: &C, task_id: i64, error: impl AsRef<str>, ) -> Result<u64, ForceSyncError>

where C: GenericClient + Sync + ?Sized,

Marks a task as failed inside an existing transaction.

Errors

Returns an error if the database write fails.

Trait Implementations

impl Clone for PgStore

fn clone(&self) -> PgStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PgStore

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

Formats the value using the given formatter.