anchor.diff:      FoldWorkerPool = {pool, metric_worker, WorkerPoolSize, []},
       {ok, IO} = metric_io:start_link(Partition),
       {ok, #state{
  -            now = Timestamp,
               partition = Partition,
               node = node(),
               tbl = ets:new(P, [public, ordered_set]),
  
positive.code:     Reply = {ok, undefined, {P, N}, R},
      {reply, Reply, State}.
  
  handle_info(tick, State = #state{}) ->
      Timestamp = erlang:system_time(milli_seconds),
      erlang:send_after(?TICK, self(), tick),
      {ok, State#state{now = Timestamp}};
  
  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 =
          lists:foldl(fun (Bucket, SAcc) ->
                              case expiery(Bucket, SAcc) of
                                  {infinity, SAcc1} ->
                                      SAcc1;
                                  {Exp, SAcc1} ->
  
negative.code:           tbl,
            ct,
            io,
            resolutions = btrie:new(),
            lifetimes  = btrie:new()
           }).
  
  -define(MASTER, metric_vnode_master).
  -define(MAX_Q_LEN, 20).
  -define(VAC, 1000*60*60*2).
  
  %% API
  