test(ds): Refactor ds_SUITE
This commit is contained in:
parent
e4a73f003a
commit
074d98a14a
|
@ -67,10 +67,16 @@ t_00_smoke_open_drop(_Config) ->
|
||||||
%% A simple smoke test that verifies that storing the messages doesn't
|
%% A simple smoke test that verifies that storing the messages doesn't
|
||||||
%% crash
|
%% crash
|
||||||
t_01_smoke_store(_Config) ->
|
t_01_smoke_store(_Config) ->
|
||||||
DB = default,
|
?check_trace(
|
||||||
?assertMatch(ok, emqx_ds:open_db(DB, opts())),
|
#{timetrap => 10_000},
|
||||||
Msg = message(<<"foo/bar">>, <<"foo">>, 0),
|
begin
|
||||||
?assertMatch(ok, emqx_ds:store_batch(DB, [Msg])).
|
DB = default,
|
||||||
|
?assertMatch(ok, emqx_ds:open_db(DB, opts())),
|
||||||
|
Msg = message(<<"foo/bar">>, <<"foo">>, 0),
|
||||||
|
?assertMatch(ok, emqx_ds:store_batch(DB, [Msg]))
|
||||||
|
end,
|
||||||
|
[]
|
||||||
|
).
|
||||||
|
|
||||||
%% A simple smoke test that verifies that getting the list of streams
|
%% A simple smoke test that verifies that getting the list of streams
|
||||||
%% doesn't crash and that iterators can be opened.
|
%% doesn't crash and that iterators can be opened.
|
||||||
|
|
Loading…
Reference in New Issue