Struct StructuredReader 

pub struct StructuredReader { /* private fields */ }

Implementations

impl StructuredReader

pub fn open(read_config: ReaderConfig, global_snapshot_id: u64) -> Result<Self>

pub fn open_current(read_config: ReaderConfig) -> Result<Self>

pub fn current_schema(&self) -> StructuredSchema

pub fn get( &mut self, bucket_id: u16, key: &[u8], ) -> Result<Option<Vec<Option<StructuredColumnValue>>>>

pub fn multi_get<K: AsRef<[u8]>>( &mut self, keys: &[(u16, K)], ) -> Result<Vec<Option<Vec<Option<StructuredColumnValue>>>>>

pub fn multi_get_with_options<K: AsRef<[u8]>>( &mut self, keys: &[(u16, K)], options: &StructuredReadOptions, ) -> Result<Vec<Option<Vec<Option<StructuredColumnValue>>>>>

pub fn get_with_options( &mut self, bucket_id: u16, key: &[u8], options: &StructuredReadOptions, ) -> Result<Option<Vec<Option<StructuredColumnValue>>>>

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

pub fn scan_with_options( &mut self, bucket_id: u16, range: Range<&[u8]>, options: &StructuredScanOptions, ) -> Result<StructuredDbIterator>

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

pub fn register_schema_transform<F, T>( &mut self, transform_type: impl Into<String>, factory: F, ) -> Result<()>

where F: Fn(&[u8]) -> Result<T> + Send + Sync + 'static, T: Fn(Option<Bytes>) -> Result<Option<Bytes>> + Send + Sync + 'static,

Register a factory for raw single-column transform specifications.

pub fn read_mode(&self) -> &'static str

pub fn configured_snapshot_id(&self) -> Option<u64>

pub fn current_global_snapshot(&self) -> &GlobalSnapshotManifest

pub fn list_global_snapshots(&self) -> Result<Vec<GlobalSnapshotSummary>>

pub fn list_global_snapshot_manifests( &self, ) -> Result<Vec<GlobalSnapshotManifest>>