pyella 0.1.5

Python bindings for the ella datastore.
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

use std::{future::IntoFuture, sync::Arc};

use ella::{Config, Ella};
use pyo3::{prelude::*, types::PyMapping};

use crate::{
    lazy::PyLazy,
    table::TableAccessor,
    utils::{deserialize_py, serialize_py, wait_for_future},
};

/// Handle for interacting with an ella datastore.
#[derive(Debug, Clone, derive_more::From)]
#[pyclass(name = "Ella")]
pub struct PyElla {
    inner: Arc<Ella>,
}

/// Connect to a remote ella datastore.
///
/// Args:
///     addr: address of the API server
#[pyfunction]
pub fn connect(py: Python, addr: &str) -> crate::Result<PyElla> {
    let inner = Arc::new(wait_for_future(py, ella::connect(addr))?);
    Ok(PyElla { inner })
}

/// Open the datastore at the given path.
///
/// Args:
///     root: Path to the datastore.
///     serve: If not `None` then start an API server on the given address.
///     config: Config used to create the datastore if `create` is `True`.
///     create: If `True` then create the datastore if it doesn't exist.
#[pyfunction]
#[pyo3(signature = (root, serve="127.0.0.1:50052".to_string(), config=None, create=false))]
pub fn open(
    py: Python,
    root: String,
    serve: Option<String>,
    config: Option<&PyMapping>,
    create: bool,
) -> PyResult<PyElla> {
    let config = if let Some(config) = config {
        deserialize_py(py, &config.to_object(py))?
    } else {
        Config::default()
    };
    let inner = if create {
        let mut f = ella::open(root).or_create(config);
        if let Some(serve) = serve {
            f = f.and_serve(serve)?;
        }
        wait_for_future(py, f.into_future())
    } else {
        let mut f = ella::open(root);

        if let Some(serve) = serve {
            f = f.and_serve(serve)?;
        }
        wait_for_future(py, f.into_future())
    }?;

    Ok(PyElla {
        inner: Arc::new(inner),
    })
}

#[pymethods]
impl PyElla {
    /// Get or create datastore tables.
    #[getter]
    fn tables(&self) -> TableAccessor {
        self.inner.clone().into()
    }

    /// Create a new lazily evaluated query.
    ///
    /// Args:
    ///     sql: SQL expression used to generate the query
    fn query(&self, py: Python, sql: String) -> PyResult<PyLazy> {
        let plan = wait_for_future(py, self.inner.query(sql))?;
        Ok(plan.into())
    }

    /// Shutdown the datastore.
    fn shutdown(&self, py: Python) -> crate::Result<()> {
        wait_for_future(py, (*self.inner).clone().shutdown())
    }

    /// Get the datastore configuration.
    #[getter]
    fn config(&self, py: Python) -> PyResult<PyObject> {
        serialize_py(py, &self.inner.config())
    }

    fn __enter__<'py>(this: PyRef<'py, Self>, _py: Python<'py>) -> PyResult<PyRef<'py, Self>> {
        Ok(this)
    }

    fn __exit__(
        &self,
        py: Python,
        _exc_type: &PyAny,
        _exc_value: &PyAny,
        _traceback: &PyAny,
    ) -> ella::Result<()> {
        self.shutdown(py)
    }
}

impl Drop for PyElla {
    fn drop(&mut self) {
        Python::with_gil(|py| {
            if let Err(err) = self.shutdown(py) {
                PyErr::from(err).restore(py);
            }
        })
    }
}