Package step.plugins.event

Interface EventBroker

All Known Implementing Classes:

EventBrokerImpl

public interface EventBroker

Method Summary

Modifier and Type	Method	Description
void	clear()
void	clearGroup(String group)
void	clearStats()
step.plugins.events.Event	findOldestEvent()
step.plugins.events.Event	findOldestEventForGroup(String group)
step.plugins.events.Event	findYoungestEvent()
step.plugins.events.Event	findYoungestEventForGroup(String group)
step.plugins.events.Event	get(String id)
step.plugins.events.Event	get(String group, String name)	Now using a sync-free optimistic version of the group lookup as an alternative to syncGroupOn
boolean	getAdvancedStatsOn()
long	getCircuitBreakerThreshold()
long	getCumulatedAttemptedGets()
long	getCumulatedAttemptedGroupGets()
long	getCumulatedGets()
long	getCumulatedPeeks()
long	getCumulatedPuts()
Set<String>	getDistinctGroupNames()
Map<String,Set<step.plugins.events.Event>>	getFullGroupBasedEventMap()
Map<String,Set<step.plugins.events.Event>>	getGroupBasedEventMap(int skip, int limit)
Set<step.plugins.events.Event>	getGroupEvents(String group)	Group access
Set<step.plugins.events.Event>	getGroupEvents(String group, int skip, int limit)
Map<String,Object>	getGroupStats(String group)
Map<String,step.plugins.events.Event>	getIdBasedEventMap()
Map<String,step.plugins.events.Event>	getIdBasedEventMap(int skip, int limit)
int	getSize()
int	getSizeForGroup(String group)
int	getSizeWaterMark()	Not fully reliable due to the nature of CHM
Map<String,Object>	getStats()
boolean	isUniqueGroupNameOn()
step.plugins.events.Event	peek(String id)
step.plugins.events.Event	peek(String group, String name)	Group primitives, adapted via lookup() to Id primitives
step.plugins.events.Event	put(step.plugins.events.Event event)	Main primitives, based on id
void	setAdvancedStatsOn(boolean statsOn)	Stats
void	setCircuitBreakerThreshold(long circuitBreakerThreshold)
void	setUniqueGroupNameOn(boolean hashedGroupNameOn)

Method Detail

clear

void clear()

getIdBasedEventMap

Map<String,step.plugins.events.Event> getIdBasedEventMap()

getIdBasedEventMap

Map<String,step.plugins.events.Event> getIdBasedEventMap(int skip,
                                                               int limit)

getCircuitBreakerThreshold

long getCircuitBreakerThreshold()

setCircuitBreakerThreshold

void setCircuitBreakerThreshold(long circuitBreakerThreshold)

isUniqueGroupNameOn

boolean isUniqueGroupNameOn()

setUniqueGroupNameOn

void setUniqueGroupNameOn(boolean hashedGroupNameOn)

getSize

int getSize()

put

step.plugins.events.Event put(step.plugins.events.Event event)
                       throws Exception

Main primitives, based on id

Throws:

Exception

get

step.plugins.events.Event get(String id)

peek

step.plugins.events.Event peek(String id)

peek

step.plugins.events.Event peek(String group,
                               String name)

Group primitives, adapted via lookup() to Id primitives

clearGroup

void clearGroup(String group)

get

step.plugins.events.Event get(String group,
                              String name)

Now using a sync-free optimistic version of the group lookup as an alternative to syncGroupOn

setAdvancedStatsOn

void setAdvancedStatsOn(boolean statsOn)

Stats

getAdvancedStatsOn

boolean getAdvancedStatsOn()

getCumulatedPuts

long getCumulatedPuts()

getCumulatedGets

long getCumulatedGets()

getCumulatedAttemptedGets

long getCumulatedAttemptedGets()

getCumulatedAttemptedGroupGets

long getCumulatedAttemptedGroupGets()

getCumulatedPeeks

long getCumulatedPeeks()

getStats

Map<String,Object> getStats()

getGroupStats

Map<String,Object> getGroupStats(String group)

Parameters:

group -

Returns:

getSizeWaterMark

int getSizeWaterMark()

Not fully reliable due to the nature of CHM

findOldestEvent

step.plugins.events.Event findOldestEvent()

findYoungestEvent

step.plugins.events.Event findYoungestEvent()

getSizeForGroup

int getSizeForGroup(String group)

findYoungestEventForGroup

step.plugins.events.Event findYoungestEventForGroup(String group)

findOldestEventForGroup

step.plugins.events.Event findOldestEventForGroup(String group)

clearStats

void clearStats()

getGroupEvents

Set<step.plugins.events.Event> getGroupEvents(String group)

Group access

getGroupEvents

Set<step.plugins.events.Event> getGroupEvents(String group,
                                              int skip,
                                              int limit)

getFullGroupBasedEventMap

Map<String,Set<step.plugins.events.Event>> getFullGroupBasedEventMap()

getGroupBasedEventMap

Map<String,Set<step.plugins.events.Event>> getGroupBasedEventMap(int skip,
                                                                       int limit)

getDistinctGroupNames

Set<String> getDistinctGroupNames()