umgeher/leveled
0
Fork 0
Code Issues Pull requests Releases Activity Actions

Fixup API to allow for Tags to be passed

Browse source 
plus fixes to previous commits moving API functions into testutil
This commit is contained in:
martinsumner 2016-11-07 10:42:49 +00:00
parent 37c23a5b38
commit 8f068c1280
2 changed files with 7 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/leveled_bookie.erl
View file

@ -139,7 +139,9 @@
book_tempput/7, book_tempput/7,
book_delete/4, book_delete/4,
book_get/3, book_get/3,
book_get/4,
book_head/3, book_head/3,
book_head/4,
book_returnfolder/2, book_returnfolder/2,
book_snapshotstore/3, book_snapshotstore/3,
book_snapshotledger/3, book_snapshotledger/3,

10
test/end_to_end/testutil.erl
View file

@ -48,21 +48,21 @@
book_riakput(Pid, RiakObject, IndexSpecs) -> book_riakput(Pid, RiakObject, IndexSpecs) ->
{Bucket, Key} = leveled_codec:riakto_keydetails(RiakObject), {Bucket, Key} = leveled_codec:riakto_keydetails(RiakObject),
leveled_book:book_put(Pid, Bucket, Key, RiakObject, IndexSpecs, ?RIAK_TAG). leveled_bookie:book_put(Pid, Bucket, Key, RiakObject, IndexSpecs, ?RIAK_TAG).
book_riakdelete(Pid, Bucket, Key, IndexSpecs) -> book_riakdelete(Pid, Bucket, Key, IndexSpecs) ->
leveled_book:book_put(Pid, Bucket, Key, delete, IndexSpecs, ?RIAK_TAG). leveled_bookie:book_put(Pid, Bucket, Key, delete, IndexSpecs, ?RIAK_TAG).
book_riakget(Pid, Bucket, Key) -> book_riakget(Pid, Bucket, Key) ->
leveled_book:book_get(Pid, Bucket, Key, ?RIAK_TAG). leveled_bookie:book_get(Pid, Bucket, Key, ?RIAK_TAG).
book_riakhead(Pid, Bucket, Key) -> book_riakhead(Pid, Bucket, Key) ->
leveled_book:book_head(Pid, Bucket, Key, ?RIAK_TAG). leveled_bookie:book_head(Pid, Bucket, Key, ?RIAK_TAG).
riakload(Bookie, ObjectList) -> riakload(Bookie, ObjectList) ->
lists:foreach(fun({_RN, Obj, Spc}) -> lists:foreach(fun({_RN, Obj, Spc}) ->
R = book_riakput(Bookie,Obj, Spc), R = book_riakput(Bookie, Obj, Spc),
case R of case R of
ok -> ok; ok -> ok;
pause -> timer:sleep(?SLOWOFFER_DELAY) pause -> timer:sleep(?SLOWOFFER_DELAY)