anchor.diff:                                            {name,<<Prefix/binary, "wtavg_docs_latency">>},
                                             {desc,<<"Weighted average latency in ms of sending replicated mutations to remote cluster "
                                                     "(measured from per-replication stat wtavg_docs_latency)">>}]},
  -                                 {struct,[{title,<<"Number of document in replication queue">>},
  -                                          {name,<<Prefix/binary, "docs_rep_queue">>},
  -                                          {desc,<<"The number of documents in the replication queue "
  -                                                  "(measured from per-replication stat docs_rep_queue)">>}]},
  -                                 {struct,[{isBytes,true},
  -                                          {title,<<"size of replication queue">>},
  -                                          {name,<<Prefix/binary, "size_rep_queue">>},
  -                                          {desc,<<"The total size (in bytes) of all documents in the replication queue "
  -                                                  "(measured from per-replication stat size_rep_queue)">>}]},
  -                                 {struct,[{title,<<"Number of checkpoints">>},
  -                                          {name,<<Prefix/binary,"num_checkpoints">>},
  -                                          {desc,<<"Number of completed checkpoints "
  -                                                  "(measured from per-replication stat num_checkpoints)">>}]},
  -                                 {struct,[{title,<<"Number of failed checkpoints">>},
  -                                          {name,<<Prefix/binary, "num_failedckpts">>},
  -                                          {desc,<<"Number of failed checkpoints "
  -                                                  "(measured from per-replication stat num_failedckpts)">>}]},
  -                                 {struct,[{title,<<"time commiting checkpoints">>},
  -                                          {name,<<Prefix/binary, "time_committing">>},
  -                                          {desc,<<"Average time, in ms, spent in commiting checkpoints "
  -                                                  "(measured from per-replication stat time_committing)">>}]}
  -                                ]}]}
  +                                 {struct,[{title,<<"doc receival rate">>},
  +                                          {name,<<Prefix/binary,"rate_received_from_dcp">>},
  +                                          {desc,<<"Rate of mutations received from dcp in terms of number of mutations per second ">>}]}]}]}
                 end, Reps).
   
   
  
positive.code:     lists:flatmap(fun (Id) ->
                            Prefix = <<"replications/", Id/binary,"/">>,
  
                            PercentCompleteness = Z2(<<Prefix/binary, "docs_checked">>,
                                                     <<Prefix/binary, "changes_left">>,
                                                     fun (Checked, Left) ->
                                                             try (100 * Checked) / (Checked + Left)
                                                             catch error:badarith -> 0
                                                             end
                                                     end),
  
negative.code:                                           {name,<<Prefix/binary,"changes_left">>},
                                            {desc,<<"Number of mutations to be replicated to other clusters "
                                                    "(measured from per-replication stat changes_left)">>}]},
                                   {struct,[{title,<<"percent completed">>},
                                            {maxY, 100},
                                            {name,<<Prefix/binary, "percent_completeness">>},
                                            {desc,<<"Percentage of checked items out of all checked and to-be-replicated items "
                                                    "(measured from per-replication stat percent_completeness)">>}]},
                                   {struct,[{title,<<"outbound XDCR mutations filtered">>},
                                            {name,<<Prefix/binary,"docs_filtered">>},
                                            {desc,<<"Number of mutations that have been filtered out and have not been replicated to other clusters "
                                                    "(measured from per-replication stat docs_filtered)">>}]},
                                   {struct,[{title,<<"XDCR mutations failed conflict resolution on source">>},
                                            {name,<<Prefix/binary,"docs_failed_cr_source">>},
                                            {desc,<<"Number of mutations that failed conflict resolution on the source side and hence have not been replicated to other clusters "
                                                    "(measured from per-replication stat docs_failed_cr_source)">>}]},
                                   {struct,[{title,<<"mutation replication rate">>},
                                            {name,<<Prefix/binary,"rate_replicated">>},
                                            {desc,<<"Rate of replication in terms of number of replicated mutations per second "
                                                    "(measured from per-replication stat rate_replicated)">>}]},
                                   {struct,[{isBytes,true},
                                            {title,<<"data replication rate">>},
                                            {name,<<Prefix/binary,"bandwidth_usage">>},
  