Package org.apache.bookkeeper.client.impl

Class BookKeeperClientStatsImpl

java.lang.Object

org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl

All Implemented Interfaces:

BookKeeperClientStats

@StatsDoc(name="bookkeeper_client",
          category="client",
          help="BookKeeper client stats")
public class BookKeeperClientStatsImpl
extends Object
implements BookKeeperClientStats

The default implementation of BookKeeperClientStats.

Field Summary

Fields inherited from interface org.apache.bookkeeper.client.BookKeeperClientStats

ACTIVE_NON_TLS_CHANNEL_COUNTER, ACTIVE_TLS_CHANNEL_COUNTER, ADD_OP, ADD_OP_OUTSTANDING, ADD_OP_UR, BOOKIE_LABEL, CATEGORY_CLIENT, CHANNEL_ADD_OP, CHANNEL_FORCE_OP, CHANNEL_READ_LAC_OP, CHANNEL_READ_OP, CHANNEL_SCOPE, CHANNEL_START_TLS_OP, CHANNEL_TIMEOUT_ADD, CHANNEL_TIMEOUT_FORCE, CHANNEL_TIMEOUT_READ, CHANNEL_TIMEOUT_READ_LAC, CHANNEL_TIMEOUT_START_TLS_OP, CHANNEL_TIMEOUT_WRITE_LAC, CHANNEL_WRITE_LAC_OP, CLIENT_CHANNEL_WRITE_WAIT, CLIENT_CONNECT_TIMER, CLIENT_SCOPE, CREATE_OP, DELETE_OP, ENSEMBLE_CHANGES, FAILED_CONNECTION_COUNTER, FAILED_TLS_HANDSHAKE_COUNTER, FORCE_OP, GET_BOOKIE_INFO_OP, GET_LIST_OF_ENTRIES_OF_LEDGER_OP, LAC_UPDATE_HITS, LAC_UPDATE_MISSES, LEDGER_ENSEMBLE_BOOKIE_DISTRIBUTION, LEDGER_RECOVER_ADD_ENTRIES, LEDGER_RECOVER_READ_ENTRIES, NETTY_EXCEPTION_CNT, NETTY_OPS, NUM_WRITABLE_BOOKIES_IN_DEFAULT_FAULTDOMAIN, NUM_WRITABLE_BOOKIES_IN_DEFAULT_RACK, OPEN_OP, PENDING_ADDS, READ_LAC_OP, READ_LAST_CONFIRMED_AND_ENTRY, READ_LAST_CONFIRMED_AND_ENTRY_RESPONSE, READ_OP, READ_OP_DM, READ_OP_OUTSTANDING, READ_REQUESTS_REORDERED, RECOVER_OP, SPECULATIVE_READ_COUNT, TIMEOUT_GET_BOOKIE_INFO, TIMEOUT_GET_LIST_OF_ENTRIES_OF_LEDGER, WRITE_DELAYED_DUE_TO_NOT_ENOUGH_FAULT_DOMAINS, WRITE_DELAYED_DUE_TO_NOT_ENOUGH_FAULT_DOMAINS_LATENCY, WRITE_LAC_OP, WRITE_TIMED_OUT_DUE_TO_NOT_ENOUGH_FAULT_DOMAINS

Constructor Summary

Constructors

Constructor	Description
BookKeeperClientStatsImpl(StatsLogger stats)

Method Summary

Modifier and Type	Method	Description
OpStatsLogger	getAddOpLogger()
Counter	getAddOpUrCounter()
OpStatsLogger	getClientChannelWriteWaitLogger()
OpStatsLogger	getCreateOpLogger()
OpStatsLogger	getDeleteOpLogger()
Counter	getEnsembleBookieDistributionCounter(String bookie)
Counter	getEnsembleChangeCounter()
OpStatsLogger	getForceOpLogger()
Counter	getLacUpdateHitsCounter()
Counter	getLacUpdateMissesCounter()
OpStatsLogger	getOpenOpLogger()
OpStatsLogger	getReadLacAndEntryOpLogger()
OpStatsLogger	getReadLacAndEntryRespLogger()
OpStatsLogger	getReadLacOpLogger()
Counter	getReadOpDmCounter()
OpStatsLogger	getReadOpLogger()
OpStatsLogger	getRecoverAddCountLogger()
OpStatsLogger	getRecoverOpLogger()
OpStatsLogger	getRecoverReadCountLogger()
Counter	getSpeculativeReadCounter()
Counter	getWriteDelayedDueToNotEnoughFaultDomains()
OpStatsLogger	getWriteDelayedDueToNotEnoughFaultDomainsLatency()
OpStatsLogger	getWriteLacOpLogger()
Counter	getWriteTimedOutDueToNotEnoughFaultDomains()
void	registerPendingAddsGauge(Gauge<Integer> gauge)

