anchor.diff:      end.
   
   handle_cancel_replication(XID, Req) ->
  +    case cluster_compat_mode:is_goxdcr_enabled() of
  +        false ->
  +            do_handle_cancel_replication(XID, Req);
  +        true ->
  +            menelaus_web:proxy_to_goxdcr(Req)
  +    end.
  +
  +do_handle_cancel_replication(XID, Req) ->
       case xdc_rdoc_api:delete_replicator_doc(XID) of
           ok ->
               menelaus_util:reply_json(Req, [], 200);
  
positive.code: -type replication_type() :: 'one-time' | continuous.
  
  handle_create_replication(Req) ->
      Params = Req:parse_post(),
      Config = ns_config:get(),
      Buckets = ns_bucket:get_buckets(Config),
  
negative.code: format_setting_value(_K, V) -> V.
  
  handle_replication_settings_post(XID, Req) ->
      case cluster_compat_mode:is_goxdcr_enabled() of
          false ->
              do_handle_replication_settings_post(XID, Req);
          true ->
              menelaus_web:proxy_to_goxdcr(Req)
      end.
  
  do_handle_replication_settings_post(XID, Req) ->
      with_replicator_doc(
        Req, XID,
        fun (RepDoc) ->
  