Package org.apache.bookkeeper.proto

Class RequestStats

java.lang.Object
org.apache.bookkeeper.proto.RequestStats
@StatsDoc(name="bookkeeper_server", category="server", help="Bookie request stats") public class RequestStats extends Object
A umbrella class for request related stats.

  • Field Details

    • addsInProgress

      final AtomicInteger addsInProgress

    • maxAddsInProgress

      final AtomicInteger maxAddsInProgress

    • addsBlocked

      final AtomicInteger addsBlocked

    • readsInProgress

      final AtomicInteger readsInProgress

    • readsBlocked

      final AtomicInteger readsBlocked

    • maxReadsInProgress

      final AtomicInteger maxReadsInProgress

    • readRequestStats

      @StatsDoc(name="READ_ENTRY_REQUEST", help="request stats of ReadEntry on a bookie") final OpStatsLogger readRequestStats

    • readEntryStats

      @StatsDoc(name="READ_ENTRY", help="operation stats of ReadEntry on a bookie", parent="READ_ENTRY_REQUEST") final OpStatsLogger readEntryStats

    • forceLedgerStats

      @StatsDoc(name="FORCE_LEDGER", help="operation stats of ForceLedger on a bookie", parent="FORCE_LEDGER_REQUEST") final OpStatsLogger forceLedgerStats

    • forceLedgerRequestStats

      @StatsDoc(name="FORCE_LEDGER_REQUEST", help="request stats of ForceLedger on a bookie") final OpStatsLogger forceLedgerRequestStats

    • fenceReadRequestStats

      @StatsDoc(name="READ_ENTRY_FENCE_REQUEST", help="request stats of FenceRead on a bookie") final OpStatsLogger fenceReadRequestStats

    • fenceReadEntryStats

      @StatsDoc(name="READ_ENTRY_FENCE_READ", help="operation stats of FenceRead on a bookie", parent="READ_ENTRY_FENCE_REQUEST", happensAfter="READ_ENTRY_FENCE_WAIT") final OpStatsLogger fenceReadEntryStats

    • fenceReadWaitStats

      @StatsDoc(name="READ_ENTRY_FENCE_WAIT", help="operation stats of FenceReadWait on a bookie", parent="READ_ENTRY_FENCE_REQUEST") final OpStatsLogger fenceReadWaitStats

    • readEntrySchedulingDelayStats

      @StatsDoc(name="READ_ENTRY_SCHEDULING_DELAY", help="operation stats of ReadEntry scheduling delays on a bookie") final OpStatsLogger readEntrySchedulingDelayStats

    • longPollPreWaitStats

      @StatsDoc(name="READ_ENTRY_LONG_POLL_PRE_WAIT", help="operation stats of LongPoll Reads pre wait time on a bookie", parent="READ_ENTRY_LONG_POLL_REQUEST") final OpStatsLogger longPollPreWaitStats

    • longPollWaitStats

      @StatsDoc(name="READ_ENTRY_LONG_POLL_WAIT", help="operation stats of LongPoll Reads wait time on a bookie", happensAfter="READ_ENTRY_LONG_POLL_PRE_WAIT", parent="READ_ENTRY_LONG_POLL_REQUEST") final OpStatsLogger longPollWaitStats

    • longPollReadStats

      @StatsDoc(name="READ_ENTRY_LONG_POLL_READ", help="operation stats of LongPoll Reads on a bookie", happensAfter="READ_ENTRY_LONG_POLL_WAIT", parent="READ_ENTRY_LONG_POLL_REQUEST") final OpStatsLogger longPollReadStats

    • longPollReadRequestStats

      @StatsDoc(name="READ_ENTRY_LONG_POLL_REQUEST", help="request stats of LongPoll Reads on a bookie") final OpStatsLogger longPollReadRequestStats

    • readLastEntryNoEntryErrorCounter

      @StatsDoc(name="READ_LAST_ENTRY_NOENTRY_ERROR", help="total NOENTRY errors of reading last entry on a bookie") final Counter readLastEntryNoEntryErrorCounter

    • writeLacRequestStats

      @StatsDoc(name="WRITE_LAC_REQUEST", help="request stats of WriteLac on a bookie") final OpStatsLogger writeLacRequestStats

    • writeLacStats

      @StatsDoc(name="WRITE_LAC", help="operation stats of WriteLac on a bookie", parent="WRITE_LAC_REQUEST") final OpStatsLogger writeLacStats

    • readLacRequestStats

      @StatsDoc(name="READ_LAC_REQUEST", help="request stats of ReadLac on a bookie") final OpStatsLogger readLacRequestStats

    • readLacStats

      @StatsDoc(name="READ_LAC", help="operation stats of ReadLac on a bookie", parent="READ_LAC_REQUEST") final OpStatsLogger readLacStats

    • getBookieInfoRequestStats

      @StatsDoc(name="GET_BOOKIE_INFO_REQUEST", help="request stats of GetBookieInfo on a bookie") final OpStatsLogger getBookieInfoRequestStats

    • getBookieInfoStats

      @StatsDoc(name="GET_BOOKIE_INFO", help="operation stats of GetBookieInfo on a bookie") final OpStatsLogger getBookieInfoStats

    • channelWriteStats

      @StatsDoc(name="CHANNEL_WRITE", help="channel write stats on a bookie") final OpStatsLogger channelWriteStats

    • addEntryBlockedStats

      @StatsDoc(name="ADD_ENTRY_BLOCKED", help="operation stats of AddEntry blocked on a bookie") final OpStatsLogger addEntryBlockedStats

    • readEntryBlockedStats

      @StatsDoc(name="READ_ENTRY_BLOCKED", help="operation stats of ReadEntry blocked on a bookie") final OpStatsLogger readEntryBlockedStats

    • getListOfEntriesOfLedgerRequestStats

      @StatsDoc(name="GET_LIST_OF_ENTRIES_OF_LEDGER_REQUEST", help="request stats of GetListOfEntriesOfLedger on a bookie") final OpStatsLogger getListOfEntriesOfLedgerRequestStats

    • getListOfEntriesOfLedgerStats

      @StatsDoc(name="GET_LIST_OF_ENTRIES_OF_LEDGER", help="operation stats of GetListOfEntriesOfLedger", parent="GET_LIST_OF_ENTRIES_OF_LEDGER_REQUEST") final OpStatsLogger getListOfEntriesOfLedgerStats

  • Constructor Details

    • RequestStats

      public RequestStats(StatsLogger statsLogger)

  • Method Details

    • blockAddRequest

      void blockAddRequest()

    • unblockAddRequest

      void unblockAddRequest(long delayNanos)

    • trackAddRequest

      void trackAddRequest()

    • untrackAddRequest

      void untrackAddRequest()

    • maxAddsInProgressCount

      int maxAddsInProgressCount()

    • blockReadRequest

      void blockReadRequest()

    • unblockReadRequest

      void unblockReadRequest(long delayNanos)

    • trackReadRequest

      void trackReadRequest()

    • untrackReadRequest

      void untrackReadRequest()

    • maxReadsInProgressCount

      int maxReadsInProgressCount()

    • getAddsInProgress

      public AtomicInteger getAddsInProgress()

    • getMaxAddsInProgress

      public AtomicInteger getMaxAddsInProgress()

    • getAddsBlocked

      public AtomicInteger getAddsBlocked()

    • getReadsInProgress

      public AtomicInteger getReadsInProgress()

    • getReadsBlocked

      public AtomicInteger getReadsBlocked()

    • getMaxReadsInProgress

      public AtomicInteger getMaxReadsInProgress()

    • getAddRequestStats

      public OpStatsLogger getAddRequestStats()

    • getAddEntryStats

      public OpStatsLogger getAddEntryStats()

    • getWriteThreadQueuedLatency

      public OpStatsLogger getWriteThreadQueuedLatency()

    • getAddEntryRejectedCounter

      public Counter getAddEntryRejectedCounter()

    • getReadRequestStats

      public OpStatsLogger getReadRequestStats()

    • getReadEntryStats

      public OpStatsLogger getReadEntryStats()

    • getReadEntryRejectedCounter

      public Counter getReadEntryRejectedCounter()

    • getForceLedgerStats

      public OpStatsLogger getForceLedgerStats()

    • getForceLedgerRequestStats

      public OpStatsLogger getForceLedgerRequestStats()

    • getFenceReadRequestStats

      public OpStatsLogger getFenceReadRequestStats()

    • getFenceReadEntryStats

      public OpStatsLogger getFenceReadEntryStats()

    • getFenceReadWaitStats

      public OpStatsLogger getFenceReadWaitStats()

    • getReadEntrySchedulingDelayStats

      public OpStatsLogger getReadEntrySchedulingDelayStats()

    • getLongPollPreWaitStats

      public OpStatsLogger getLongPollPreWaitStats()

    • getLongPollWaitStats

      public OpStatsLogger getLongPollWaitStats()

    • getLongPollReadStats

      public OpStatsLogger getLongPollReadStats()

    • getLongPollReadRequestStats

      public OpStatsLogger getLongPollReadRequestStats()

    • getReadLastEntryNoEntryErrorCounter

      public Counter getReadLastEntryNoEntryErrorCounter()

    • getWriteLacRequestStats

      public OpStatsLogger getWriteLacRequestStats()

    • getWriteLacStats

      public OpStatsLogger getWriteLacStats()

    • getReadLacRequestStats

      public OpStatsLogger getReadLacRequestStats()

    • getReadLacStats

      public OpStatsLogger getReadLacStats()

    • getGetBookieInfoRequestStats

      public OpStatsLogger getGetBookieInfoRequestStats()

    • getGetBookieInfoStats

      public OpStatsLogger getGetBookieInfoStats()

    • getChannelWriteStats

      public OpStatsLogger getChannelWriteStats()

    • getAddEntryBlockedStats

      public OpStatsLogger getAddEntryBlockedStats()

    • getReadEntryBlockedStats

      public OpStatsLogger getReadEntryBlockedStats()

    • getGetListOfEntriesOfLedgerRequestStats

      public OpStatsLogger getGetListOfEntriesOfLedgerRequestStats()

    • getGetListOfEntriesOfLedgerStats

      public OpStatsLogger getGetListOfEntriesOfLedgerStats()