| Modifier and Type | Method and Description |
|---|---|
ExecResponse |
ComputeService.runScriptOnNode(String id,
Statement runScript) |
ExecResponse |
ComputeService.runScriptOnNode(String id,
Statement runScript,
RunScriptOptions options)
Run the script on a specific node
|
ExecResponse |
ComputeService.runScriptOnNode(String id,
String runScript) |
ExecResponse |
ComputeService.runScriptOnNode(String id,
String runScript,
RunScriptOptions options) |
| Modifier and Type | Method and Description |
|---|---|
Map<NodeMetadata,ExecResponse> |
RunScriptOnNodesException.getSuccessfulNodes() |
Map<? extends NodeMetadata,ExecResponse> |
ComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<? super NodeMetadata> filter,
Statement runScript) |
Map<? extends NodeMetadata,ExecResponse> |
ComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<? super NodeMetadata> filter,
Statement runScript,
RunScriptOptions options)
Run the script on all nodes with the specific predicate.
|
Map<? extends NodeMetadata,ExecResponse> |
ComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<? super NodeMetadata> filter,
String runScript) |
Map<? extends NodeMetadata,ExecResponse> |
ComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<? super NodeMetadata> filter,
String runScript,
RunScriptOptions options) |
com.google.common.util.concurrent.ListenableFuture<ExecResponse> |
ComputeService.submitScriptOnNode(String id,
Statement runScript,
RunScriptOptions options) |
com.google.common.util.concurrent.ListenableFuture<ExecResponse> |
ComputeService.submitScriptOnNode(String id,
String runScript,
RunScriptOptions options)
Run the script on a specific node in the background, typically as
nohup |
| Constructor and Description |
|---|
RunScriptOnNodesException(Statement runScript,
RunScriptOptions options,
Map<NodeMetadata,ExecResponse> successfulNodes,
Map<?,Exception> executionExceptions,
Map<? extends NodeMetadata,? extends Throwable> failedNodes) |
| Modifier and Type | Method and Description |
|---|---|
ExecResponse |
RunScriptOnNodeUsingSsh.call() |
ExecResponse |
RunScriptOnNodeAsInitScriptUsingSsh.call() |
ExecResponse |
RunScriptOnNode.call()
Note that
RunScriptOnNode.init() must be called first. |
ExecResponse |
RunScriptOnNodeAsInitScriptUsingSshAndBlockUntilComplete.doCall() |
protected ExecResponse |
RunScriptOnNodeAsInitScriptUsingSsh.doCall() |
ExecResponse |
BlockUntilInitScriptStatusIsZeroThenReturnOutput.get(long timeout,
TimeUnit unit) |
ExecResponse |
SudoAwareInitManager.refreshAndRunAction(String action) |
ExecResponse |
SudoAwareInitManager.runAction(String action) |
protected ExecResponse |
RunScriptOnNodeUsingSsh.runCommand(String command) |
| Modifier and Type | Method and Description |
|---|---|
com.google.common.util.concurrent.ListenableFuture<ExecResponse> |
ScriptStillRunningException.get() |
com.google.common.util.concurrent.ListenableFuture<ExecResponse> |
RunScriptOnNode.Factory.submit(NodeMetadata node,
Statement script,
RunScriptOptions options) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
BlockUntilInitScriptStatusIsZeroThenReturnOutput.set(ExecResponse value) |
| Constructor and Description |
|---|
ScriptStillRunningException(long timeout,
TimeUnit unit,
com.google.common.util.concurrent.ListenableFuture<ExecResponse> delegate) |
ScriptStillRunningException(String message,
com.google.common.util.concurrent.ListenableFuture<ExecResponse> delegate) |
| Modifier and Type | Method and Description |
|---|---|
ExecResponse |
StatementOnNodeCompletion.getResponse() |
| Constructor and Description |
|---|
StatementOnNodeCompletion(Statement statement,
NodeMetadata node,
ExecResponse response) |
| Modifier and Type | Method and Description |
|---|---|
ExecResponse |
BaseComputeService.runScriptOnNode(String id,
Statement runScript) |
ExecResponse |
BaseComputeService.runScriptOnNode(String id,
Statement runScript,
RunScriptOptions options)
Run the script on a specific node
|
ExecResponse |
BaseComputeService.runScriptOnNode(String id,
String runScript) |
ExecResponse |
BaseComputeService.runScriptOnNode(String id,
String runScript,
RunScriptOptions options) |
| Modifier and Type | Method and Description |
|---|---|
Map<NodeMetadata,ExecResponse> |
BaseComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<? super NodeMetadata> filter,
Statement runScript) |
Map<NodeMetadata,ExecResponse> |
BaseComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<? super NodeMetadata> filter,
Statement runScript,
RunScriptOptions options)
Run the script on all nodes with the specific predicate.
|
Map<NodeMetadata,ExecResponse> |
BaseComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<? super NodeMetadata> filter,
String runScript) |
Map<? extends NodeMetadata,ExecResponse> |
BaseComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<? super NodeMetadata> filter,
String runScript,
RunScriptOptions options) |
com.google.common.util.concurrent.ListenableFuture<ExecResponse> |
BaseComputeService.submitScriptOnNode(String id,
Statement runScript,
RunScriptOptions options) |
com.google.common.util.concurrent.ListenableFuture<ExecResponse> |
BaseComputeService.submitScriptOnNode(String id,
String runScript,
RunScriptOptions options)
Run the script on a specific node in the background, typically as
nohup |
| Modifier and Type | Method and Description |
|---|---|
ExecResponse |
RunScriptOnNodeAndAddToGoodMapOrPutExceptionIntoBadMap.call() |
| Constructor and Description |
|---|
RunScriptOnNodeAndAddToGoodMapOrPutExceptionIntoBadMap(RunScriptOnNode runScriptOnNode,
Map<NodeMetadata,ExecResponse> goodNodes,
Map<NodeMetadata,Exception> badNodes) |
| Modifier and Type | Method and Description |
|---|---|
ExecResponse |
SshClient.exec(String command)
Execute a process and block until it is complete
|
| Modifier and Type | Method and Description |
|---|---|
ExecResponse |
JschSshClient.exec(String command) |
| Modifier and Type | Method and Description |
|---|---|
ExecResponse |
SshjSshClient.exec(String command) |
Copyright © 2009-2016 The Apache Software Foundation. All Rights Reserved.