public class MockXmlRpcResourceManagerClient extends XmlRpcResourceManagerClient
XmlRpcResourceManagerClient
.Modifier and Type | Class and Description |
---|---|
class |
MockXmlRpcResourceManagerClient.MethodCallDetails |
INT, INT1, VAL, VAL1
Constructor and Description |
---|
MockXmlRpcResourceManagerClient() |
Modifier and Type | Method and Description |
---|---|
void |
addNode(ResourceNode node) |
void |
addNodeToQueue(String nodeId,
String queueName) |
void |
addQueue(String queueName) |
String |
getExecutionNode(String jobId) |
Job |
getJobInfo(String jobId) |
MockXmlRpcResourceManagerClient.MethodCallDetails |
getLastMethodCallDetails() |
ResourceNode |
getNodeById(String nodeId) |
String |
getNodeLoad(String nodeId) |
List<ResourceNode> |
getNodes() |
List<String> |
getNodesInQueue(String queueName) |
List<String> |
getQueues() |
List<String> |
getQueuesWithNode(String nodeId) |
boolean |
killJob(String jobId) |
void |
removeNode(String nodeId) |
void |
removeNodeFromQueue(String nodeId,
String queueName) |
void |
removeQueue(String queueName) |
void |
setNodeCapacity(String nodeId,
int capacity) |
String |
submitJob(Job exec,
JobInput in) |
boolean |
submitJob(Job exec,
JobInput in,
URL url) |
getExecReport, getJobQueueCapacity, getJobQueueSize, getNodeReport, getQueuedJobs, getReadableJobStatus, getResMgrUrl, isAlive, isJobComplete, main, setResMgrUrl
public MockXmlRpcResourceManagerClient() throws MalformedURLException
MalformedURLException
public MockXmlRpcResourceManagerClient.MethodCallDetails getLastMethodCallDetails()
public void addNode(ResourceNode node) throws MonitorException
addNode
in class XmlRpcResourceManagerClient
MonitorException
public void addNodeToQueue(String nodeId, String queueName) throws QueueManagerException
addNodeToQueue
in class XmlRpcResourceManagerClient
QueueManagerException
public void addQueue(String queueName) throws QueueManagerException
addQueue
in class XmlRpcResourceManagerClient
QueueManagerException
public String getExecutionNode(String jobId)
getExecutionNode
in class XmlRpcResourceManagerClient
public Job getJobInfo(String jobId) throws JobRepositoryException
getJobInfo
in class XmlRpcResourceManagerClient
JobRepositoryException
public ResourceNode getNodeById(String nodeId) throws MonitorException
getNodeById
in class XmlRpcResourceManagerClient
MonitorException
public String getNodeLoad(String nodeId) throws MonitorException
getNodeLoad
in class XmlRpcResourceManagerClient
MonitorException
public List<ResourceNode> getNodes() throws MonitorException
getNodes
in class XmlRpcResourceManagerClient
MonitorException
public List<String> getNodesInQueue(String queueName) throws QueueManagerException
getNodesInQueue
in class XmlRpcResourceManagerClient
QueueManagerException
public List<String> getQueues() throws QueueManagerException
getQueues
in class XmlRpcResourceManagerClient
QueueManagerException
public List<String> getQueuesWithNode(String nodeId) throws QueueManagerException
getQueuesWithNode
in class XmlRpcResourceManagerClient
QueueManagerException
public boolean killJob(String jobId)
killJob
in class XmlRpcResourceManagerClient
public void removeNode(String nodeId) throws MonitorException
removeNode
in class XmlRpcResourceManagerClient
MonitorException
public void removeNodeFromQueue(String nodeId, String queueName) throws QueueManagerException
removeNodeFromQueue
in class XmlRpcResourceManagerClient
QueueManagerException
public void removeQueue(String queueName) throws QueueManagerException
removeQueue
in class XmlRpcResourceManagerClient
QueueManagerException
public void setNodeCapacity(String nodeId, int capacity) throws MonitorException
setNodeCapacity
in class XmlRpcResourceManagerClient
MonitorException
public String submitJob(Job exec, JobInput in) throws JobExecutionException
submitJob
in class XmlRpcResourceManagerClient
JobExecutionException
public boolean submitJob(Job exec, JobInput in, URL url) throws JobExecutionException
submitJob
in class XmlRpcResourceManagerClient
JobExecutionException
Copyright © 1999–2017 Apache OODT. All rights reserved.