com.neeve.ods
Interface IStoreJournallingWriterStats

All Superinterfaces:

com.neeve.stats.IStats, IStoreWriterStats

All Known Subinterfaces:

IRogLogStats, IStorePersisterStats, IStoreSenderStats

public interface IStoreJournallingWriterStats
extends IStoreWriterStats

Defines an ODS store journalling writer's statistics interface.

Nested Class Summary

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

com.neeve.stats.IStats.Counter, com.neeve.stats.IStats.Gauge, com.neeve.stats.IStats.Latencies

Method Summary

int	getDisruptorCapacity() Get a writer's disruptor capacity (applicable only if operating in detached mode)
String	getDisruptorClaimStrategy() Get a writer's disruptor claim strategy (applicable only if operating in detached mode)
int	getDisruptorRemaining() Get a writer's disruptor remaining (applicable only if operating in detached mode)
String	getDisruptorWaitStrategy() Get a writer's disruptor wait strategy (applicable only if operating in detached mode)
com.neeve.stats.IStats.Latencies	getOfferToPollLatencies() Get a writer's offer to poll latencies (applicable only if operating in detached mode).
boolean	isDetached() Is a journalling writer operating in detached write mode?

Methods inherited from interface com.neeve.ods.IStoreWriterStats

getNumCommits, getNumPutsRecorded, getNumRemovesRecorded, getNumSendsRecorded, getNumUpdatesRecorded

Methods inherited from interface com.neeve.stats.IStats

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

Method Detail

isDetached

boolean isDetached()

Is a journalling writer operating in detached write mode?

getDisruptorCapacity

int getDisruptorCapacity()

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

getDisruptorRemaining

int getDisruptorRemaining()

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

getDisruptorClaimStrategy

String getDisruptorClaimStrategy()

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

getDisruptorWaitStrategy

String getDisruptorWaitStrategy()

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

getOfferToPollLatencies

com.neeve.stats.IStats.Latencies getOfferToPollLatencies()

Get a writer's offer to poll latencies (applicable only if operating in detached mode). The records the time it takes events to pass through the disruptor.

Returns:

The writer's 'offer to poll' latencies