Methods inherited from class java.lang.Object

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

Constructor Details

BookKeeperClientStatsImpl

public BookKeeperClientStatsImpl(StatsLogger stats)

Method Details

getCreateOpLogger

public OpStatsLogger getCreateOpLogger()

Specified by:

getCreateOpLogger in interface BookKeeperClientStats

getOpenOpLogger

public OpStatsLogger getOpenOpLogger()

Specified by:

getOpenOpLogger in interface BookKeeperClientStats

getDeleteOpLogger

public OpStatsLogger getDeleteOpLogger()

Specified by:

getDeleteOpLogger in interface BookKeeperClientStats

getRecoverOpLogger

public OpStatsLogger getRecoverOpLogger()

Specified by:

getRecoverOpLogger in interface BookKeeperClientStats

getReadOpLogger

public OpStatsLogger getReadOpLogger()

Specified by:

getReadOpLogger in interface BookKeeperClientStats

getReadLacAndEntryOpLogger

public OpStatsLogger getReadLacAndEntryOpLogger()

Specified by:

getReadLacAndEntryOpLogger in interface BookKeeperClientStats

getReadLacAndEntryRespLogger

public OpStatsLogger getReadLacAndEntryRespLogger()

Specified by:

getReadLacAndEntryRespLogger in interface BookKeeperClientStats

getAddOpLogger

public OpStatsLogger getAddOpLogger()

Specified by:

getAddOpLogger in interface BookKeeperClientStats

getForceOpLogger

public OpStatsLogger getForceOpLogger()

Specified by:

getForceOpLogger in interface BookKeeperClientStats

getWriteLacOpLogger

public OpStatsLogger getWriteLacOpLogger()

Specified by:

getWriteLacOpLogger in interface BookKeeperClientStats

getReadLacOpLogger

public OpStatsLogger getReadLacOpLogger()

Specified by:

getReadLacOpLogger in interface BookKeeperClientStats

getRecoverAddCountLogger

public OpStatsLogger getRecoverAddCountLogger()

Specified by:

getRecoverAddCountLogger in interface BookKeeperClientStats

getRecoverReadCountLogger

public OpStatsLogger getRecoverReadCountLogger()

Specified by:

getRecoverReadCountLogger in interface BookKeeperClientStats

getReadOpDmCounter

public Counter getReadOpDmCounter()

Specified by:

getReadOpDmCounter in interface BookKeeperClientStats

getAddOpUrCounter

public Counter getAddOpUrCounter()

Specified by:

getAddOpUrCounter in interface BookKeeperClientStats

getSpeculativeReadCounter

public Counter getSpeculativeReadCounter()

Specified by:

getSpeculativeReadCounter in interface BookKeeperClientStats

getEnsembleChangeCounter

public Counter getEnsembleChangeCounter()

Specified by:

getEnsembleChangeCounter in interface BookKeeperClientStats

getLacUpdateHitsCounter

public Counter getLacUpdateHitsCounter()

Specified by:

getLacUpdateHitsCounter in interface BookKeeperClientStats

getLacUpdateMissesCounter

public Counter getLacUpdateMissesCounter()

Specified by:

getLacUpdateMissesCounter in interface BookKeeperClientStats

getClientChannelWriteWaitLogger

public OpStatsLogger getClientChannelWriteWaitLogger()

Specified by:

getClientChannelWriteWaitLogger in interface BookKeeperClientStats

getEnsembleBookieDistributionCounter

public Counter getEnsembleBookieDistributionCounter(String bookie)

Specified by:

getEnsembleBookieDistributionCounter in interface BookKeeperClientStats

getWriteDelayedDueToNotEnoughFaultDomainsLatency

public OpStatsLogger getWriteDelayedDueToNotEnoughFaultDomainsLatency()

Specified by:

getWriteDelayedDueToNotEnoughFaultDomainsLatency in interface BookKeeperClientStats

getWriteDelayedDueToNotEnoughFaultDomains

public Counter getWriteDelayedDueToNotEnoughFaultDomains()

Specified by:

getWriteDelayedDueToNotEnoughFaultDomains in interface BookKeeperClientStats

getWriteTimedOutDueToNotEnoughFaultDomains

public Counter getWriteTimedOutDueToNotEnoughFaultDomains()

Specified by:

getWriteTimedOutDueToNotEnoughFaultDomains in interface BookKeeperClientStats

registerPendingAddsGauge

public void registerPendingAddsGauge(Gauge<Integer> gauge)

Specified by:

registerPendingAddsGauge in interface BookKeeperClientStats