com.neeve.ods

Interface IStoreWriterStats

All Superinterfaces:

IStats

All Known Subinterfaces:

IRogLogStats, IStorePersisterStats, IStoreSenderStats

public interface IStoreWriterStats
extends IStats

Defines an ODS store writer'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	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)
long	getNumCommits() Get the number of commits performed by a writer
long	getNumForks() Get the number of forks performed by a writer
long	getNumPutsRecorded() Get the number of puts recorded with a writer
long	getNumRemovesRecorded() Get the number of removes recorded with a writer
long	getNumSendsRecorded() Get the number of sends recorded with a writer
long	getNumUpdatesRecorded() Get the number of updates recorded with a writer
IStats.Latencies	getOfferToPollLatencies() Get a writer's offer to poll latencies (applicable only if operating in detached mode).
boolean	isDetached() Is a writer operating in detached write mode?

Methods inherited from interface com.neeve.stats.IStats

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

Method Detail

getNumPutsRecorded

long getNumPutsRecorded()

Get the number of puts recorded with a writer

getNumUpdatesRecorded

long getNumUpdatesRecorded()

Get the number of updates recorded with a writer

getNumRemovesRecorded

long getNumRemovesRecorded()

Get the number of removes recorded with a writer

getNumSendsRecorded

long getNumSendsRecorded()

Get the number of sends recorded with a writer

getNumCommits

long getNumCommits()

Get the number of commits performed by a writer

getNumForks

long getNumForks()

Get the number of forks performed by a writer

isDetached

boolean isDetached()

Is a 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

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