anchor.diff:      {ok, KV} = ns_memcached:stats(couch_util:to_list(BucketName), io_lib:format("vbucket-seqno ~B", [Vb])),
       Key = iolist_to_binary(io_lib:format("vb_~B:uuid", [Vb])),
       misc:expect_prop_value(Key, KV).
  -
  -get_failover_uuid(BucketName, Vb) ->
  -    {U, _} = lists:last(xdcr_upr_streamer:get_failover_log(couch_util:to_list(BucketName), Vb)),
  -    U.
  
positive.code:      TotalDataReplicated,
       RemoteVBOpaque}.
  
  parse_validate_checkpoint_doc(Rep, Vb, Body, ApiRequestBase) ->
      try
          do_parse_validate_checkpoint_doc(Rep, Vb, Body, ApiRequestBase)
      catch T:E ->
              S = erlang:get_stacktrace(),
              ?xdcr_debug("Got parse_validate_checkpoint_doc exception: ~p:~p~n~p", [T, E, S]),
              erlang:raise(T, E, S)
      end.
  
  do_parse_validate_checkpoint_doc(Rep, Vb, Body0, ApiRequestBase) ->
      Body = case Body0 of
                 {XB} -> XB;
                 _ -> []
  
negative.code:     DocId = build_commit_doc_id(Rep, Vb),
      case couch_db:open_doc_int(DB, DocId, [ejson_body]) of
          {ok, #doc{body = Body}} ->
              parse_validate_checkpoint_doc(Vb, Body, ApiRequestBase);
          {not_found, _} ->
              ?xdcr_debug("Found no local checkpoint document for vb: ~B. Will start from scratch", [Vb]),
              handle_no_checkpoint(ApiRequestBase)
  