anchor.diff:  
   init([Partition]) ->
       ok = dalmatiner_vacuum:register(),
  -    erlang:send_after(?TICK, self(), tick),
  -    Timestamp = erlang:system_time(milli_seconds),
       process_flag(trap_exit, true),
       random:seed(erlang:phash2([node()]),
                   erlang:monotonic_time(),
  
positive.code: %% Return the latest point we'd ever want to save. This is more strict
  %% then the expiration we do on the data but it is strong enough for
  %% our guarantee.
  expiery(Bucket, State = #state{now = Now}) ->
      case get_lifetime(Bucket, State) of
          {infinity, State1} ->
              {infinity, State1};
  
negative.code:     Reply = {ok, undefined, {P, N}, R},
      {reply, Reply, State}.
  
  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 expiry(Bucket, SAcc) of
                                  {infinity, SAcc1} ->
                                      SAcc1;
                                  {Exp, SAcc1} ->
  