com.neeve.ods

Interface IStoreReplicatorStats

All Superinterfaces:

IStats

public interface IStoreReplicatorStats
extends IStats

Defines an ODS store replicator's statistics interface.

Nested Class Summary

Nested classes/interfaces inherited from interface com.neeve.stats.IStats

IStats.Counter, IStats.Gauge, IStats.Latencies, IStats.Series

Method Summary

Methods

Modifier and Type	Method and Description
int	getDetachedDispatchDisruptorCapacity() Get a replicator's detached dispatch disruptor capacity (applicable only if operating in detached dispatch mode)
String	getDetachedDispatchDisruptorClaimStrategy() Get a replicator's detached dispatch disruptor claim strategy (applicable only if operating in detached dispatch mode)
int	getDetachedDispatchDisruptorRemaining() Get a replicator's detached dispatch disruptor remaining (applicable only if operating in detached dispatch mode)
String	getDetachedDispatchDisruptorWaitStrategy() Get a replicator's detached dispatch disruptor wait strategy (applicable only if operating in detached dispatch mode)
IStats.Latencies	getDetachedDispatchOfferToPollLatencies() Get a replicator's offer to poll latencies of the detached dispatch queue.
int	getDetachedSendDisruptorCapacity() Get a replicator's detached send disruptor capacity (applicable only if operating in detached send mode)
String	getDetachedSendDisruptorClaimStrategy() Get a replicator's detached send disruptor claim strategy (applicable only if operating in detached send mode)
int	getDetachedSendDisruptorRemaining() Get a replicator's detached send disruptor remaining (applicable only if operating in detached send mode)
String	getDetachedSendDisruptorWaitStrategy() Get a replicator's detached send disruptor wait strategy (applicable only if operating in detached send mode)
IStats.Latencies	getDetachedSendOfferToPollLatencies() Get a replicator's offer to poll latencies of the detached send queue.
long	getNumCommitAcksReceived() Get the number of commit acks received
long	getNumCommitAcksSent() Get the number of commit acks sent
long	getNumCommitEntriesReceived() Get the number of commit entries (packet) received
long	getNumCommitEntriesSent() Get the number of commit entries (packet) sent
long	getNumCommitsReceived() Get the number of full commits (transactions) received
long	getNumCommitsSent() Get the number of full commits (transactions) sent
boolean	isDetachedDispatch() Is a replicator operating in detached dispatch mode?
boolean	isDetachedSend() Is a replicator operating in detached send mode?

Methods inherited from interface com.neeve.stats.IStats

close, get, getLogger, getName, getType, startPeriodicOutput, stopPeriodicOutput

Method Detail

getNumCommitsReceived

long getNumCommitsReceived()

Get the number of full commits (transactions) received

getNumCommitEntriesReceived

long getNumCommitEntriesReceived()

Get the number of commit entries (packet) received

getNumCommitsSent

long getNumCommitsSent()

Get the number of full commits (transactions) sent

getNumCommitEntriesSent

long getNumCommitEntriesSent()

Get the number of commit entries (packet) sent

getNumCommitAcksReceived

long getNumCommitAcksReceived()

Get the number of commit acks received

getNumCommitAcksSent

long getNumCommitAcksSent()

Get the number of commit acks sent

isDetachedSend

boolean isDetachedSend()

Is a replicator operating in detached send mode?

getDetachedSendDisruptorCapacity

int getDetachedSendDisruptorCapacity()

Get a replicator's detached send disruptor capacity (applicable only if operating in detached send mode)

getDetachedSendDisruptorRemaining

int getDetachedSendDisruptorRemaining()

Get a replicator's detached send disruptor remaining (applicable only if operating in detached send mode)

getDetachedSendDisruptorClaimStrategy

String getDetachedSendDisruptorClaimStrategy()

Get a replicator's detached send disruptor claim strategy (applicable only if operating in detached send mode)

getDetachedSendDisruptorWaitStrategy

String getDetachedSendDisruptorWaitStrategy()

Get a replicator's detached send disruptor wait strategy (applicable only if operating in detached send mode)

getDetachedSendOfferToPollLatencies

IStats.Latencies getDetachedSendOfferToPollLatencies()

Get a replicator's offer to poll latencies of the detached send queue. This is only applicable if the replicator is operating in detached send mode. The "offer to poll" time is the time it takes for events to pass through the send queue i.e. how latent the events are in the queue.

Returns:

The 'offer to poll' latencies of the detached send queue

isDetachedDispatch

boolean isDetachedDispatch()

Is a replicator operating in detached dispatch mode?

getDetachedDispatchDisruptorCapacity

int getDetachedDispatchDisruptorCapacity()

Get a replicator's detached dispatch disruptor capacity (applicable only if operating in detached dispatch mode)

getDetachedDispatchDisruptorRemaining

int getDetachedDispatchDisruptorRemaining()

Get a replicator's detached dispatch disruptor remaining (applicable only if operating in detached dispatch mode)

getDetachedDispatchDisruptorClaimStrategy

String getDetachedDispatchDisruptorClaimStrategy()

Get a replicator's detached dispatch disruptor claim strategy (applicable only if operating in detached dispatch mode)

getDetachedDispatchDisruptorWaitStrategy

String getDetachedDispatchDisruptorWaitStrategy()

Get a replicator's detached dispatch disruptor wait strategy (applicable only if operating in detached dispatch mode)

getDetachedDispatchOfferToPollLatencies

IStats.Latencies getDetachedDispatchOfferToPollLatencies()

Get a replicator's offer to poll latencies of the detached dispatch queue. This is only applicable if the replicator is operating in detached dispatch mode. The "offer to poll" time is the time it takes for events to pass through the dispatch queue i.e. how latent the events are in the queue.

Returns:

The 'offer to poll' latencies of the detached dispatch queue