Packages
kvs
2.1.0
13.5.22-aleph
13.4.16
13.4.15
13.4.14
13.4.13
13.3.1
13.2.28
11.9.1
10.8.3
10.8.2
10.3.0
9.9.2
9.9.1
9.9.0
9.8.0
9.7.0
9.4.8
9.4.7
9.4.6
9.4.5
9.4.4
9.4.3
9.4.2
9.4.1
9.4.0
8.12.0
8.11.2
8.11.1
8.10.4
8.10.3
8.10.2
8.10.1
8.10.0
8.5.2
8.5.1
8.5.0
8.4.1
8.4.0
8.3.1
8.3.0
7.11.5
7.9.1
7.7.0
7.1.3
7.1.2
7.1.1
6.12.11
6.12.10
6.12.9
6.12.8
6.12.7
6.12.6
6.12.5
6.12.4
6.12.3
6.12.2
6.12.1
6.12.0
6.11.2
6.11.1
6.11.0
6.10.2
6.10.1
6.10.0
6.9.2
6.9.1
6.9.0
6.7.7
6.7.6
6.7.5
6.7.4
6.7.3
6.7.2
6.7.1
6.7.0
6.6.0
2.1.0
0.12.1
retired
KVS Key-Value Store Abstraction Layer
Current section
Files
Jump to
Current section
Files
src/store_kai.erl
-module(store_kai).
-author('Maxim Sokhatsky').
-copyright('Synrc Research Center s.r.o.').
-include("config.hrl").
-include("metainfo.hrl").
-include_lib("stdlib/include/qlc.hrl").
-compile(export_all).
-record(data, { key, bucket, last_modified, vector_clocks, checksum, flags, value }).
start() -> kai:start(), ok.
stop() -> kai_store:stop(), ok.
version() -> {version,"KVS KAI"}.
join() -> initialize(), ok.
join(Node) -> initialize(), ok.
initialize() -> ok.
dir() -> [{table,T}||T<-kvs:modules()].
put(Records) when is_list(Records) -> lists:foreach(fun kai_put/1, Records);
put(Record) -> kai_put(Record).
kai_put(Record) ->
Data = #data{key = element(2,Record), bucket = table_to_num(element(1,Record)),
last_modified = now(), checksum = erlang:md5(term_to_binary(Record)),
vector_clocks = vclock:fresh(), value = Record },
kai_store:put(Data).
update(Record, Object) -> ok.
get(Tab, Key) ->
Data = #data{key=Key,bucket=table_to_num(Tab)},
kai_get(Data).
kai_get(Data) ->
case kai_store:get(Data) of
#data{value=Value} -> {ok,Value};
undefined -> {error,not_found};
E -> {error,E} end.
delete(Tab, Key) ->
Data = #data{key=Key,bucket=table_to_num(Tab)},
kai_delete(Data).
kai_delete(Data) ->
case kai_store:delete(Data) of
ok -> ok;
E -> {error,E} end.
key_to_bin(Key) ->
if is_integer(Key) -> erlang:list_to_binary(integer_to_list(Key));
is_list(Key) -> erlang:list_to_binary(Key);
is_atom(Key) -> erlang:list_to_binary(erlang:atom_to_list(Key));
is_binary(Key) -> Key;
true -> [ListKey] = io_lib:format("~p", [Key]), erlang:list_to_binary(ListKey) end.
all(RecordName) ->
{list_of_data,List} = kai_store:list(table_to_num(RecordName)),
[ begin {ok,Val}=kai_get(Data),Val end || Data <- List ].
all_by_index(Tab, IndexId, IndexVal) -> [].
table_to_num(user) -> 10;
table_to_num(subscription) -> 11;
table_to_num(group) -> 12;
table_to_num(id_seq) -> 13;
table_to_num(product) -> 14;
table_to_num(acl) -> 15;
table_to_num(feed) -> 16;
table_to_num(entry) -> 17;
table_to_num(comment) -> 18;
table_to_num(Name) -> case kvs:config(kvs,table_to_num) of
[] -> unknown_table;
Module -> Module:table_to_num(Name) end.