Struct Table 

pub struct Table { /* private fields */ }

Typed access to one table-backed Cobble column family.

Implementations

impl Table

pub fn create( db: Arc<Db>, name: impl Into<String>, schema: TableSchema, ) -> Result<Self>

Create a table or reopen it when its persisted schema is identical.

pub fn open(db: Arc<Db>, name: impl Into<String>) -> Result<Self>

Open a table from metadata stored in its column-family options.

pub fn schema(&self) -> &TableSchema

Return the persisted semantic schema of this table.

pub fn metrics(&self) -> Vec<MetricSample>

Return metrics for this table’s backing database shard.

Metrics are collected at database scope and include all column families; they are not filtered to this table’s physical column family.

pub fn key_builder(&self) -> TableKeyBuilder

Start building one primary key in schema order.

pub fn project_by_names<S: AsRef<str>>( &self, field_names: &[S], ) -> Result<TableProjection>

Compile a reusable read projection from top-level field names.

pub fn put(&self, row: &[Value]) -> Result<()>

Write one full row in schema field order.

pub fn put_with_options( &self, row: &[Value], options: &WriteOptions, ) -> Result<()>

Write one full row with caller options safely rebound to this table.

pub fn delete(&self, key: &TableKey) -> Result<()>

Delete one complete row.

pub fn delete_batch(&self, keys: &[TableKey]) -> Result<()>

Delete complete rows in one batch without cloning encoded keys.

pub fn get(&self, key: &TableKey) -> Result<Option<Vec<Value>>>

Read one row by primary key.

pub fn multi_get(&self, keys: &[TableKey]) -> Result<Vec<Option<Vec<Value>>>>

Read many primary keys with one core multi-get, preserving order and duplicates.

pub fn scan(&self, bucket: u16) -> Result<TableScan>

Scan all rows in one bucket.

pub fn scan_bounds( &self, bucket: u16, start_key_inclusive: Option<&TableKey>, end_key_exclusive: Option<&TableKey>, ) -> Result<TableScan>

Scan one bucket from an inclusive primary-key bound to an exclusive bound.

pub fn snapshot(&self) -> Result<u64>

Start an asynchronous shard snapshot, returning its id immediately.

pub fn snapshot_with_callback<F>(&self, callback: F) -> Result<u64>

where F: Fn(Result<ShardSnapshotMetadata>) + Send + Sync + 'static,

Receive either the completed shard input or its publication error.

pub fn snapshot_and_wait(&self) -> Result<ShardSnapshotMetadata>

Create a snapshot and wait for its callback, without polling.

pub fn shard_snapshot_metadata( &self, snapshot_id: u64, ) -> Result<ShardSnapshotMetadata>

Return complete metadata for a completed shard snapshot.

pub fn refresh_schema(&mut self) -> Result<bool>

Refresh this writable handle from the local database schema.

This does not consult a catalog or track a moving catalog version. Existing projections remain bound to the layout they were compiled with and must be rebuilt after a change.