datasources 0.1.5

Async datasource interfaces, middleware, registry, and test doubles
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

#![allow(non_local_definitions)]

use crate::sabi_value::{SabiCell, SabiResponse, SabiValue};
use abi_stable::std_types::{RBox, ROption, RResult, RString, RVec};

#[abi_stable::sabi_trait]
pub trait SabiReader: Send + Sync {
    fn current(&self) -> ROption<RVec<SabiCell>>;
    fn next(&self) -> RResult<bool, RString>;
    fn next_result(&self) -> RResult<bool, RString>;
}

pub type SabiReaderBox = SabiReader_TO<'static, RBox<()>>;

#[abi_stable::sabi_trait]
pub trait SabiTransaction: Send + Sync {
    fn isolation(&self) -> u8;
    fn commit(&self) -> RResult<(), RString>;
    fn abort(&self) -> RResult<(), RString>;
}

pub type SabiTransactionBox = SabiTransaction_TO<'static, RBox<()>>;

#[abi_stable::sabi_trait]
pub trait SabiCommand: Send + Sync {
    fn execute(
        &self,
        text: RString,
        parameters: ROption<RVec<crate::sabi_value::SabiParameter>>,
    ) -> RResult<SabiResponse, RString>;
    fn execute_reader(
        &self,
        text: RString,
        parameters: ROption<RVec<crate::sabi_value::SabiParameter>>,
    ) -> RResult<SabiReaderBox, RString>;
}

pub type SabiCommandBox = SabiCommand_TO<'static, RBox<()>>;

#[abi_stable::sabi_trait]
pub trait SabiConnection: Send + Sync {
    fn slot(&self) -> u64;
    fn provider(&self) -> RString;
    fn is_open(&self) -> bool;
    fn create_command(&self) -> SabiCommandBox;
    fn open(&self) -> RResult<(), RString>;
    fn close(&self) -> RResult<(), RString>;
    fn start_transaction(&self, isolation: ROption<u8>) -> RResult<SabiTransactionBox, RString>;
}

pub type SabiConnectionBox = SabiConnection_TO<'static, RBox<()>>;

#[abi_stable::sabi_trait]
pub trait SabiDriver: Send + Sync {
    fn connection(&self, options: RVec<SabiCell>) -> SabiConnectionBox;
    fn command(&self, slot: u64) -> SabiCommandBox;
    fn transaction(&self, slot: u64, isolation: u8) -> SabiTransactionBox;
    fn column_type(&self, name: RString) -> RResult<RString, RString>;
    fn converter_names(&self) -> RVec<RString>;
    fn convert(&self, name: RString, value: SabiValue, reverse: bool) -> RResult<SabiValue, RString>;
}

pub type SabiDriverBox = SabiDriver_TO<'static, RBox<()>>;