Struct StructuredDb 

pub struct StructuredDb { /* private fields */ }

Implementations

impl StructuredDb

pub fn open( config: Config, bucket_ranges: Vec<RangeInclusive<u16>>, ) -> Result<Self>

pub fn open_from_snapshot( config: Config, snapshot_id: u64, db_id: String, ) -> Result<Self>

pub fn open_from_snapshot_with_resolver( config: Config, snapshot_id: u64, db_id: String, resolver: Option<Arc<dyn MergeOperatorResolver>>, ) -> Result<Self>

pub fn resume(config: Config, db_id: String) -> Result<Self>

pub fn resume_with_resolver( config: Config, db_id: String, resolver: Option<Arc<dyn MergeOperatorResolver>>, ) -> Result<Self>

pub fn id(&self) -> &str

pub fn current_schema(&self) -> StructuredSchema

pub fn update_schema(&mut self) -> StructuredSchemaBuilder<'_, Self>

pub fn reload_schema(&mut self) -> Result<()>

pub fn apply_schema( &mut self, structured_schema: StructuredSchema, ) -> Result<StructuredSchema>

pub fn put<K, V>( &self, bucket: u16, key: K, column: u16, value: V, ) -> Result<()>

where K: AsRef<[u8]>, V: Into<StructuredColumnValue>,

pub fn put_with_options<K, V>( &self, bucket: u16, key: K, column: u16, value: V, options: &WriteOptions, ) -> Result<()>

where K: AsRef<[u8]>, V: Into<StructuredColumnValue>,

pub fn merge<K, V>( &self, bucket: u16, key: K, column: u16, value: V, ) -> Result<()>

where K: AsRef<[u8]>, V: Into<StructuredColumnValue>,

pub fn merge_with_options<K, V>( &self, bucket: u16, key: K, column: u16, value: V, options: &WriteOptions, ) -> Result<()>

where K: AsRef<[u8]>, V: Into<StructuredColumnValue>,

pub fn delete<K>(&self, bucket: u16, key: K, column: u16) -> Result<()>

where K: AsRef<[u8]>,

pub fn new_write_batch(&self) -> StructuredWriteBatch

pub fn write_batch(&self, batch: StructuredWriteBatch) -> Result<()>

pub fn get<K>( &self, bucket: u16, key: K, ) -> Result<Option<Vec<Option<StructuredColumnValue>>>>

where K: AsRef<[u8]>,

pub fn get_with_options<K>( &self, bucket: u16, key: K, options: &ReadOptions, ) -> Result<Option<Vec<Option<StructuredColumnValue>>>>

where K: AsRef<[u8]>,

pub fn scan<'a>( &'a self, bucket: u16, range: Range<&[u8]>, ) -> Result<StructuredDbIterator<'a>>

pub fn scan_with_options<'a>( &'a self, bucket: u16, range: Range<&[u8]>, options: &ScanOptions, ) -> Result<StructuredDbIterator<'a>>

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

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

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

pub fn expire_snapshot(&self, snapshot_id: u64) -> Result<bool>

pub fn retain_snapshot(&self, snapshot_id: u64) -> bool

pub fn shard_snapshot_input( &self, snapshot_id: u64, ) -> Result<ShardSnapshotInput>

pub fn set_time(&self, next: u32)

pub fn now_seconds(&self) -> u32

pub fn get_raw_with_options( &self, bucket: u16, key: &[u8], options: &ReadOptions, ) -> Result<Option<Vec<Option<Bytes>>>>

pub fn scan_raw<'a>( &'a self, bucket: u16, range: Range<&[u8]>, options: &ScanOptions, ) -> Result<DbIterator<'a>>

pub fn close(&self) -> Result<()>