Struct StoreRowWrites 

pub struct StoreRowWrites { /* private fields */ }

Implementations

impl StoreRowWrites

pub fn new(database: StoreDatabase) -> Self

pub fn requires_routing_encryption(&self) -> bool

pub fn subscribe_committed_changes(&self) -> Receiver<Arc<CommittedChanges>>

pub async fn pending_writes(&self) -> Result<Vec<PendingWrite>, DbError>

pub async fn blocked_writes(&self) -> Result<Vec<PendingWrite>, DbError>

pub async fn retry_blocked_write( &self, write_id: &WriteId, ) -> Result<Vec<WriteId>, DbError>

pub async fn discard_blocked_write( &self, write_id: &WriteId, ) -> Result<BlockedWriteDiscard, DbError>

pub async fn write_status( &self, write_id: &WriteId, ) -> Result<WriteStatus, DbError>

pub async fn subscribe_write_status( &self, write_id: &WriteId, ) -> Result<Receiver<WriteStatus>, DbError>

pub async fn execute<R, E>( &self, operation: HostWriteOperation<R, E>, routing_encryption: Option<EncryptionService>, blob_staging: Option<Box<dyn AudienceBlobMoveStaging>>, ) -> Result<WriteReceipt<R>, HostWriteError<E>>

where R: Send + 'static, E: Send + 'static,

pub async fn store_write_partition_for_test( &self, write_id: &WriteId, ) -> Result<Vec<u8>, DbError>

pub async fn write_blob_lease_count_for_test( &self, write_id: &WriteId, ) -> Result<i64, DbError>

pub async fn store_write_journal_counts_for_test( &self, ) -> Result<(i64, i64), DbError>

pub async fn cleanup_intent_count_for_test( &self, namespace: &str, blob_id: &str, ) -> Result<i64, DbError>

pub async fn coven_table_exists_for_test( &self, table: DatabaseTestTable, ) -> Result<bool, DbError>

pub async fn install_store_write_failure_trigger_for_test( &self, ) -> Result<(), DbError>

pub async fn remove_store_write_failure_trigger_for_test( &self, ) -> Result<(), DbError>

pub async fn write_blob_facts_for_test( &self, write_id: WriteId, ) -> Result<String, DbError>

Trait Implementations

impl Clone for StoreRowWrites

fn clone(&self) -> StoreRowWrites

Returns a duplicate of the value.

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

Performs copy-assignment from source.