dutils 0.1.14

I am speed
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58

use tracing::warn;
use super::*;

pub trait RocksDbTablesDef: Sized {
    const TABLES: &[&str];
    const VERSION: usize;

    fn table_info(&self, cf: &str) -> TableInfo;
    fn make_tables(db: RocksDB) -> Self;

    fn open(path: &str) -> anyhow::Result<Self> {
        let db = RocksDB::open_db(
            path,
            [
                &[internal::TABLE_INFO_CF, internal::DB_INFO_CF],
                Self::TABLES,
            ]
            .into_iter()
            .flatten(),
        );

        let mut tables = Self::make_tables(db.clone());

        let db_info = db.table::<(), UsingSerde<DbInfo>>(internal::DB_INFO_CF);
        if let Some(db_info) = db_info.get(()) {
            if db_info.version > Self::VERSION {
                bail!(
                    "Version of DB '{}' is not supported: {}",
                    std::any::type_name::<Self>(),
                    db_info.version
                );
            }
            if db_info.version < Self::VERSION {
                warn!(
                    "Db '{}' version is outdated. Trying to upgrade from {} to {}",
                    std::any::type_name::<Self>(),
                    db_info.version,
                    Self::VERSION
                );
                tables.migrate(db_info.version)?;
            }
        }

        db_info.insert(
            (),
            DbInfo {
                version: Self::VERSION,
            },
        );

        Ok(tables)
    }

    fn migrate(&mut self, version: usize) -> anyhow::Result<()> {
        let _ = version;
        bail!("Migration from version {version} is not supported")
    }
}