Eleveldb version

rebar.config

@@ -0,0 +1,4 @@
+{deps, [
+       {eleveldb, ".*", {git, "git://github.com/SyncFree/eleveldb", {branch, "antidote_comparator"}}},
+       {antidote_utils, ".*", {git, "git://github.com/SyncFree/antidote_utils", {branch, "additions_for_antidote_db"}}}
+]}.

src/antidote_db.app.src

@@ -0,0 +1,13 @@
+{application, antidote_db,
+ [
+  {description, "Antidote DataBase application"},
+  {vsn, "1"},
+  {registered, []},
+  {applications, [
+                  kernel,
+                  stdlib,
+                  eleveldb
+                 ]},
+  {mod, { antidote_db, []}},
+  {env, []}
+ ]}.

src/antidote_db.erl

@@ -0,0 +1,99 @@
+%% -------------------------------------------------------------------
+%%
+%% Copyright (c) 2014 SyncFree Consortium.  All Rights Reserved.
+%%
+%% This file is provided to you under the Apache License,
+%% Version 2.0 (the "License"); you may not use this file
+%% except in compliance with the License.  You may obtain
+%% a copy of the License at
+%%
+%%   http://www.apache.org/licenses/LICENSE-2.0
+%%
+%% Unless required by applicable law or agreed to in writing,
+%% software distributed under the License is distributed on an
+%% "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+%% KIND, either express or implied.  See the License for the
+%% specific language governing permissions and limitations
+%% under the License.
+%%
+%% -------------------------------------------------------------------
+
+-module(antidote_db).
+
+-export([
+    new/1,
+    get/2,
+    put/3,
+    close_and_destroy/2,
+    close/1,
+    fold/4,
+    fold_keys/4,
+    is_empty/1,
+    delete/2,
+    repair/1]).
+
+-type antidote_db() :: eleveldb:db_ref().
+
+-export_type([antidote_db/0]).
+
+%% Given a name, returns a new AntidoteDB (ElevelDB)
+%% OpenOptions are set to use Antidote special comparator
+-spec new(atom()) -> {ok, antidote_db()} | {error, any()}.
+new(Name) ->
+    eleveldb:open(Name, [{create_if_missing, true}, {antidote, true}]).
+
+%% Closes and destroys the given base
+-spec close_and_destroy(antidote_db(), atom()) -> ok | {error, any()}.
+close_and_destroy(AntidoteDB, Name) ->
+    eleveldb:close(AntidoteDB),
+    eleveldb:destroy(Name, []).
+
+-spec close(antidote_db()) -> ok | {error, any()}.
+close(AntidoteDB) ->
+    eleveldb:close(AntidoteDB).
+
+%% @doc returns the value of Key, in the antidote_db
+-spec get(antidote_db(), any()) -> term() | not_found.
+get(AntidoteDB, Key) ->
+    AKey = case is_binary(Key) of
+               true -> Key;
+               false -> term_to_binary(Key)
+           end,
+    case eleveldb:get(AntidoteDB, AKey, []) of
+        {ok, Res} ->
+            binary_to_term(Res);
+        not_found ->
+            not_found
+    end.
+
+%% @doc puts the Value associated to Key in eleveldb AntidoteDB
+-spec put(antidote_db(), any(), any()) -> ok | {error, any()}.
+put(AntidoteDB, Key, Value) ->
+    AKey = case is_binary(Key) of
+               true -> Key;
+               false -> term_to_binary(Key)
+           end,
+    ATerm = case is_binary(Value) of
+                true -> Value;
+                false -> term_to_binary(Value)
+            end,
+    eleveldb:put(AntidoteDB, AKey, ATerm, []).
+
+-spec fold(antidote_db(), eleveldb:fold_fun(), any(), eleveldb:read_options()) -> any().
+fold(AntidoteDB, Fun, Acc0, Opts) ->
+    eleveldb:fold(AntidoteDB, Fun, Acc0, Opts).
+
+-spec fold_keys(antidote_db(), eleveldb:fold_keys_fun(), any(), eleveldb:read_options()) -> any().
+fold_keys(AntidoteDB, Fun, Acc0, Opts) ->
+    eleveldb:fold_keys(AntidoteDB, Fun, Acc0, Opts).
+
+-spec is_empty(antidote_db()) -> boolean().
+is_empty(AntidoteDB) ->
+    eleveldb:is_empty(AntidoteDB).
+
+repair(Name) ->
+    eleveldb:repair(Name, []).
+
+-spec delete(antidote_db(), binary()) -> ok | {error, any()}.
+delete(AntidoteDB, Key) ->
+    eleveldb:delete(AntidoteDB, Key, []).

src/antidote_db_sup.erl

@@ -0,0 +1,45 @@
+%% -------------------------------------------------------------------
+%%
+%% Copyright (c) 2014 SyncFree Consortium.  All Rights Reserved.
+%%
+%% This file is provided to you under the Apache License,
+%% Version 2.0 (the "License"); you may not use this file
+%% except in compliance with the License.  You may obtain
+%% a copy of the License at
+%%
+%%   http://www.apache.org/licenses/LICENSE-2.0
+%%
+%% Unless required by applicable law or agreed to in writing,
+%% software distributed under the License is distributed on an
+%% "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+%% KIND, either express or implied.  See the License for the
+%% specific language governing permissions and limitations
+%% under the License.
+%%
+%% -------------------------------------------------------------------
+-module(antidote_db_sup).
+
+-behaviour(supervisor).
+
+%% API
+-export([start_link/0]).
+
+%% Supervisor callbacks
+-export([init/1]).
+
+%% Helper macro for declaring children of supervisor
+-define(CHILD(I, Type), {I, {I, start_link, []}, permanent, 5000, Type, [I]}).
+
+%% ===================================================================
+%% API functions
+%% ===================================================================
+
+start_link() ->
+    supervisor:start_link({local, ?MODULE}, ?MODULE, []).
+
+%% ===================================================================
+%% Supervisor callbacks
+%% ===================================================================
+
+init([]) ->
+    {ok, { {one_for_one, 5, 10}, []} }.