Struct SyncEngine 

pub struct SyncEngine<A: Authenticator> { /* private fields */ }

Runtime sync engine for the explicit Postgres-to-Salesforce vertical slice.

Implementations

impl<A: Authenticator> SyncEngine<A>

pub fn builder(salesforce_client: ForceClient<A>) -> SyncEngineBuilder<A>

Creates a builder for a runtime using the given Salesforce client.

pub async fn run_capture_postgres_once(&self) -> Result<usize, ForceSyncError>

Captures a single configured batch from the Postgres outbox.

Errors

Returns an error if the outbox capture fails.

pub async fn run_apply_once(&self) -> Result<usize, ForceSyncError>

Leases and applies one configured batch of ready tasks.

Errors

Returns an error if task loading or control-plane updates fail.

pub async fn run_reconcile_once(&self) -> Result<usize, ForceSyncError>

Runs one reconciliation pass and enqueues repair tasks for drift.

Errors

Returns an error if drift detection or task insertion fails.

Trait Implementations

impl<A: Clone + Authenticator> Clone for SyncEngine<A>

fn clone(&self) -> SyncEngine<A>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A: Debug + Authenticator> Debug for SyncEngine<A>

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

Formats the value using the given formatter.