| Package | Description |
|---|---|
| com.opencloud.rhino.limiting |
| Modifier and Type | Method and Description |
|---|---|
void |
LimiterManagementMBean.connectLimiterEndpoint(String limiterEndpointID,
String limiterName)
Connect a limiter to a limiter endpoint.
|
void |
LimiterManagementMBean.createLimiter(String type,
String name)
Create a limiter using the specified properties.
|
void |
LimiterRampUpMBean.disableRampUp()
Disable incremental growth in the allowed rate of the SystemInput limiter and set the allowed rate to the maximum rate.
|
void |
LimiterManagementMBean.disconnectLimiterEndpoint(String limiterEndpointID)
Disconnect a limiter from a limiter endpoint.
|
void |
LimiterRampUpMBean.enableRampUp(double startRate,
double rateIncrement,
int eventsPerIncrement)
Enable incremental growth in the allowed rate of the SystemInput limiter (Tip: ramp up will only be effective when the "SystemInput" limiter is not bypassed)
|
String[] |
LimiterMBean.getChildLimiters()
Get the names of all limiters for which this limiter is their parent.
|
TabularData |
LimiterMBean.getConfigSummary()
Get the default and per node configuration values stored for this limiter.
|
String[] |
LimiterMBean.getConnectedEndPoints()
Get the IDs of the limiter endpoints connected to this limiter.
|
double |
RateLimiterMBean.getDepthDefault()
Get the default "depth" of this limiter (depth is the number of time units' worth of work capacity can be stored by the rate limiter).
|
double[] |
RateLimiterMBean.getDepthForNode(int[] nodeIDs)
Get the per-node "depth" of this limiter on the specified nodes (depth is the number of time units' worth of work capacity can be stored by the rate limiter).
|
int |
LimiterRampUpMBean.getEventsPerIncrement()
Get the number of events which must be processed before Rhino will add "RateIncrement" to the allowed rate.
|
String |
LimiterManagementMBean.getHierarchySummary()
Get a (multiline) string describing all limiter hierarchies and the connected endpoints.
|
TabularData |
LimiterMBean.getInfoSummary(int[] nodeIDs)
Get a summary of the configuration of this limiter on the specified nodes (as derived from default and per node settings).
|
String[] |
LimiterManagementMBean.getLimiterEndpoints()
Get the set of endpoint IDs that identify all the endpoints in the SLEE.
|
TabularData |
LimiterManagementMBean.getLimiterEndpointsInfo()
Returns a TabularData object containing two String columns:
A "limiterendpoint" column containing the endpoint ID
A "connected-limiter" column containing the name of the connected limiter, or
null if the endpoint is not connected to a limiter
This method operates only on limiter endpoints for the currently active namespace for the client connection. |
String |
LimiterManagementMBean.getLimiterForEndpoint(String limiterEndpointID)
Get the name of the limiter connected to the specified limiter endpoint
This method operates only on limiter endpoints for the currently active namespace for the client connection.
|
ObjectName |
LimiterManagementMBean.getLimiterMBean(String name)
Get the JMX ObjectName for a com.opencloud.rhino.limiting.LimiterMBean object for the specified limiter.
|
ObjectName |
LimiterManagementMBean.getLimiterRampUpMBean()
Get the JMX ObjectName for a
LimiterRampUpMBean object for the SystemInput limiter. |
ObjectName |
LimiterManagementMBean.getLimiterRampUpMBean(String name)
Get the JMX ObjectName for a
LimiterRampUpMBean object for the specified limiter. |
String[] |
LimiterManagementMBean.getLimiters()
Get the set of limiter names that identify all the limiters in the SLEE.
|
double |
RateLimiterMBean.getMaxRateDefault()
Get the default maximum number of units which can be consumed per time unit by this limiter, eg "100" for a rate of 100 per second.
|
double[] |
RateLimiterMBean.getMaxRateForNode(int[] nodeIDs)
Get the per-node maximum number of units which can be consumed per time unit by this limiter on the specified nodes, eg "100" for a rate of 100 per second.
|
double |
QueueSaturationLimiterMBean.getMaxSaturationDefault()
Get the default maximum amount of saturation allowed in the queue, as a percentage, before this limiter will reject work.
|
double[] |
QueueSaturationLimiterMBean.getMaxSaturationForNode(int[] nodeIDs)
Get the per-node maximum amount of saturation allowed in the queue on the specified nodes, as a percentage, before this limiter will reject work.
|
String |
LimiterMBean.getName()
Get the name of this limiter.
|
String |
LimiterMBean.getParent()
Get the name of the parent of this limiter (or null if no parent is set).
|
double |
LimiterRampUpMBean.getRateIncrement()
Get the amount added to the allowed rate if Rhino is successfully processing work.
|
double |
LimiterRampUpMBean.getStartRate()
Get the initial rate allowed by the SystemInput limiter.
|
ObjectName |
LimiterManagementMBean.getSystemInputLimiterMBean()
Get the JMX ObjectName for a
LimiterMBean object for the SystemInput limiter. |
String |
RateLimiterMBean.getTimeUnit()
Get the type of time unit to be used by this limiter when setting the rate, eg the "seconds" in a rate of 100 per second.
|
String |
LimiterMBean.getType()
Get the type of this limiter.
|
boolean |
LimiterMBean.isBypassedDefault()
Get the default "bypassed" property for this limiter (if bypassed is true this limiter will delegate all decisions to its parent or if the is no parent will allow all useUnit/s()).
|
boolean[] |
LimiterMBean.isBypassedForNode(int[] nodeIDs)
Get the per-node "bypassed" property for this limiter on the specified nodes (if bypassed is true this limiter will delegate all decisions to its parent or if the is no parent will allow all useUnit/s()).
|
boolean |
LimiterRampUpMBean.isEnabled()
Test if the ramp up is enabled.
|
void |
LimiterManagementMBean.removeLimiter(String name)
Remove a limiter.
|
void |
LimiterMBean.setBypassedDefault(boolean bypassed)
Set the default "bypassed" property for this limiter (if bypassed is true this limiter will delegate all decisions to its parent or if the is no parent will allow all useUnit/s()).
|
void |
LimiterMBean.setBypassedForNode(boolean[] bypassed,
int[] nodeIDs)
Set the per-node "bypassed" property for this limiter on the specified nodes (if bypassed is true this limiter will delegate all decisions to its parent or if the is no parent will allow all useUnit/s()).
|
void |
LimiterMBean.setBypassedForNode(Boolean[] bypassed,
int[] nodeIDs)
Set the per-node "bypassed" property for this limiter on the specified nodes (if bypassed is true this limiter will delegate all decisions to its parent or if the is no parent will allow all useUnit/s()).
|
void |
RateLimiterMBean.setDepthDefault(double depth)
Set the default "depth" of this limiter (depth is the number of time units' worth of work capacity can be stored by the rate limiter).
|
void |
RateLimiterMBean.setDepthForNode(double[] depth,
int[] nodeIDs)
Set the per-node "depth" of this limiter on the specified nodes (depth is the number of time units' worth of work capacity can be stored by the rate limiter).
|
void |
RateLimiterMBean.setDepthForNode(Double[] depth,
int[] nodeIDs)
Set the per-node "depth" of this limiter on the specified nodes.
|
void |
RateLimiterMBean.setMaxRateDefault(double maxRate)
Set the default maximum number of units which can be consumed per time unit by this limiter, eg "100" for a rate of 100 per second.
|
void |
RateLimiterMBean.setMaxRateForNode(double[] maxRate,
int[] nodeIDs)
Set the per-node maximum number of units which can be consumed per time unit by this limiter on the specified nodes, eg "100" for a rate of 100 per second.
|
void |
RateLimiterMBean.setMaxRateForNode(Double[] maxRate,
int[] nodeIDs)
Set the per-node maximum number of units which can be consumed per time unit by this limiter on the specified nodes, eg "100" for a rate of 100 per second.
|
void |
QueueSaturationLimiterMBean.setMaxSaturationDefault(double maxSaturation)
Set the default maximum amount of saturation allowed in the queue, as a percentage, before this limiter will reject work (the range of valid values is from "0" to "100").
|
void |
QueueSaturationLimiterMBean.setMaxSaturationForNode(double[] maxSaturation,
int[] nodeIDs)
Set the per-node maximum amount of saturation allowed in the queue on the specified nodes, as a percentage, before this limiter will reject work (the range of valid values is from "0" to "100").
|
void |
QueueSaturationLimiterMBean.setMaxSaturationForNode(Double[] maxSaturation,
int[] nodeIDs)
Set the per-node maximum amount of saturation allowed in the queue on the specified nodes, as a percentage, before this limiter will reject work (the range of valid values is from "0" to "100").
|
void |
LimiterMBean.setParent(String parentName)
Set the specified limiter as the parent of this limiter.
|
void |
RateLimiterMBean.setTimeUnit(String timeUnit)
Set the type of time unit to be used by this limiter when setting the rate, eg the "seconds" in a rate of 100 per second.
|
void |
LimiterMBean.useDefaultConfig(int[] nodeIDs)
Removes any node specific configuration settings for the limiter on the given node(s), causing the nodes to use the cluster wide settings.
|