Modifier and Type | Method and Description |
---|---|
boolean |
XmlRpcBatchMgr.executeRemotely(JobSpec jobSpec,
ResourceNode resNode) |
boolean |
Batchmgr.executeRemotely(JobSpec job,
ResourceNode resNode)
Executes a job remotely on the specified
remoteHost . |
boolean |
XmlRpcBatchMgr.killJob(String jobId,
ResourceNode node) |
boolean |
Batchmgr.killJob(String jobId,
ResourceNode node) |
protected void |
XmlRpcBatchMgr.notifyMonitor(ResourceNode node,
JobSpec jobSpec) |
Constructor and Description |
---|
XmlRpcBatchMgrProxy(JobSpec jobSpec,
ResourceNode remoteHost,
XmlRpcBatchMgr par) |
Modifier and Type | Method and Description |
---|---|
ResourceNode |
Monitor.getNodeById(String nodeId)
Gets the
ResourceNode with the given nodeId . |
ResourceNode |
AssignmentMonitor.getNodeById(String nodeId) |
ResourceNode |
Monitor.getNodeByURL(URL ipAddr)
Returns the
ResourceNode with the given ipAddr . |
ResourceNode |
AssignmentMonitor.getNodeByURL(URL ipAddr) |
Modifier and Type | Method and Description |
---|---|
List<ResourceNode> |
AssignmentMonitor.getNodes() |
Modifier and Type | Method and Description |
---|---|
void |
Monitor.addNode(ResourceNode node)
Adds a new
ResourceNode for this Monitor to manage (if
node already exist, then should perform update) |
void |
AssignmentMonitor.addNode(ResourceNode node) |
boolean |
Monitor.assignLoad(ResourceNode node,
int loadValue) |
boolean |
AssignmentMonitor.assignLoad(ResourceNode node,
int loadValue) |
int |
Monitor.getLoad(ResourceNode node)
Gets the load on a resource node available to the resource manager.
|
int |
AssignmentMonitor.getLoad(ResourceNode node) |
boolean |
Monitor.reduceLoad(ResourceNode node,
int loadValue)
Reduces the load on a particular
ResourceNode by the given
loadValue . |
boolean |
AssignmentMonitor.reduceLoad(ResourceNode node,
int loadValue) |
Constructor and Description |
---|
AssignmentMonitor(List<ResourceNode> nodes) |
Modifier and Type | Method and Description |
---|---|
ResourceNode |
GangliaResourceMonitor.getNodeById(String nodeId) |
ResourceNode |
GangliaResourceMonitor.getNodeByURL(URL ipAddr) |
Modifier and Type | Method and Description |
---|---|
void |
GangliaResourceMonitor.addNode(ResourceNode node) |
boolean |
GangliaResourceMonitor.assignLoad(ResourceNode node,
int loadValue) |
int |
GangliaResourceMonitor.getLoad(ResourceNode node) |
boolean |
GangliaResourceMonitor.reduceLoad(ResourceNode node,
int loadValue) |
Modifier and Type | Method and Description |
---|---|
ResourceNode |
QueueMuxMonitor.getNodeById(String nodeId) |
ResourceNode |
QueueMuxMonitor.getNodeByURL(URL ipAddr) |
ResourceNode |
QueueMuxScheduler.nodeAvailable(JobSpec spec) |
Modifier and Type | Method and Description |
---|---|
List<ResourceNode> |
QueueMuxMonitor.getNodes() |
Modifier and Type | Method and Description |
---|---|
void |
QueueMuxMonitor.addNode(ResourceNode node) |
boolean |
QueueMuxMonitor.assignLoad(ResourceNode node,
int loadValue) |
boolean |
QueueMuxBatchManager.executeRemotely(JobSpec job,
ResourceNode resNode) |
int |
QueueMuxMonitor.getLoad(ResourceNode node) |
boolean |
QueueMuxBatchManager.killJob(String jobId,
ResourceNode node) |
boolean |
QueueMuxMonitor.reduceLoad(ResourceNode node,
int loadValue) |
Modifier and Type | Method and Description |
---|---|
List<ResourceNode> |
XmlNodeRepository.loadNodes() |
List<ResourceNode> |
NodeRepository.loadNodes() |
Modifier and Type | Method and Description |
---|---|
ResourceNode |
Scheduler.nodeAvailable(JobSpec spec)
Returns the ResourceNode that is considered to be
most availablewithin our underlying set of resources for the given JobSpec. |
ResourceNode |
LRUScheduler.nodeAvailable(JobSpec spec) |
Modifier and Type | Method and Description |
---|---|
ResourceNode |
XmlRpcResourceManagerClient.getNodeById(String nodeId) |
Modifier and Type | Method and Description |
---|---|
void |
XmlRpcResourceManagerClient.addNode(ResourceNode node)
Adds a node
|
Modifier and Type | Method and Description |
---|---|
static ResourceNode |
XmlStructFactory.getNodes(Node node) |
static ResourceNode |
XmlRpcStructFactory.getResourceNodeFromXmlRpc(Map resNodeHash) |
Modifier and Type | Method and Description |
---|---|
int |
ResourceNodeComparator.compare(ResourceNode rn1,
ResourceNode rn2) |
static Hashtable<String,String> |
XmlRpcStructFactory.getXmlRpcResourceNode(ResourceNode node) |
Modifier and Type | Method and Description |
---|---|
static Vector |
XmlRpcStructFactory.getXmlRpcResourceNodeList(List<ResourceNode> resNodes) |
Copyright © 1999–2017 Apache OODT. All rights reserved.