synrc / kvs Goto Github PK

mnesia:schema(text).
-- Properties for text table --- 
access_mode          -> read_write
active_replicas      -> [nonode@nohost]
all_nodes            -> [nonode@nohost]
arity                -> 4
attributes           -> [id,title,body]
checkpoints          -> []
commit_work          -> []
cookie               -> {{1514407290293049786,-576460752303422623,1},
                         nonode@nohost}
disc_copies          -> [nonode@nohost]
disc_only_copies     -> []
external_copies      -> []
frag_properties      -> []
index                -> []
index_info           -> {index,bag,[]}
load_by_force        -> false
load_node            -> nonode@nohost
load_order           -> 0
load_reason          -> local_only
local_content        -> false
majority             -> false
master_nodes         -> []
memory               -> 306
ram_copies           -> []
record_name          -> text
record_validation    -> {text,4,bag}
setorbag             -> bag
size                 -> 0
snmp                 -> []
storage_properties   -> []
storage_type         -> disc_copies
subscribers          -> []
user_properties      -> []
version              -> {{2,0},[]}
where_to_commit      -> [{nonode@nohost,disc_copies}]
where_to_read        -> nonode@nohost
where_to_wlock       -> {[nonode@nohost],false}
where_to_write       -> [nonode@nohost]
wild_pattern         -> {text,'_','_','_'}

event(submit) ->
    Title = wf:q(title),
    Body = wf:q(body),
    kvs:add(#text{id=kvs:next_id("text",1),title=Title,body=Body});

<<"g2gCaAVkAAJldmQABXNtb2tlZAAGc3VibWl0bQAAAAZzdWJtaXRkAAVldmVudGgDYgAABepiAAY3fGIAC32Q">>,
                                                                                        [{{"submit",<<"detail">>},[]},
                                             {title,"Test title"},
                                                                                          {body,"Test body"}]}
n2o_nitrogen:Catch: error:badarg
                                [{erlang,atom_to_list,[<<"Test title">>],undefined},
                                                                               {kvs,rname,1,383},
                                                                                                  {kvs,range,2,334},
              {kvs,get,3,261},
                               {kvs,ensure_link,2,103},
                                                        {n2o_nitrogen,html_events,2,73},
                                                                                         {n2o_nitrogen,info,3,35},
            {n2o_proto,push,5,44}]

insert () ->
	Record = #text{id=1,title="Test title",body="Test body"},
	F = fun() ->
		mnesia:write(Record)
	end,

	mnesia:transaction(F).

database_logic:insert().
{atomic,ok}

kvs:all(text).
[{text,1,"Test title","Test body"}]

> require ERP
ERP
> :kvs.feed '/crm/towns', KVS.kvs(mod: :kvs_mnesia, st: :kvs_stream)