leveldb-rs 0.0.1

Bindings to the LevelDB key/value storage library (https://github.com/google/leveldb)
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
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152

#[allow(dead_code)]
#[allow(non_camel_case_types)]
pub mod ffi {
    use libc::{c_char, c_int, c_uchar, c_void};
    use libc::types::os::arch::c95::size_t;

    // These are opaque types that LevelDB uses.
    pub type leveldb_t = c_void;
    pub type leveldb_cache_t = c_void;
    pub type leveldb_comparator_t = c_void;
    pub type leveldb_env_t = c_void;
    pub type leveldb_filelock_t = c_void;
    pub type leveldb_filterpolicy_t = c_void;
    pub type leveldb_iterator_t = c_void;
    pub type leveldb_logger_t = c_void;
    pub type leveldb_options_t = c_void;
    pub type leveldb_randomfile_t = c_void;
    pub type leveldb_readoptions_t = c_void;
    pub type leveldb_seqfile_t = c_void;
    pub type leveldb_snapshot_t = c_void;
    pub type leveldb_writablefile_t = c_void;
    pub type leveldb_writebatch_t = c_void;
    pub type leveldb_writeoptions_t = c_void;

    pub static LEVELDB_NO_COMPRESSION: c_int = 0;
    pub static LEVELDB_SNAPPY_COMPRESSION: c_int = 1;

    extern "C" {
        // DB operations
        pub fn leveldb_open(options: *const leveldb_options_t, name: *const c_char, errptr: *mut *mut c_char) -> *mut leveldb_t;
        pub fn leveldb_close(db: *mut leveldb_t);
        pub fn leveldb_put(db: *mut leveldb_t, options: *const leveldb_writeoptions_t, key: *const c_char, keylen: size_t, val: *const c_char, vallen: size_t, errptr: *mut *mut c_char);
        pub fn leveldb_delete(db: *mut leveldb_t, options: *const leveldb_writeoptions_t, key: *const c_char, keylen: size_t, errptr: *mut *mut c_char);
        pub fn leveldb_write(db: *mut leveldb_t, options: *const leveldb_writeoptions_t, batch: *mut leveldb_writebatch_t, errptr: *mut *mut c_char);
        pub fn leveldb_get(db: *mut leveldb_t, options: *const leveldb_readoptions_t, key: *const c_char, keylen: size_t, vallen: *mut size_t, errptr: *mut *mut c_char) -> *mut c_char;
        pub fn leveldb_create_iterator(db: *mut leveldb_t, options: *const leveldb_readoptions_t) -> *mut leveldb_iterator_t;
        pub fn leveldb_create_snapshot(db: *mut leveldb_t) -> *mut leveldb_snapshot_t;
        pub fn leveldb_release_snapshot(db: *mut leveldb_t, snapshot: *const leveldb_snapshot_t);
        pub fn leveldb_property_value(db: *mut leveldb_t, propname: *const c_char) -> *mut c_char;

        // TODO: const'ness of pointers here is in question
        pub fn leveldb_approximate_sizes(db: *mut leveldb_t, num_ranges: c_int, range_start_key: *const *const c_char, range_start_key_len: *const size_t, range_limit_key: *const *const c_char, range_limit_key_len: *const size_t, sizes: *mut u64);
        pub fn leveldb_compact_range(db: *mut leveldb_t, start_key: *const c_char, start_key_len: size_t, limit_key: *const c_char, limit_key_len: size_t);

        // Management operations
        pub fn leveldb_destroy_db(options: *const leveldb_options_t, name: *const c_char, errptr: *mut *mut c_char);
        pub fn leveldb_repair_db(options: *const leveldb_options_t, name: *const c_char, errptr: *mut *mut c_char);

        // Iterator
        pub fn leveldb_iter_destroy(it: *mut leveldb_iterator_t);
        pub fn leveldb_iter_valid(it: *const leveldb_iterator_t) -> c_uchar;
        pub fn leveldb_iter_seek_to_first(it: *mut leveldb_iterator_t);
        pub fn leveldb_iter_seek_to_last(it: *mut leveldb_iterator_t);
        pub fn leveldb_iter_seek(it: *mut leveldb_iterator_t, k: *const c_char, klen: size_t);
        pub fn leveldb_iter_next(it: *mut leveldb_iterator_t);
        pub fn leveldb_iter_prev(it: *mut leveldb_iterator_t);
        pub fn leveldb_iter_key(it: *const leveldb_iterator_t, klen: *mut size_t) -> *const c_char;
        pub fn leveldb_iter_value(it: *const leveldb_iterator_t, vlen: *mut size_t) -> *const c_char;
        pub fn leveldb_iter_get_error(it: *const leveldb_iterator_t, errptr: *const *const c_char);

        // Write batch
        pub fn leveldb_writebatch_create() -> *mut leveldb_writebatch_t;
        pub fn leveldb_writebatch_destroy(b: *mut leveldb_writebatch_t);
        pub fn leveldb_writebatch_clear(b: *mut leveldb_writebatch_t);
        pub fn leveldb_writebatch_put(b: *mut leveldb_writebatch_t, key: *const c_char, keylen: size_t, val: *const c_char, vallen: size_t);
        pub fn leveldb_writebatch_delete(b: *mut leveldb_writebatch_t, key: *const c_char, keylen: size_t);
        pub fn leveldb_writebatch_iterate(
            b: *mut leveldb_writebatch_t,
            state: *mut c_void,
            put: extern fn(*mut c_void, *const c_char, size_t, *const c_char, size_t),
            deleted: extern fn(*mut c_void, *const c_char, size_t)
        );

        // Options
        pub fn leveldb_options_create() -> *mut leveldb_options_t;
        pub fn leveldb_options_destroy(o: *mut leveldb_options_t);
        pub fn leveldb_options_set_comparator(o: *mut leveldb_options_t, c: *mut leveldb_comparator_t);
        pub fn leveldb_options_set_filter_policy(o: *mut leveldb_options_t, c: *mut leveldb_filterpolicy_t);
        pub fn leveldb_options_set_create_if_missing(o: *mut leveldb_options_t, val: c_uchar);
        pub fn leveldb_options_set_error_if_exists(o: *mut leveldb_options_t, val: c_uchar);
        pub fn leveldb_options_set_paranoid_checks(o: *mut leveldb_options_t, val: c_uchar);
        pub fn leveldb_options_set_env(o: *mut leveldb_options_t, env: *mut leveldb_env_t);
        pub fn leveldb_options_set_info_log(o: *mut leveldb_options_t, logger: *mut leveldb_logger_t);
        pub fn leveldb_options_set_write_buffer_size(o: *mut leveldb_options_t, size: size_t);
        pub fn leveldb_options_set_max_open_files(o: *mut leveldb_options_t, num: c_int);
        pub fn leveldb_options_set_cache(o: *mut leveldb_options_t, cache: *mut leveldb_cache_t);
        pub fn leveldb_options_set_block_size(o: *mut leveldb_options_t, size: size_t);
        pub fn leveldb_options_set_block_restart_interval(o: *mut leveldb_options_t, interval: c_int);
        pub fn leveldb_options_set_compression(o: *mut leveldb_options_t, val: c_int);

        // Comparator
        pub fn leveldb_comparator_create(
            state: *mut c_void,
            destructor: extern fn(*mut c_void),
            compare: extern fn(*mut c_void, *const c_char, size_t, *const c_char, size_t) -> c_int,
            name: extern fn(*mut c_void) -> *const c_char
        ) -> *mut leveldb_comparator_t;
        pub fn leveldb_comparator_destroy(c: *mut leveldb_comparator_t);

        // Filter policy
        //pub leveldb_filterpolicy_create(state: *mut c_void, /* TODO */) -> *mut leveldb_filterpolicy_t;
        /*
            extern leveldb_filterpolicy_t* leveldb_filterpolicy_create(
                void* state,
                void (*destructor)(void*),
                char* (*create_filter)(
                    void*,
                    const char* const* key_array, const size_t* key_length_array,
                    int num_keys,
                    size_t* filter_length),
                unsigned char (*key_may_match)(
                    void*,
                    const char* key, size_t length,
                    const char* filter, size_t filter_length),
                const char* (*name)(void*));
        */
        pub fn leveldb_filterpolicy_destroy(p: *mut leveldb_filterpolicy_t);
        pub fn leveldb_filterpolicy_create_bloom(bits_per_key: c_int) -> *mut leveldb_filterpolicy_t;

        // Read options
        pub fn leveldb_readoptions_create() -> *mut leveldb_readoptions_t;
        pub fn leveldb_readoptions_destroy(o: *mut leveldb_readoptions_t);
        pub fn leveldb_readoptions_set_verify_checksums(o: *mut leveldb_readoptions_t, val: c_uchar);
        pub fn leveldb_readoptions_set_fill_cache(o: *mut leveldb_readoptions_t, val: c_uchar);
        pub fn leveldb_readoptions_set_snapshot(o: *mut leveldb_readoptions_t, snapshot: *const leveldb_snapshot_t);

        // Write options
        pub fn leveldb_writeoptions_create() -> *mut leveldb_writeoptions_t;
        pub fn leveldb_writeoptions_destroy(o: *mut leveldb_writeoptions_t);
        pub fn leveldb_writeoptions_set_sync(o: *mut leveldb_writeoptions_t, val: c_uchar);

        // Cache
        pub fn leveldb_cache_create_lru(capacity: size_t) -> *mut leveldb_cache_t;
        pub fn leveldb_cache_destroy(c: *mut leveldb_cache_t);

        // Env
        pub fn leveldb_create_default_env() -> *mut leveldb_env_t;
        pub fn leveldb_env_destroy(e: *mut leveldb_env_t);

        // Utility
        pub fn leveldb_free(ptr: *mut c_void);

        // Versioning
        pub fn leveldb_major_version() -> c_int;
        pub fn leveldb_minor_version() -> c_int;
    }

    // TODO: Should figure out a better way to specify this.
    #[cfg(any(target_os = "linux", target_os = "macos"))]
    #[link(name="stdc++")]
    extern {}
}