Skip to content

Commit

Permalink
Merge pull request #22 from permaweb/rocksdb_store_families
Browse files Browse the repository at this point in the history
feat(ao_store): add ao_rocksdb_store support
  • Loading branch information
oltarasenko authored Dec 10, 2024
2 parents ec5f207 + c91fd72 commit 435419d
Show file tree
Hide file tree
Showing 9 changed files with 844 additions and 84 deletions.
1 change: 0 additions & 1 deletion .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@ node_modules
c_src/*.o
c_src/*.d
priv/*
rebar.lock
.DS_STORE
TEST-data*
test-cache/*
Expand Down
2 changes: 1 addition & 1 deletion erlang_ls.config
Original file line number Diff line number Diff line change
Expand Up @@ -24,4 +24,4 @@ lenses:
- show-behaviour-usages
providers:
enabled:
- signature-help
- signature-help
3 changes: 2 additions & 1 deletion rebar.config
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,8 @@
{jiffy, {git, "https://github.com/ArweaveTeam/jiffy.git", {ref, "74c956defa9116c85d76f77c3e9b5bd6de7bd39a"}}},
{cowboy, {git, "https://github.com/ninenines/cowboy", {tag, "2.12.0"}}},
{prometheus, "4.11.0"},
{prometheus_cowboy, "0.1.8"}
{prometheus_cowboy, "0.1.8"},
{rocksdb, "1.8.0"}
]}.

{shell, [
Expand Down
43 changes: 43 additions & 0 deletions rebar.lock
Original file line number Diff line number Diff line change
@@ -0,0 +1,43 @@
{"1.2.0",
[{<<"accept">>,{pkg,<<"accept">>,<<"0.3.5">>},2},
{<<"b64fast">>,
{git,"https://github.com/ArweaveTeam/b64fast.git",
{ref,"58f0502e49bf73b29d95c6d02460d1fb8d2a5273"}},
0},
{<<"cowboy">>,
{git,"https://github.com/ninenines/cowboy",
{ref,"3ea8395eb8f53a57acb5d3c00b99c70296e7cdbd"}},
0},
{<<"cowlib">>,
{git,"https://github.com/ninenines/cowlib",
{ref,"1eb7f4293a652adcfe43b1835d22c58d8def839f"}},
1},
{<<"jiffy">>,
{git,"https://github.com/ArweaveTeam/jiffy.git",
{ref,"74c956defa9116c85d76f77c3e9b5bd6de7bd39a"}},
0},
{<<"prometheus">>,{pkg,<<"prometheus">>,<<"4.11.0">>},0},
{<<"prometheus_cowboy">>,{pkg,<<"prometheus_cowboy">>,<<"0.1.8">>},0},
{<<"prometheus_httpd">>,{pkg,<<"prometheus_httpd">>,<<"2.1.11">>},1},
{<<"quantile_estimator">>,{pkg,<<"quantile_estimator">>,<<"0.2.1">>},1},
{<<"ranch">>,
{git,"https://github.com/ninenines/ranch",
{ref,"a692f44567034dacf5efcaa24a24183788594eb7"}},
1},
{<<"rocksdb">>,{pkg,<<"rocksdb">>,<<"1.8.0">>},0}]}.
[
{pkg_hash,[
{<<"accept">>, <<"B33B127ABCA7CC948BBE6CAA4C263369ABF1347CFA9D8E699C6D214660F10CD1">>},
{<<"prometheus">>, <<"B95F8DE8530F541BD95951E18E355A840003672E5EDA4788C5FA6183406BA29A">>},
{<<"prometheus_cowboy">>, <<"CFCE0BC7B668C5096639084FCD873826E6220EA714BF60A716F5BD080EF2A99C">>},
{<<"prometheus_httpd">>, <<"F616ED9B85B536B195D94104063025A91F904A4CFC20255363F49A197D96C896">>},
{<<"quantile_estimator">>, <<"EF50A361F11B5F26B5F16D0696E46A9E4661756492C981F7B2229EF42FF1CD15">>},
{<<"rocksdb">>, <<"0AE072F9818DAC03E18BA0E4B436450D24040DFB1A526E2198B451FD9FA0284F">>}]},
{pkg_hash_ext,[
{<<"accept">>, <<"11B18C220BCC2EAB63B5470C038EF10EB6783BCB1FCDB11AA4137DEFA5AC1BB8">>},
{<<"prometheus">>, <<"719862351AABF4DF7079B05DC085D2BBCBE3AC0AC3009E956671B1D5AB88247D">>},
{<<"prometheus_cowboy">>, <<"BA286BECA9302618418892D37BCD5DC669A6CC001F4EB6D6AF85FF81F3F4F34C">>},
{<<"prometheus_httpd">>, <<"0BBE831452CFDF9588538EB2F570B26F30C348ADAE5E95A7D87F35A5910BCF92">>},
{<<"quantile_estimator">>, <<"282A8A323CA2A845C9E6F787D166348F776C1D4A41EDE63046D72D422E3DA946">>},
{<<"rocksdb">>, <<"185E645EA480E9325D5EFE362BF3D2A38EDFC31B5145031B0CBEED978E89523C">>}]}
].
5 changes: 3 additions & 2 deletions src/ar_bundles.erl
Original file line number Diff line number Diff line change
Expand Up @@ -944,7 +944,8 @@ ar_bundles_test_() ->
{timeout, 30, fun test_bundle_map/0},
{timeout, 30, fun test_basic_member_id/0},
{timeout, 30, fun test_deep_member/0},
{timeout, 30, fun test_serialize_deserialize_deep_signed_bundle/0}
{timeout, 30, fun test_serialize_deserialize_deep_signed_bundle/0},
{timeout, 30, fun test_extremely_large_bundle/0}
].

test_no_tags() ->
Expand Down Expand Up @@ -1080,7 +1081,7 @@ test_bundle_map() ->
?assertEqual(Item1#tx.data, (maps:get(<<"key1">>, BundleItem#tx.data))#tx.data),
?assert(verify_item(BundleItem)).

extremely_large_bundle_test() ->
test_extremely_large_bundle() ->
W = ar_wallet:new(),
Data = crypto:strong_rand_bytes(100_000_000),
Norm = normalize(#tx { data = #{ <<"key">> => #tx { data = Data } } }),
Expand Down
5 changes: 4 additions & 1 deletion src/hb_beamr.erl
Original file line number Diff line number Diff line change
Expand Up @@ -172,7 +172,10 @@ aos64_standalone_wex_test() ->
#{<<"Output">> := #{ <<"data">> := Data }} = Resp,
?assertEqual(<<"2">>, Data).

checkpoint_and_resume_test() ->
slow_test_() ->
[ {timeout, 30, fun test_checkpoint_and_resume/0}].

test_checkpoint_and_resume() ->
Env = gen_test_env(),
Msg1 = gen_test_aos_msg("TestVar = 0"),
Msg2 = gen_test_aos_msg("TestVar = 1"),
Expand Down
Loading

0 comments on commit 435419d

Please sign in to comment.