public class TaskMonitor
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_EXPIRATION_TIME |
static int |
DEFAULT_MAX_TASKS |
static long |
DEFAULT_MONITOR_INTERVAL |
static long |
DEFAULT_RPC_WARN_TIME |
static java.lang.String |
EXPIRATION_TIME_KEY |
static java.lang.String |
MAX_TASKS_KEY |
static java.lang.String |
MONITOR_INTERVAL_KEY |
static java.lang.String |
RPC_WARN_TIME_KEY |
Modifier and Type | Method and Description |
---|---|
MonitoredRPCHandler |
createRPCStatus(java.lang.String description) |
MonitoredTask |
createStatus(java.lang.String description) |
void |
dumpAsText(java.io.PrintWriter out) |
static TaskMonitor |
get()
Get singleton instance.
|
java.util.List<MonitoredTask> |
getTasks()
Produces a list containing copies of the current state of all non-expired
MonitoredTasks handled by this TaskMonitor.
|
java.util.List<MonitoredTask> |
getTasks(java.lang.String filter)
Produces a list containing copies of the current state of all non-expired
MonitoredTasks handled by this TaskMonitor.
|
void |
shutdown() |
public static final java.lang.String MAX_TASKS_KEY
public static final int DEFAULT_MAX_TASKS
public static final java.lang.String RPC_WARN_TIME_KEY
public static final long DEFAULT_RPC_WARN_TIME
public static final java.lang.String EXPIRATION_TIME_KEY
public static final long DEFAULT_EXPIRATION_TIME
public static final java.lang.String MONITOR_INTERVAL_KEY
public static final long DEFAULT_MONITOR_INTERVAL
public static TaskMonitor get()
public MonitoredTask createStatus(java.lang.String description)
public MonitoredRPCHandler createRPCStatus(java.lang.String description)
public java.util.List<MonitoredTask> getTasks()
public java.util.List<MonitoredTask> getTasks(java.lang.String filter)
filter
- type of wanted taskspublic void dumpAsText(java.io.PrintWriter out)
public void shutdown()