com.neeve.event
Interface IEventMultiplexerStats

All Superinterfaces:

IStats

public interface IEventMultiplexerStats
extends IStats

Defines an event multiplexer's statistics interface.

Nested Class Summary

static interface

IEventMultiplexerStats.IFeederQueueStats

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

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

Method Summary

int	getCapacity() Gets the multiplexer capacity.
int	getCapacityRemaining() Gets the multiplexer's remaining capacity.
String	getClaimStrategy() Gets the strategy used by enqueuing threads to claim a slot.
void	getFeederQueueStats(List<IEventMultiplexerStats.IFeederQueueStats> feederQueueStatsCollector) Fetched feeder queue stats.
int	getLastDecongested()
int	getMaxConcurrency()
int	getNumFeederQueues()
IStats.Latencies	getOfferToPollLatencies() Get the offer to poll latencies
int	getScheduleQueueSize()
String	getWaitStrategy() Gets the strategy used by dispatching thread(s) to take elements for dispatch.

Methods inherited from interface com.neeve.stats.IStats

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

Method Detail

getOfferToPollLatencies

IStats.Latencies getOfferToPollLatencies()

Get the offer to poll latencies

getCapacity

int getCapacity()

Gets the multiplexer capacity.

The capacity represents the number of events that can be pending dispatch before a newly offered event would block.

Returns:

The capacity of the multiplexer.

getCapacityRemaining

int getCapacityRemaining()

Gets the multiplexer's remaining capacity.

The remaining capacity indicates how many slots are left in the multiplexer before newly offered events would block.

Returns:

The remaining capacity of the multiplexer.

getClaimStrategy

String getClaimStrategy()

Gets the strategy used by enqueuing threads to claim a slot.

Returns:

The multiplexer's claim strategy.

getWaitStrategy

String getWaitStrategy()

Gets the strategy used by dispatching thread(s) to take elements for dispatch.

Returns:

The multiplexer's wait strategy.

getNumFeederQueues

int getNumFeederQueues()

Returns:

The number of feeder queues in use by the Multiplexer.

getMaxConcurrency

int getMaxConcurrency()

Returns:

The maximum number of feeder queues allowed by the Multiplexer.

getLastDecongested

int getLastDecongested()

Returns:

The maximum number of feeder queues allowed by the Multiplexer.

getScheduleQueueSize

int getScheduleQueueSize()

Returns:

The number of currently scheduled events to dispatch.

getFeederQueueStats

void getFeederQueueStats(List<IEventMultiplexerStats.IFeederQueueStats> feederQueueStatsCollector)

Fetched feeder queue stats.

A new IEventMultiplexerStats.IFeederQueueStats will be allocated for each null value in the provided array, otherwise if the values in the array are non-null then they will be used populate the feeder stats. If the provided array is smaller in size than the number of feeder queues for the multiplexer then not all feeder queue stats will be reported. If the provided array is larger than the number of feeder queue stats then the remaining entries will have their values cleared. A null value for getOwner indicates that the result should be ignored.

Parameters:

feederQueueStatsCollector - An array of IEventMultiplexerStats.IFeederQueueStats to populate