ducklake 0.0.9

Rust SDK for DuckLake.
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

use crate::catalog::Catalog;
use crate::{DucklakeError, DucklakeResult};

mod column;
mod schema;
mod table;

pub(crate) use schema::SchemaView;
pub(crate) use table::TableView;

/* ---------------------------------------- TRY INTO REF --------------------------------------- */

pub trait TryIntoRef<Ref, Container = Catalog> {
    type Error: std::error::Error;

    fn try_into_ref(self, container: &Container) -> Result<Ref, Self::Error>;
}

impl<Ref: Copy, Container> TryIntoRef<Ref, Container> for Ref {
    type Error = !;

    fn try_into_ref(self, _container: &Container) -> Result<Ref, Self::Error> {
        Ok(self)
    }
}

/* ------------------------------------------- UTILS ------------------------------------------- */

fn upsert_tag(tags: &mut Vec<crate::Tag>, tag: crate::Tag) {
    tags.retain(|t| t.key != tag.key);
    tags.push(tag);
}

fn remove_tag(tags: &mut Vec<crate::Tag>, key: &str) -> DucklakeResult<()> {
    if tags.extract_if(.., |t| t.key == key).count() == 0 {
        return Err(DucklakeError::NotFound {
            entity: "tag",
            name: key.to_string(),
        });
    }
    Ok(())
}