anchor.diff:                             DcpInfo),
   
       {ok, State#state{last_ts = TS,
  -                     tap_info = NewTapInfo,
                        dcp_info = NewDcpInfo,
                        last_update_local_clock = misc:time_to_epoch_ms_int(now())}};
   
  
positive.code: new_safeness_info(_, _, _, _, Info) ->
      Info.
  
  pick_level(unknown, _) ->
      unknown;
  pick_level(_, unknown) ->
      unknown;
  pick_level(green, green) ->
      green;
  pick_level(_, _) ->
      yellow.
  
  handle_call(get_level, #state{last_update_local_clock = UpdateTS,
                                tap_info = #safeness_info{safeness_level = TapLevel},
                                dcp_info = #safeness_info{safeness_level = DcpLevel}} = State) ->
      Now = misc:time_to_epoch_ms_int(now()),
      RV = case Now - UpdateTS > ?STALENESS_THRESHOLD of
               true ->
                   stale;
               _ ->
                   pick_level(TapLevel, DcpLevel)
           end,
      {ok, {ok, RV}, State};
  handle_call(get_state, State) ->
  
negative.code: 
  init([BucketName]) ->
      {ok, #state{bucket_name = BucketName,
                  dcp_info = #safeness_info{},
                  last_update_local_clock = misc:time_to_epoch_ms_int(now())}}.
  
  