Struct garage_table::table::Table

pub struct Table<F: TableSchema, R: TableReplication> {
    pub system: Arc<System>,
    pub data: Arc<TableData<F, R>>,
    pub merkle_updater: Arc<MerkleUpdater<F, R>>,
    pub syncer: Arc<TableSyncer<F, R>>,
    /* private fields */
}

Fields

system: Arc<System>

data: Arc<TableData<F, R>>

merkle_updater: Arc<MerkleUpdater<F, R>>

syncer: Arc<TableSyncer<F, R>>

Implementations

impl<F: TableSchema, R: TableReplication> Table<F, R>

pub fn new(instance: F, replication: R, system: Arc<System>, db: &Db) -> Arc<Self>

pub fn spawn_workers(self: &Arc<Self>, bg: &BackgroundRunner)

pub async fn insert(&self, e: &F::E) -> Result<(), Error>

pub fn queue_insert( &self, tx: &mut Transaction<'_>, e: &F::E ) -> TxResult<(), Error>

Insert item locally

pub async fn insert_many<I, IE>(&self, entries: I) -> Result<(), Error>where I: IntoIterator<Item = IE> + Send + Sync, IE: Borrow<F::E> + Send + Sync,

pub async fn get( self: &Arc<Self>, partition_key: &F::P, sort_key: &F::S ) -> Result<Option<F::E>, Error>

pub async fn get_range( self: &Arc<Self>, partition_key: &F::P, begin_sort_key: Option<F::S>, filter: Option<F::Filter>, limit: usize, enumeration_order: EnumerationOrder ) -> Result<Vec<F::E>, Error>