rsoffkv 0.1.8

A uniform interface for 3 different distributed key-value storages: Zookeeper, Consul, ETCD
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
123
124
125
126
127
128
129
130
131
132
133
134
135
136

use libc::{size_t,c_int};
use std::os::raw::{c_char,c_void};
use std::ffi::CString;


extern "C" {
    pub(super) fn offkv_open(
        url: *const c_char,
        prefix: *const c_char,
        error_code: *mut c_int
    ) -> *mut c_void;

    pub(super) fn offkv_create(
        handle: *mut c_void,
        key: *const c_char,
        value: *const c_char,
        value_size: size_t,
        flags: c_int
    ) -> i64;

    pub(super) fn offkv_erase(
        handle: *mut c_void,
        key: *const c_char,
        version: i64,
    ) -> c_int;

    pub(super) fn offkv_set(
        handle: *mut c_void,
        key: *const c_char,
        value: *const c_char,
        value_size: size_t,
    ) -> i64;

    pub(super) fn offkv_cas(
        handle: *mut c_void,
        key: *const c_char,
        value: *const c_char,
        value_size: size_t,
        version: i64,
    ) -> i64;

    pub(super) fn offkv_get(
        handle: *mut c_void,
        key: *const c_char,
        watch_handle: *mut *mut c_void,
    ) -> offkv_GetResult;

    pub(super) fn offkv_exists(
        handle: *mut c_void,
        key: *const c_char,
        watch_handle: *mut *mut c_void,
    ) -> i64;

    pub(super) fn offkv_children(
        handle: *mut c_void,
        key: *const c_char,
        watch_handle: *mut *mut c_void,
    ) -> offkv_ChildrenResult;

    pub(super) fn offkv_commit(
        handle: *mut c_void,
        checks: *const offkv_TxnCheck,
        nchecks: size_t,
        ops: *const offkv_TxnOp,
        nops: size_t,
        result: *mut offkv_TxnResult,
    ) -> c_int;

    pub(super) fn offkv_watch(watch_handle: *mut c_void);
    pub(super) fn offkv_watch_drop(watch_handle: *mut c_void);

    pub(super) fn offkv_close(handle: *mut c_void);
}

#[repr(C)]
pub(super) struct offkv_GetResult {
    pub(super) value: *mut c_char,
    pub(super) value_size: size_t,
    pub(super) version: i64,
}

#[repr(C)]
pub(super) struct offkv_ChildrenResult {
    pub(super) keys: *mut *mut c_char,
    pub(super) nkeys: size_t,
    pub(super) error_code: c_int,
}

#[repr(C)]
pub(super) struct offkv_TxnCheck {
    pub(super) key: *const c_char,
    pub(super) version: i64,
}

#[repr(C)]
pub(super) struct offkv_TxnOp {
    pub(super) op_kind: c_int,
    pub(super) flags: c_int,
    pub(super) key: *const c_char,
    pub(super) value: *const c_char,
    pub(super) value_size: size_t,
}

#[repr(C)]
pub(super) struct offkv_TxnOpResult {
    pub(super) op_kind: c_int,
    pub(super) version: i64,
}

#[repr(C)]
pub(super) struct offkv_TxnResult {
    pub(super) results: *mut offkv_TxnOpResult,
    pub(super) nresults: size_t,
    pub(super) failed_op: size_t,
}


#[allow(non_camel_case_types)]
// copied from clib.h
pub(super) const OFFKV_LEASE: c_int = 1 << 0;


// transaction operations
#[repr(C)]
#[allow(non_camel_case_types)]
// copied from clib.h
pub(super) enum OffkvTxnOpCode {
    OFFKV_OP_CREATE,
    OFFKV_OP_SET,
    OFFKV_OP_ERASE,
}


pub(super) fn to_cstring(s: &str) -> CString {
    CString::new(s).expect("Failed to create CString")
}