z.LastFailedCount, err = dc.ReadUint64()
			if err != nil {
				err = msgp.WrapError(err, "LastFailedCount")
				return
			}
		case "TotalDroppedCount":
			z.TotalDroppedCount, err = dc.ReadUint64()
			if err != nil {
				err = msgp.WrapError(err, "TotalDroppedCount")
				return
			}
		case "TotalDroppedBytes":
			z.TotalDroppedBytes, err = dc.ReadUint64()
			if err != nil {

type ReplicationMRFStats struct {
	LastFailedCount uint64 `json:"failedCount_last5min"`
	// Count of unreplicated entries that were dropped after MRF retry limit reached since cluster start.
	TotalDroppedCount uint64 `json:"droppedCount_since_uptime"`
	// Bytes of unreplicated entries that were dropped after MRF retry limit reached since cluster start.
	TotalDroppedBytes uint64 `json:"droppedBytes_since_uptime"`
}

		atomic.AddUint64(&p.stats.mrfStats.TotalDroppedCount, 1)
		atomic.AddUint64(&p.stats.mrfStats.TotalDroppedBytes, uint64(entry.sz))
		return
	}

	select {
	case <-GlobalContext.Done():
		return
	case <-p.mrfStopCh:
		return
	default:
		select {
		case p.mrfSaveCh <- entry:
		default:
			atomic.AddUint64(&p.stats.mrfStats.TotalDroppedCount, 1)