ella 0.1.5

A streaming time-series datastore for low-latency applications.
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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122

use std::future::IntoFuture;

use ella_engine::registry::Id;
use futures::{future::BoxFuture, FutureExt};

use crate::Ella;

#[must_use]
#[derive(Debug)]
pub struct GetCatalog<'a> {
    inner: &'a Ella,
    catalog: Id<'a>,
}

impl<'a> GetCatalog<'a> {
    pub(crate) fn new(inner: &'a Ella, catalog: Id<'a>) -> Self {
        Self { inner, catalog }
    }

    pub fn or_create(self) -> GetOrCreateCatalog<'a> {
        GetOrCreateCatalog {
            inner: self.inner,
            catalog: self.catalog,
        }
    }

    pub fn and_use(self) -> UseCatalog<'a> {
        UseCatalog {
            inner: self.inner,
            catalog: self.catalog,
            create: false,
        }
    }

    pub fn drop(self) -> DropCatalog<'a> {
        DropCatalog {
            inner: self.inner,
            catalog: self.catalog,
            if_exists: false,
            cascade: false,
        }
    }
}

#[must_use]
#[derive(Debug)]
pub struct GetOrCreateCatalog<'a> {
    inner: &'a Ella,
    catalog: Id<'a>,
}

impl<'a> GetOrCreateCatalog<'a> {
    pub fn and_use(self) -> UseCatalog<'a> {
        UseCatalog {
            inner: self.inner,
            catalog: self.catalog,
            create: true,
        }
    }
}

#[must_use]
#[derive(Debug)]
pub struct UseCatalog<'a> {
    inner: &'a Ella,
    catalog: Id<'a>,
    create: bool,
}

impl<'a> IntoFuture for UseCatalog<'a> {
    type Output = crate::Result<Ella>;
    type IntoFuture = BoxFuture<'a, Self::Output>;

    fn into_future(self) -> Self::IntoFuture {
        async move {
            let mut this = self.inner.clone();
            if self.create {
                this.create_catalog(self.catalog.clone(), true).await?;
            }
            this.use_catalog(self.catalog).await
        }
        .boxed()
    }
}

#[must_use]
#[derive(Debug)]
pub struct DropCatalog<'a> {
    inner: &'a Ella,
    catalog: Id<'a>,
    if_exists: bool,
    cascade: bool,
}

impl<'a> DropCatalog<'a> {
    pub fn if_exists(mut self) -> Self {
        self.if_exists = true;
        self
    }

    pub fn cascade(mut self) -> Self {
        self.cascade = true;
        self
    }
}

impl<'a> IntoFuture for DropCatalog<'a> {
    type Output = crate::Result<&'a Ella>;
    type IntoFuture = BoxFuture<'a, Self::Output>;

    fn into_future(self) -> Self::IntoFuture {
        async move {
            let if_exists = if self.if_exists { "IF EXISTS " } else { "" };
            let cascade = if self.cascade { " CASCADE" } else { "" };
            self.inner
                .execute(format!("DROP CATALOG {if_exists}{}{cascade}", self.catalog))
                .await?;
            Ok(self.inner)
        }
        .boxed()
    }
}