anchor.diff:  handle_info(vacuum, State = #state{io = IO, partition = P}) ->
       lager:info("[vaccum] Starting vaccum for partution ~p.", [P]),
       {ok, Bs} = metric_io:buckets(IO),
  -    State1 =
  +    State1 = State#state{now = timestamp()},
  +    State2 =
           lists:foldl(fun (Bucket, SAcc) ->
                               case expiry(Bucket, SAcc) of
                                   {infinity, SAcc1} ->
  
positive.code:             node = node(),
              tbl = ets:new(P, [public, ordered_set]),
              io = IO,
              ct = CT
             },
       [FoldWorkerPool]}.
  
negative.code:           tbl,
            ct,
            io,
            now,
            resolutions = btrie:new(),
            lifetimes  = btrie:new()
           }).
  