public interface BlobberWatchDog
BlobberPlugin#createMonitorDAOs()
and can also be used by the ACS layers of the blobber. That's why we define it here.
It provides JMX data about the queues and other information.
| Modifier and Type | Method and Description |
|---|---|
void |
addQueueToWatch(java.util.Collection<ComponentData> queue,
java.lang.String queueName,
int maxQueueSize)
Adds a queue that should be watched by this watch dog.
|
long |
getQueueSize(java.lang.String queueName)
Returns the size of the queue with the given name.
|
void |
removeQueueToWatch(java.lang.String queueName)
Removes a queue that should no longer be watched.
|
void addQueueToWatch(java.util.Collection<ComponentData> queue, java.lang.String queueName, int maxQueueSize)
queue - The collection / queue to be monitored.queueName - A name for the queue, used to select a queue and for reporting.maxQueueSize - The maximum possible or allowed queue size, used to evaluate how full the queue is.void removeQueueToWatch(java.lang.String queueName)
queueName - long getQueueSize(java.lang.String queueName)
queueName - Name of the queue.