public interface EventBroker
Modifier and Type | Method and 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) |
void clear()
long getCircuitBreakerThreshold()
void setCircuitBreakerThreshold(long circuitBreakerThreshold)
boolean isUniqueGroupNameOn()
void setUniqueGroupNameOn(boolean hashedGroupNameOn)
int getSize()
step.plugins.events.Event put(step.plugins.events.Event event) throws Exception
Exception
step.plugins.events.Event get(String id)
step.plugins.events.Event peek(String id)
step.plugins.events.Event peek(String group, String name)
void clearGroup(String group)
step.plugins.events.Event get(String group, String name)
void setAdvancedStatsOn(boolean statsOn)
boolean getAdvancedStatsOn()
long getCumulatedPuts()
long getCumulatedGets()
long getCumulatedAttemptedGets()
long getCumulatedAttemptedGroupGets()
long getCumulatedPeeks()
int getSizeWaterMark()
step.plugins.events.Event findOldestEvent()
step.plugins.events.Event findYoungestEvent()
int getSizeForGroup(String group)
step.plugins.events.Event findYoungestEventForGroup(String group)
step.plugins.events.Event findOldestEventForGroup(String group)
void clearStats()
Map<String,Set<step.plugins.events.Event>> getGroupBasedEventMap(int skip, int limit)
Copyright © 2020. All rights reserved.