sync/io.github.maniramezan.kommon.sync/SyncEngine/sync

sync

suspend fun <E : SyncableEntity<E>, U, D, C> sync(adapter: SyncResourceAdapter<E, U, D, C>, limit: Int = DEFAULT_LIMIT): Result<Unit>

Runs a single resource's sync pass with one unbounded push and response pages of limit rows.

suspend fun <E : SyncableEntity<E>, U, D, C> sync(adapter: SyncResourceAdapter<E, U, D, C>, limit: Int = DEFAULT_LIMIT, pushBatchSize: Int): Result<Unit>

Runs a resource with at most pushBatchSize pending rows per request, counting upserts and deletes together. limit still controls response page size and is sent unchanged.

Enable only when the server accepts independent partial pushes and retries by stable row keys. Each batch's acknowledgements, response pages, and full-snapshot reconciliation finish before the next batch starts from the saved cursor. A failure stops this resource; already persisted batches remain committed, and pending rows can be retried on the next pass.

Pending rows are snapshotted once per pass, bounding its work even if local edits continue. Rows edited in flight remain pending through the acknowledgement guard. This bounds network request size; SyncResourceAdapter.pending still loads the complete pending list into memory. Empty pending lists still issue one pull request. Telemetry reports totals across all batches.