Struct CloudOutboxRecords 

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

Implementations

impl<'connection> CloudOutboxRecords<'connection>

pub fn consume_created_upload_handoff( &self, package: &AudiencePackage, binding: &RowBlobLocatorBinding, ) -> Result<bool, DbError>

pub fn created_upload_handoff( &self, table: &str, row_id: &str, column: &str, row_stamp: &str, ) -> Result<Option<StoreWriteRemoteBlob>, DbError>

pub fn upload_entries_for_rows( &self, rows: &[RowBlobRef], ) -> Result<Vec<OutboxEntry>, DbError>

pub fn upload_entries_for_root( &self, gates: &Gates, tables: &[SyncedTable], root_table: &str, root_id: &str, ) -> Result<Vec<OutboxEntry>, DbError>

pub fn enqueue_upload( &self, root_table: &str, root_id: &str, root_label: &str, row: &RowBlobRef, source_path: &Path, retain_pinned: bool, created_at: &str, ) -> Result<(), DbError>

pub fn enqueue_delete( &self, stored: &StoredBlobRef, created_at: &str, ) -> Result<(), DbError>

pub fn remove_entry(&self, entry: &OutboxEntry) -> Result<(), DbError>

pub fn finish_cancelled_upload( &self, entry: &OutboxEntry, ) -> Result<bool, DbError>