Struct CsvStorage 

pub struct CsvStorage {
    pub path: PathBuf,
}

Fields

path: PathBuf

Implementations

impl CsvStorage

pub fn new<T: AsRef<Path>>(path: T) -> Result<Self>

Trait Implementations

impl AlterTable for CsvStorage

fn rename_schema<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, table_name: &'life1 str, new_table_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: Send + 'async_trait,

fn rename_column<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, table_name: &'life1 str, old_column_name: &'life2 str, new_column_name: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, Self: Send + 'async_trait,

fn add_column<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, table_name: &'life1 str, column_def: &'life2 ColumnDef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: Send + 'async_trait,

fn drop_column<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, table_name: &'life1 str, column_name: &'life2 str, if_exists: bool, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: Send + 'async_trait,

impl CustomFunction for CsvStorage

fn fetch_function<'a, 'life0, 'async_trait>( &'a self, _func_name: &'life0 str, ) -> Pin<Box<dyn Future<Output = Result<Option<&'a CustomFunction>, Error>> + Send + 'async_trait>>

where 'a: 'async_trait, 'life0: 'async_trait, Self: Sync + 'async_trait,

fn fetch_all_functions<'a, 'async_trait>( &'a self, ) -> Pin<Box<dyn Future<Output = Result<Vec<&'a CustomFunction>, Error>> + Send + 'async_trait>>

where 'a: 'async_trait, Self: Sync + 'async_trait,

impl CustomFunctionMut for CsvStorage

fn insert_function<'life0, 'async_trait>( &'life0 mut self, _func: CustomFunction, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: Send + 'async_trait,

fn delete_function<'life0, 'life1, 'async_trait>( &'life0 mut self, _func_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Send + 'async_trait,

impl Index for CsvStorage

fn scan_indexed_data<'a, 'life0, 'life1, 'life2, 'async_trait>( &'a self, _table_name: &'life0 str, _index_name: &'life1 str, _asc: Option<bool>, _cmp_value: Option<(&'life2 IndexOperator, Value)>, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<(Key, DataRow), Error>> + Send + 'a>>, Error>> + Send + 'async_trait>>

where 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: Sync + 'async_trait,

impl IndexMut for CsvStorage

fn create_index<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, _table_name: &'life1 str, _index_name: &'life2 str, _column: &'life3 OrderByExpr, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, Self: Send + 'async_trait,

fn drop_index<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, _table_name: &'life1 str, _index_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: Send + 'async_trait,

impl Metadata for CsvStorage

fn scan_table_meta<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Iterator<Item = Result<(String, BTreeMap<String, Value>), Error>>>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: Sync + 'async_trait,

impl Store for CsvStorage

fn fetch_schema<'life0, 'life1, 'async_trait>( &'life0 self, table_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Schema>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn fetch_all_schemas<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Schema>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn fetch_data<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, table_name: &'life1 str, target: &'life2 Key, ) -> Pin<Box<dyn Future<Output = Result<Option<DataRow>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn scan_data<'a, 'life0, 'async_trait>( &'a self, table_name: &'life0 str, ) -> Pin<Box<dyn Future<Output = Result<RowIter<'a>>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

fn fetch_referencings<'life0, 'life1, 'async_trait>( &'life0 self, table_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Referencing>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

impl StoreMut for CsvStorage

fn insert_schema<'life0, 'life1, 'async_trait>( &'life0 mut self, schema: &'life1 Schema, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn delete_schema<'life0, 'life1, 'async_trait>( &'life0 mut self, table_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn append_data<'life0, 'life1, 'async_trait>( &'life0 mut self, table_name: &'life1 str, rows: Vec<DataRow>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn insert_data<'life0, 'life1, 'async_trait>( &'life0 mut self, table_name: &'life1 str, rows: Vec<(Key, DataRow)>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn delete_data<'life0, 'life1, 'async_trait>( &'life0 mut self, table_name: &'life1 str, keys: Vec<Key>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Transaction for CsvStorage

fn begin<'life0, 'async_trait>( &'life0 mut self, autocommit: bool, ) -> Pin<Box<dyn Future<Output = Result<bool, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: Send + 'async_trait,

fn rollback<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: Send + 'async_trait,

fn commit<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: Send + 'async_trait,