anchor.diff:  
   handle_event({stats, StatsBucket, #stat_entry{timestamp = TS, values = Values}},
                #state{bucket_name = StatsBucket,
  -                    tap_info = TapInfo,
                       dcp_info = DcpInfo,
                       last_ts = LastTS} = State) ->
  -    TapBacklogSize =
  -        case {orddict:find(ep_tap_replica_queue_backfillremaining, Values),
  -              orddict:find(ep_tap_replica_qlen, Values)} of
  -            {{ok, BackfillRemaining}, {ok, Qlen}} ->
  -                {ok, BackfillRemaining + Qlen};
  -            _ ->
  -                false
  -        end,
  -
  -    NewTapInfo =
  -         new_safeness_info(TapBacklogSize,
  -                           orddict:find(ep_tap_replica_queue_drain, Values),
  -                           TS,
  -                           LastTS,
  -                           TapInfo),
  -
       NewDcpInfo =
            new_safeness_info(orddict:find(ep_dcp_replica_items_remaining, Values),
                              orddict:find(ep_dcp_replica_items_sent, Values),
  
positive.code: 
  init([BucketName]) ->
      {ok, #state{bucket_name = BucketName,
                  tap_info = #safeness_info{},
                  dcp_info = #safeness_info{},
                  last_update_local_clock = misc:time_to_epoch_ms_int(now())}}.
  
  
negative.code:                            DcpInfo),
  
      {ok, State#state{last_ts = TS,
                       dcp_info = NewDcpInfo,
                       last_update_local_clock = misc:time_to_epoch_ms_int(now())}};
  
  