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 java.lang.Object

A umbrella class for request related stats.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) OpStatsLogger	addEntryBlockedStats
(package private) java.util.concurrent.atomic.AtomicInteger	addsBlocked
(package private) java.util.concurrent.atomic.AtomicInteger	addsInProgress
(package private) OpStatsLogger	channelWriteStats
(package private) OpStatsLogger	fenceReadEntryStats
(package private) OpStatsLogger	fenceReadRequestStats
(package private) OpStatsLogger	fenceReadWaitStats
(package private) OpStatsLogger	forceLedgerRequestStats
(package private) OpStatsLogger	forceLedgerStats
(package private) OpStatsLogger	getBookieInfoRequestStats
(package private) OpStatsLogger	getBookieInfoStats
(package private) OpStatsLogger	getListOfEntriesOfLedgerRequestStats
(package private) OpStatsLogger	getListOfEntriesOfLedgerStats
(package private) OpStatsLogger	longPollPreWaitStats
(package private) OpStatsLogger	longPollReadRequestStats
(package private) OpStatsLogger	longPollReadStats
(package private) OpStatsLogger	longPollWaitStats
(package private) java.util.concurrent.atomic.AtomicInteger	maxAddsInProgress
(package private) java.util.concurrent.atomic.AtomicInteger	maxReadsInProgress
(package private) OpStatsLogger	readEntryBlockedStats
(package private) OpStatsLogger	readEntrySchedulingDelayStats
(package private) OpStatsLogger	readEntryStats
(package private) OpStatsLogger	readLacRequestStats
(package private) OpStatsLogger	readLacStats
(package private) Counter	readLastEntryNoEntryErrorCounter
(package private) OpStatsLogger	readRequestStats
(package private) java.util.concurrent.atomic.AtomicInteger	readsBlocked
(package private) java.util.concurrent.atomic.AtomicInteger	readsInProgress
(package private) OpStatsLogger	writeLacRequestStats
(package private) OpStatsLogger	writeLacStats

Constructor Summary

Constructors

Constructor	Description
RequestStats(StatsLogger statsLogger)

Method Summary

Modifier and Type	Method	Description
(package private) void	blockAddRequest()
(package private) void	blockReadRequest()
OpStatsLogger	getAddEntryBlockedStats()
Counter	getAddEntryRejectedCounter()
OpStatsLogger	getAddEntryStats()
OpStatsLogger	getAddRequestStats()
java.util.concurrent.atomic.AtomicInteger	getAddsBlocked()
java.util.concurrent.atomic.AtomicInteger	getAddsInProgress()
OpStatsLogger	getChannelWriteStats()
OpStatsLogger	getFenceReadEntryStats()
OpStatsLogger	getFenceReadRequestStats()
OpStatsLogger	getFenceReadWaitStats()
OpStatsLogger	getForceLedgerRequestStats()
OpStatsLogger	getForceLedgerStats()
OpStatsLogger	getGetBookieInfoRequestStats()
OpStatsLogger	getGetBookieInfoStats()
OpStatsLogger	getGetListOfEntriesOfLedgerRequestStats()
OpStatsLogger	getGetListOfEntriesOfLedgerStats()
OpStatsLogger	getLongPollPreWaitStats()
OpStatsLogger	getLongPollReadRequestStats()
OpStatsLogger	getLongPollReadStats()
OpStatsLogger	getLongPollWaitStats()
java.util.concurrent.atomic.AtomicInteger	getMaxAddsInProgress()
java.util.concurrent.atomic.AtomicInteger	getMaxReadsInProgress()
OpStatsLogger	getReadEntryBlockedStats()
Counter	getReadEntryRejectedCounter()
OpStatsLogger	getReadEntrySchedulingDelayStats()
OpStatsLogger	getReadEntryStats()
OpStatsLogger	getReadLacRequestStats()
OpStatsLogger	getReadLacStats()
Counter	getReadLastEntryNoEntryErrorCounter()
OpStatsLogger	getReadRequestStats()
java.util.concurrent.atomic.AtomicInteger	getReadsBlocked()
java.util.concurrent.atomic.AtomicInteger	getReadsInProgress()
OpStatsLogger	getWriteLacRequestStats()
OpStatsLogger	getWriteLacStats()
OpStatsLogger	getWriteThreadQueuedLatency()
(package private) int	maxAddsInProgressCount()
(package private) int	maxReadsInProgressCount()
(package private) void	trackAddRequest()
(package private) void	trackReadRequest()
(package private) void	unblockAddRequest(long delayNanos)
(package private) void	unblockReadRequest(long delayNanos)
(package private) void	untrackAddRequest()
(package private) void	untrackReadRequest()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

addsInProgress

final java.util.concurrent.atomic.AtomicInteger addsInProgress

maxAddsInProgress

final java.util.concurrent.atomic.AtomicInteger maxAddsInProgress

addsBlocked

final java.util.concurrent.atomic.AtomicInteger addsBlocked

readsInProgress

final java.util.concurrent.atomic.AtomicInteger readsInProgress

readsBlocked

final java.util.concurrent.atomic.AtomicInteger readsBlocked

maxReadsInProgress

final java.util.concurrent.atomic.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 Detail

RequestStats

public RequestStats(StatsLogger statsLogger)

Method Detail

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 java.util.concurrent.atomic.AtomicInteger getAddsInProgress()

getMaxAddsInProgress

public java.util.concurrent.atomic.AtomicInteger getMaxAddsInProgress()

getAddsBlocked

public java.util.concurrent.atomic.AtomicInteger getAddsBlocked()

getReadsInProgress

public java.util.concurrent.atomic.AtomicInteger getReadsInProgress()

getReadsBlocked

public java.util.concurrent.atomic.AtomicInteger getReadsBlocked()

getMaxReadsInProgress

public java.util.concurrent.atomic.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()