diff --git a/src/tsuru.app.src b/src/tsuru.app.src index aca9ef5e0087ea2e9c0800aa25b3316b0383f716..5f373cb4015e287fce25a251b4319696f2fd4886 100644 --- a/src/tsuru.app.src +++ b/src/tsuru.app.src @@ -1,5 +1,5 @@ {application, tsuru, [{description, "A collection of useful tools for Erlang applications"}, - {vsn, "1.3.0"}, + {vsn, "1.4.0"}, {applications, [kernel, stdlib]}, {modules, []}, {registered, []}, diff --git a/src/tsuru_forward_decay.erl b/src/tsuru_forward_decay.erl index c031772e999ed00a183892d2f372d3d190672a43..c2a0c3df8c122e0a5e121a5c84fcbddfcf3067ac 100644 --- a/src/tsuru_forward_decay.erl +++ b/src/tsuru_forward_decay.erl @@ -3,6 +3,7 @@ -export([ new/0, new/3, + delete/1, set_block_count/2, set_landmark/1, set_landmark/2, @@ -31,6 +32,10 @@ new() -> new(seconds, 1, infinity). +-spec delete(forward_decay()) -> true. +delete(#forward_decay{events = Events}) -> + ets:delete(Events). + -spec new(erlang:time_unit(), pos_integer(), pos_integer() | infinity) -> forward_decay(). new(TimeUnit, BlockSize, BlockCount) -> Events = ets:new(events, [ordered_set, {write_concurrency, true}]), diff --git a/test/tsuru_forward_decay_test.erl b/test/tsuru_forward_decay_test.erl index 775360f467719684ddebbb6c556bc5aee1320dcd..bd6814a9ce8d320060c60b855633b4e04a842dfb 100644 --- a/test/tsuru_forward_decay_test.erl +++ b/test/tsuru_forward_decay_test.erl @@ -11,6 +11,7 @@ basic_test() -> fun({Time, Value}, ForwardDecay) -> case tsuru_forward_decay:add_event(Time, Value, ForwardDecay) of {ok, NewForwardDecay} -> + tsuru_forward_decay:delete(ForwardDecay), NewForwardDecay; ok -> ForwardDecay