Modifier and Type | Method and Description |
---|---|
protected Set<? extends NodeMetadata> |
AWSEC2ComputeService.addUserMetadataFromTemplateOptionsToNodes(Template template,
String group,
Set<? extends NodeMetadata> nodes) |
Set<? extends NodeMetadata> |
AWSEC2ComputeService.createNodesInGroup(String group,
int count,
Template template) |
Modifier and Type | Method and Description |
---|---|
protected void |
AWSEC2ComputeService.addTagsToNodesFromUserMetadataInTemplate(Set<? extends NodeMetadata> nodes,
String group,
Template template) |
protected Set<? extends NodeMetadata> |
AWSEC2ComputeService.addUserMetadataFromTemplateOptionsToNodes(Template template,
String group,
Set<? extends NodeMetadata> nodes) |
Constructor and Description |
---|
AWSEC2ComputeService(ComputeServiceContext context,
Map<String,Credentials> credentialStore,
com.google.common.base.Supplier<Set<? extends Image>> images,
com.google.common.base.Supplier<Set<? extends Hardware>> sizes,
com.google.common.base.Supplier<Set<? extends Location>> locations,
ListNodesStrategy listNodesStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
Provider<TemplateBuilder> templateBuilderProvider,
Provider<TemplateOptions> templateOptionsProvider,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeTerminated,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeSuspended,
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory initScriptRunnerFactory,
RunScriptOnNode.Factory runScriptOnNodeFactory,
InitAdminAccess initAdminAccess,
PersistNodeCredentials persistNodeCredentials,
ComputeServiceConstants.Timeouts timeouts,
ExecutorService executor,
AWSEC2Client ec2Client,
ConcurrentMap<RegionAndName,KeyPair> credentialsMap,
com.google.common.cache.LoadingCache<RegionAndName,String> securityGroupMap,
com.google.common.cache.LoadingCache<RegionAndName,String> placementGroupMap,
com.google.common.base.Predicate<PlacementGroup> placementGroupDeleted,
boolean generateInstanceNames,
AWSEC2AsyncClient aclient) |
AWSEC2ComputeService(ComputeServiceContext context,
Map<String,Credentials> credentialStore,
com.google.common.base.Supplier<Set<? extends Image>> images,
com.google.common.base.Supplier<Set<? extends Hardware>> sizes,
com.google.common.base.Supplier<Set<? extends Location>> locations,
ListNodesStrategy listNodesStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
Provider<TemplateBuilder> templateBuilderProvider,
Provider<TemplateOptions> templateOptionsProvider,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeTerminated,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeSuspended,
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory initScriptRunnerFactory,
RunScriptOnNode.Factory runScriptOnNodeFactory,
InitAdminAccess initAdminAccess,
PersistNodeCredentials persistNodeCredentials,
ComputeServiceConstants.Timeouts timeouts,
ExecutorService executor,
AWSEC2Client ec2Client,
ConcurrentMap<RegionAndName,KeyPair> credentialsMap,
com.google.common.cache.LoadingCache<RegionAndName,String> securityGroupMap,
com.google.common.cache.LoadingCache<RegionAndName,String> placementGroupMap,
com.google.common.base.Predicate<PlacementGroup> placementGroupDeleted,
boolean generateInstanceNames,
AWSEC2AsyncClient aclient) |
AWSEC2ComputeService(ComputeServiceContext context,
Map<String,Credentials> credentialStore,
com.google.common.base.Supplier<Set<? extends Image>> images,
com.google.common.base.Supplier<Set<? extends Hardware>> sizes,
com.google.common.base.Supplier<Set<? extends Location>> locations,
ListNodesStrategy listNodesStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
Provider<TemplateBuilder> templateBuilderProvider,
Provider<TemplateOptions> templateOptionsProvider,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeTerminated,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeSuspended,
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory initScriptRunnerFactory,
RunScriptOnNode.Factory runScriptOnNodeFactory,
InitAdminAccess initAdminAccess,
PersistNodeCredentials persistNodeCredentials,
ComputeServiceConstants.Timeouts timeouts,
ExecutorService executor,
AWSEC2Client ec2Client,
ConcurrentMap<RegionAndName,KeyPair> credentialsMap,
com.google.common.cache.LoadingCache<RegionAndName,String> securityGroupMap,
com.google.common.cache.LoadingCache<RegionAndName,String> placementGroupMap,
com.google.common.base.Predicate<PlacementGroup> placementGroupDeleted,
boolean generateInstanceNames,
AWSEC2AsyncClient aclient) |
Constructor and Description |
---|
AWSEC2CreateNodesInGroupThenAddToSet(AWSEC2Client client,
com.google.common.cache.LoadingCache<RegionAndName,String> elasticIpCache,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
AWSEC2AsyncClient aclient,
boolean generateInstanceNames,
Provider<TemplateBuilder> templateBuilderProvider,
CreateKeyPairPlacementAndSecurityGroupsAsNeededAndReturnRunOptions createKeyPairAndSecurityGroupsAsNeededAndReturncustomize,
AWSEC2InstancePresent instancePresent,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata,
com.google.common.cache.LoadingCache<RunningInstance,Credentials> instanceToCredentials,
Map<String,Credentials> credentialStore,
ComputeUtils utils,
SpotInstanceRequestToAWSRunningInstance spotConverter) |
AWSEC2CreateNodesInGroupThenAddToSet(AWSEC2Client client,
com.google.common.cache.LoadingCache<RegionAndName,String> elasticIpCache,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
AWSEC2AsyncClient aclient,
boolean generateInstanceNames,
Provider<TemplateBuilder> templateBuilderProvider,
CreateKeyPairPlacementAndSecurityGroupsAsNeededAndReturnRunOptions createKeyPairAndSecurityGroupsAsNeededAndReturncustomize,
AWSEC2InstancePresent instancePresent,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata,
com.google.common.cache.LoadingCache<RunningInstance,Credentials> instanceToCredentials,
Map<String,Credentials> credentialStore,
ComputeUtils utils,
SpotInstanceRequestToAWSRunningInstance spotConverter) |
AWSEC2GetNodeMetadataStrategy(AWSEC2Client client,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata,
SpotInstanceRequestToAWSRunningInstance spotConverter) |
AWSEC2ListNodesStrategy(AWSEC2AsyncClient client,
com.google.common.base.Supplier<Set<String>> regions,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata,
ExecutorService executor,
SpotInstanceRequestToAWSRunningInstance spotConverter) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
NodeToNodeMetadata.apply(Node from) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
BYONComputeServiceAdapter.getNode(String id) |
Modifier and Type | Method and Description |
---|---|
Iterable<NodeMetadata> |
BYONComputeServiceAdapter.listNodes() |
Modifier and Type | Method and Description |
---|---|
LoadBalancerMetadata |
CloudLoadBalancersLoadBalanceNodesStrategy.createLoadBalancerInLocation(Location location,
String name,
String protocol,
int loadBalancerPort,
int instancePort,
Iterable<? extends NodeMetadata> nodes) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
ServerToNodeMetadata.apply(Server from) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
ServerInfoToNodeMetadata.apply(ServerInfo from) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
VirtualMachineToNodeMetadata.apply(VirtualMachine from) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
JCloudsNativeComputeServiceAdapter.getNode(String id) |
NodeMetadata |
ComputeService.getNodeMetadata(String id)
Find a node by its id.
|
Modifier and Type | Method and Description |
---|---|
Set<? extends NodeMetadata> |
ComputeService.createNodesInGroup(String group,
int count)
Like
ComputeService.createNodesInGroup(String,int,TemplateOptions) , except that the
options are default, as specified in ComputeService.templateOptions() . |
Set<? extends NodeMetadata> |
ComputeService.createNodesInGroup(String group,
int count,
Template template)
The compute api treats nodes as a group based on the name you specify.
|
Set<? extends NodeMetadata> |
ComputeService.createNodesInGroup(String group,
int count,
TemplateOptions templateOptions)
Like
ComputeService.createNodesInGroup(String,int,Template) , except that the template
is default, equivalent to templateBuilder().any().options(templateOptions) . |
Set<? extends NodeMetadata> |
ComputeService.destroyNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
Map<? extends NodeMetadata,? extends Throwable> |
RunScriptOnNodesException.getNodeErrors() |
Map<? extends NodeMetadata,? extends Throwable> |
RunNodesException.getNodeErrors() |
Map<NodeMetadata,ExecResponse> |
RunScriptOnNodesException.getSuccessfulNodes() |
Set<? extends NodeMetadata> |
RunNodesException.getSuccessfulNodes() |
Iterable<NodeMetadata> |
JCloudsNativeComputeServiceAdapter.listNodes() |
Set<? extends NodeMetadata> |
ComputeService.listNodesDetailsMatching(com.google.common.base.Predicate<ComputeMetadata> filter)
get all nodes including details such as image and ip addresses even if it incurs extra
requests to the service.
|
Map<? extends NodeMetadata,ExecResponse> |
ComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter,
Statement runScript) |
Map<? extends NodeMetadata,ExecResponse> |
ComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<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<NodeMetadata> filter,
String runScript) |
Map<? extends NodeMetadata,ExecResponse> |
ComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter,
String runScript,
RunScriptOptions options) |
com.google.common.base.Function<NodeMetadata,SshClient> |
Utils.sshForNode() |
Modifier and Type | Method and Description |
---|---|
Set<? extends NodeMetadata> |
ComputeService.destroyNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
void |
ComputeService.rebootNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
void |
ComputeService.resumeNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
Map<? extends NodeMetadata,ExecResponse> |
ComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter,
Statement runScript) |
Map<? extends NodeMetadata,ExecResponse> |
ComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<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<NodeMetadata> filter,
String runScript) |
Map<? extends NodeMetadata,ExecResponse> |
ComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter,
String runScript,
RunScriptOptions options) |
void |
ComputeService.suspendNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
Constructor and Description |
---|
JCloudsNativeComputeServiceAdapter.NodeWithInitialCredentials(NodeMetadata node) |
Constructor and Description |
---|
RunNodesException(String group,
int count,
Template template,
Set<? extends NodeMetadata> successfulNodes,
Map<?,Exception> executionExceptions,
Map<? extends NodeMetadata,? extends Throwable> failedNodes) |
RunNodesException(String group,
int count,
Template template,
Set<? extends NodeMetadata> successfulNodes,
Map<?,Exception> executionExceptions,
Map<? extends NodeMetadata,? extends Throwable> failedNodes) |
RunScriptOnNodesException(Statement runScript,
RunScriptOptions options,
Map<NodeMetadata,ExecResponse> successfulNodes,
Map<?,Exception> executionExceptions,
Map<? extends NodeMetadata,? extends Throwable> failedNodes) |
RunScriptOnNodesException(Statement runScript,
RunScriptOptions options,
Map<NodeMetadata,ExecResponse> successfulNodes,
Map<?,Exception> executionExceptions,
Map<? extends NodeMetadata,? extends Throwable> failedNodes) |
Modifier and Type | Field and Description |
---|---|
protected NodeMetadata |
SudoAwareInitManager.node |
protected NodeMetadata |
RunScriptOnNodeUsingSsh.node |
Modifier and Type | Field and Description |
---|---|
protected com.google.common.base.Function<NodeMetadata,SshClient> |
SudoAwareInitManager.sshFactory |
protected com.google.common.base.Function<NodeMetadata,SshClient> |
RunScriptOnNodeUsingSsh.sshFactory |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
SudoAwareInitManager.getNode() |
NodeMetadata |
RunScriptOnNodeUsingSsh.getNode() |
NodeMetadata |
RunScriptOnNode.getNode()
the node this command is being executed on.
|
Modifier and Type | Method and Description |
---|---|
RunScriptOnNode |
RunScriptOnNode.Factory.create(NodeMetadata node,
Statement script,
RunScriptOptions options) |
com.google.common.util.concurrent.ListenableFuture<ExecResponse> |
RunScriptOnNode.Factory.submit(NodeMetadata node,
Statement script,
RunScriptOptions options) |
Constructor and Description |
---|
RunScriptOnNodeAsInitScriptUsingSsh(com.google.common.base.Function<NodeMetadata,SshClient> sshFactory,
com.google.common.eventbus.EventBus eventBus,
InitScriptConfigurationForTasks initScriptConfiguration,
NodeMetadata node,
Statement script,
RunScriptOptions options) |
RunScriptOnNodeAsInitScriptUsingSshAndBlockUntilComplete(BlockUntilInitScriptStatusIsZeroThenReturnOutput.Factory statusFactory,
ComputeServiceConstants.Timeouts timeouts,
com.google.common.base.Function<NodeMetadata,SshClient> sshFactory,
com.google.common.eventbus.EventBus eventBus,
InitScriptConfigurationForTasks initScriptConfiguration,
NodeMetadata node,
Statement script,
RunScriptOptions options) |
RunScriptOnNodeUsingSsh(com.google.common.base.Function<NodeMetadata,SshClient> sshFactory,
com.google.common.eventbus.EventBus eventBus,
NodeMetadata node,
Statement statement,
RunScriptOptions options) |
SudoAwareInitManager(com.google.common.base.Function<NodeMetadata,SshClient> sshFactory,
boolean runAsRoot,
NodeMetadata node,
InitScriptConfigurationForTasks initScriptConfiguration,
InitScript init) |
Constructor and Description |
---|
RunScriptOnNodeAsInitScriptUsingSsh(com.google.common.base.Function<NodeMetadata,SshClient> sshFactory,
com.google.common.eventbus.EventBus eventBus,
InitScriptConfigurationForTasks initScriptConfiguration,
NodeMetadata node,
Statement script,
RunScriptOptions options) |
RunScriptOnNodeAsInitScriptUsingSshAndBlockUntilComplete(BlockUntilInitScriptStatusIsZeroThenReturnOutput.Factory statusFactory,
ComputeServiceConstants.Timeouts timeouts,
com.google.common.base.Function<NodeMetadata,SshClient> sshFactory,
com.google.common.eventbus.EventBus eventBus,
InitScriptConfigurationForTasks initScriptConfiguration,
NodeMetadata node,
Statement script,
RunScriptOptions options) |
RunScriptOnNodeUsingSsh(com.google.common.base.Function<NodeMetadata,SshClient> sshFactory,
com.google.common.eventbus.EventBus eventBus,
NodeMetadata node,
Statement statement,
RunScriptOptions options) |
SudoAwareInitManager(com.google.common.base.Function<NodeMetadata,SshClient> sshFactory,
boolean runAsRoot,
NodeMetadata node,
InitScriptConfigurationForTasks initScriptConfiguration,
InitScript init) |
Modifier and Type | Field and Description |
---|---|
protected Class<? extends ComputeServiceAdapter<NodeMetadata,Hardware,Image,Location>> |
JCloudsNativeComputeServiceAdapterContextModule.adapter |
Modifier and Type | Method and Description |
---|---|
protected com.google.common.base.Predicate<AtomicReference<NodeMetadata>> |
ComputeServiceTimeoutsModule.nodeRunning(AtomicNodeRunning stateRunning,
ComputeServiceConstants.Timeouts timeouts) |
protected com.google.common.base.Predicate<NodeMetadata> |
ComputeServiceTimeoutsModule.nodeRunning(NodeRunning stateRunning,
ComputeServiceConstants.Timeouts timeouts)
Deprecated.
|
protected com.google.common.base.Predicate<AtomicReference<NodeMetadata>> |
ComputeServiceTimeoutsModule.serverSuspended(AtomicNodeSuspended stateSuspended,
ComputeServiceConstants.Timeouts timeouts) |
protected com.google.common.base.Predicate<NodeMetadata> |
ComputeServiceTimeoutsModule.serverSuspended(NodeSuspended stateSuspended,
ComputeServiceConstants.Timeouts timeouts)
Deprecated.
|
protected com.google.common.base.Predicate<NodeMetadata> |
ComputeServiceTimeoutsModule.serverTerminated(NodeTerminated stateTerminated,
ComputeServiceConstants.Timeouts timeouts)
Deprecated.
|
protected com.google.common.base.Predicate<AtomicReference<NodeMetadata>> |
ComputeServiceTimeoutsModule.serverTerminated(TrueIfNullOrTerminatedRefreshAndDoubleCheckOnFalse stateTerminated,
ComputeServiceConstants.Timeouts timeouts) |
Constructor and Description |
---|
JCloudsNativeComputeServiceAdapterContextModule(Class<S> syncClientType,
Class<A> asyncClientType,
Class<? extends ComputeServiceAdapter<NodeMetadata,Hardware,Image,Location>> adapter) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
NodeMetadataBuilder.build() |
Modifier and Type | Method and Description |
---|---|
static NodeMetadataBuilder |
NodeMetadataBuilder.fromNodeMetadata(NodeMetadata node) |
Modifier and Type | Class and Description |
---|---|
class |
NodeMetadataImpl |
Modifier and Type | Field and Description |
---|---|
protected NodeMetadata |
StatementOnNode.node |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
StatementOnNode.getNode() |
Constructor and Description |
---|
InitScriptOnNodeSubmission(InitScript statement,
NodeMetadata node) |
StatementOnNode(Statement statement,
NodeMetadata node) |
StatementOnNodeCompletion(Statement statement,
NodeMetadata node,
ExecResponse response) |
StatementOnNodeFailure(Statement statement,
NodeMetadata node,
Throwable cause) |
StatementOnNodeSubmission(Statement statement,
NodeMetadata node) |
Modifier and Type | Method and Description |
---|---|
SshClient |
CreateSshClientOncePortIsListeningOnNode.apply(NodeMetadata node) |
Modifier and Type | Method and Description |
---|---|
protected NodeMetadata |
BaseComputeService.doDestroyNode(String id) |
NodeMetadata |
BaseComputeService.getNodeMetadata(String id)
Find a node by its id.
|
protected NodeMetadata |
BaseComputeService.updateNodeWithCredentialsIfPresent(NodeMetadata node,
RunScriptOptions options) |
Modifier and Type | Method and Description |
---|---|
com.google.common.base.Function<NodeMetadata,NodeMetadata> |
PersistNodeCredentials.always(Statement statement) |
com.google.common.base.Function<NodeMetadata,NodeMetadata> |
PersistNodeCredentials.always(Statement statement) |
Set<? extends NodeMetadata> |
BaseComputeService.createNodesInGroup(String group,
int count) |
Set<? extends NodeMetadata> |
BaseComputeService.createNodesInGroup(String group,
int count,
Template template) |
Set<? extends NodeMetadata> |
BaseComputeService.createNodesInGroup(String group,
int count,
TemplateOptions templateOptions) |
Set<? extends NodeMetadata> |
BaseComputeService.destroyNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
com.google.common.base.Function<NodeMetadata,NodeMetadata> |
PersistNodeCredentials.ifAdminAccess(Statement statement) |
com.google.common.base.Function<NodeMetadata,NodeMetadata> |
PersistNodeCredentials.ifAdminAccess(Statement statement) |
Set<? extends NodeMetadata> |
BaseComputeService.listNodesDetailsMatching(com.google.common.base.Predicate<ComputeMetadata> filter)
get all nodes including details such as image and ip addresses even if it incurs extra
requests to the service.
|
Map<NodeMetadata,ExecResponse> |
BaseComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter,
Statement runScript) |
Map<NodeMetadata,ExecResponse> |
BaseComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<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<NodeMetadata> filter,
String runScript) |
Map<? extends NodeMetadata,ExecResponse> |
BaseComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter,
String runScript,
RunScriptOptions options) |
com.google.common.base.Function<NodeMetadata,SshClient> |
UtilsImpl.sshForNode() |
Modifier and Type | Method and Description |
---|---|
protected NodeMetadata |
BaseComputeService.updateNodeWithCredentialsIfPresent(NodeMetadata node,
RunScriptOptions options) |
Modifier and Type | Method and Description |
---|---|
protected void |
BaseComputeService.cleanUpIncidentalResourcesOfDeadNodes(Set<? extends NodeMetadata> deadNodes) |
Set<? extends NodeMetadata> |
BaseComputeService.destroyNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
void |
BaseComputeService.rebootNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
void |
BaseComputeService.resumeNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
Map<NodeMetadata,ExecResponse> |
BaseComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter,
Statement runScript) |
Map<NodeMetadata,ExecResponse> |
BaseComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<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<NodeMetadata> filter,
String runScript) |
Map<? extends NodeMetadata,ExecResponse> |
BaseComputeService.runScriptOnNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter,
String runScript,
RunScriptOptions options) |
void |
BaseComputeService.suspendNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
Constructor and Description |
---|
BaseComputeService(ComputeServiceContext context,
Map<String,Credentials> credentialStore,
com.google.common.base.Supplier<Set<? extends Image>> images,
com.google.common.base.Supplier<Set<? extends Hardware>> hardwareProfiles,
com.google.common.base.Supplier<Set<? extends Location>> locations,
ListNodesStrategy listNodesStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
Provider<TemplateBuilder> templateBuilderProvider,
Provider<TemplateOptions> templateOptionsProvider,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeTerminated,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeSuspended,
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory initScriptRunnerFactory,
InitAdminAccess initAdminAccess,
RunScriptOnNode.Factory runScriptOnNodeFactory,
PersistNodeCredentials persistNodeCredentials,
ComputeServiceConstants.Timeouts timeouts,
ExecutorService executor) |
BaseComputeService(ComputeServiceContext context,
Map<String,Credentials> credentialStore,
com.google.common.base.Supplier<Set<? extends Image>> images,
com.google.common.base.Supplier<Set<? extends Hardware>> hardwareProfiles,
com.google.common.base.Supplier<Set<? extends Location>> locations,
ListNodesStrategy listNodesStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
Provider<TemplateBuilder> templateBuilderProvider,
Provider<TemplateOptions> templateOptionsProvider,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeTerminated,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeSuspended,
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory initScriptRunnerFactory,
InitAdminAccess initAdminAccess,
RunScriptOnNode.Factory runScriptOnNodeFactory,
PersistNodeCredentials persistNodeCredentials,
ComputeServiceConstants.Timeouts timeouts,
ExecutorService executor) |
BaseComputeService(ComputeServiceContext context,
Map<String,Credentials> credentialStore,
com.google.common.base.Supplier<Set<? extends Image>> images,
com.google.common.base.Supplier<Set<? extends Hardware>> hardwareProfiles,
com.google.common.base.Supplier<Set<? extends Location>> locations,
ListNodesStrategy listNodesStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
Provider<TemplateBuilder> templateBuilderProvider,
Provider<TemplateOptions> templateOptionsProvider,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeTerminated,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeSuspended,
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory initScriptRunnerFactory,
InitAdminAccess initAdminAccess,
RunScriptOnNode.Factory runScriptOnNodeFactory,
PersistNodeCredentials persistNodeCredentials,
ComputeServiceConstants.Timeouts timeouts,
ExecutorService executor) |
Modifier and Type | Field and Description |
---|---|
static com.google.common.base.Predicate<NodeMetadata> |
NodePredicates.RUNNING
Match nodes with State == RUNNING
|
static com.google.common.base.Predicate<NodeMetadata> |
NodePredicates.TERMINATED
Match nodes with State == NODE_TERMINATED
|
Modifier and Type | Method and Description |
---|---|
static com.google.common.base.Predicate<NodeMetadata> |
NodePredicates.inGroup(String group)
Return nodes in the specified group.
|
static com.google.common.base.Predicate<NodeMetadata> |
NodePredicates.runningInGroup(String group)
Return nodes with specified group that are in the NODE_RUNNING state.
|
Modifier and Type | Method and Description |
---|---|
boolean |
NodeTerminated.apply(NodeMetadata node)
Deprecated.
|
boolean |
NodePresentAndInIntendedState.apply(NodeMetadata node)
Deprecated.
|
boolean |
TrueIfNullOrTerminatedRefreshAndDoubleCheckOnFalse.checkState(NodeMetadata node) |
boolean |
RefreshAndDoubleCheckOnFailUnlessStateInvalid.checkState(NodeMetadata node) |
Modifier and Type | Method and Description |
---|---|
boolean |
TrueIfNullOrTerminatedRefreshAndDoubleCheckOnFalse.apply(AtomicReference<NodeMetadata> atomicNode) |
boolean |
RefreshAndDoubleCheckOnFailUnlessStateInvalid.apply(AtomicReference<NodeMetadata> atomicNode) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
CreateNodeWithGroupEncodedIntoName.createNodeWithGroupEncodedIntoName(String group,
String name,
Template template)
create a node given the name and template parameters such as imageid, hardwareid, and
locationid.
|
NodeMetadata |
DestroyNodeStrategy.destroyNode(String id) |
NodeMetadata |
GetNodeMetadataStrategy.getNode(String id) |
NodeMetadata |
RebootNodeStrategy.rebootNode(String id) |
NodeMetadata |
ResumeNodeStrategy.resumeNode(String id) |
NodeMetadata |
SuspendNodeStrategy.suspendNode(String id) |
Modifier and Type | Method and Description |
---|---|
com.google.common.base.Function<AtomicReference<NodeMetadata>,Void> |
CustomizeNodeAndAddToGoodMapOrPutExceptionIntoBadMap.Factory.create(TemplateOptions options,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Iterable<? extends NodeMetadata> |
ListNodesStrategy.listDetailsOnNodesMatching(com.google.common.base.Predicate<ComputeMetadata> filter) |
Modifier and Type | Method and Description |
---|---|
Callable<RunScriptOnNode> |
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory.create(NodeMetadata node,
Statement script,
RunScriptOptions options,
Map<NodeMetadata,Exception> badNodes) |
Modifier and Type | Method and Description |
---|---|
Void |
CustomizeNodeAndAddToGoodMapOrPutExceptionIntoBadMap.apply(AtomicReference<NodeMetadata> input) |
Callable<RunScriptOnNode> |
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory.create(NodeMetadata node,
Statement script,
RunScriptOptions options,
Map<NodeMetadata,Exception> badNodes) |
Callable<Void> |
CustomizeNodeAndAddToGoodMapOrPutExceptionIntoBadMap.Factory.create(TemplateOptions options,
AtomicReference<NodeMetadata> node,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Callable<Void> |
CustomizeNodeAndAddToGoodMapOrPutExceptionIntoBadMap.Factory.create(TemplateOptions options,
AtomicReference<NodeMetadata> node,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Callable<Void> |
CustomizeNodeAndAddToGoodMapOrPutExceptionIntoBadMap.Factory.create(TemplateOptions options,
AtomicReference<NodeMetadata> node,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Callable<Void> |
CustomizeNodeAndAddToGoodMapOrPutExceptionIntoBadMap.Factory.create(TemplateOptions options,
AtomicReference<NodeMetadata> node,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
com.google.common.base.Function<AtomicReference<NodeMetadata>,Void> |
CustomizeNodeAndAddToGoodMapOrPutExceptionIntoBadMap.Factory.create(TemplateOptions options,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
com.google.common.base.Function<AtomicReference<NodeMetadata>,Void> |
CustomizeNodeAndAddToGoodMapOrPutExceptionIntoBadMap.Factory.create(TemplateOptions options,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
com.google.common.base.Function<AtomicReference<NodeMetadata>,Void> |
CustomizeNodeAndAddToGoodMapOrPutExceptionIntoBadMap.Factory.create(TemplateOptions options,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Map<?,Future<Void>> |
CreateNodesInGroupThenAddToSet.execute(String group,
int count,
Template template,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Map<?,Future<Void>> |
CreateNodesInGroupThenAddToSet.execute(String group,
int count,
Template template,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Map<?,Future<Void>> |
CreateNodesInGroupThenAddToSet.execute(String group,
int count,
Template template,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
AdaptingComputeServiceStrategies.createNodeWithGroupEncodedIntoName(String group,
String name,
Template template)
create a node given the name and template parameters such as imageid, hardwareid, and
locationid.
|
NodeMetadata |
AdaptingComputeServiceStrategies.destroyNode(String id) |
NodeMetadata |
AdaptingComputeServiceStrategies.getNode(String id) |
NodeMetadata |
AdaptingComputeServiceStrategies.rebootNode(String id) |
NodeMetadata |
AdaptingComputeServiceStrategies.resumeNode(String id) |
NodeMetadata |
AdaptingComputeServiceStrategies.suspendNode(String id) |
Modifier and Type | Method and Description |
---|---|
Iterable<? extends NodeMetadata> |
AdaptingComputeServiceStrategies.listDetailsOnNodesMatching(com.google.common.base.Predicate<ComputeMetadata> filter) |
Modifier and Type | Method and Description |
---|---|
Map<?,Future<Void>> |
CreateNodesWithGroupEncodedIntoNameThenAddToSet.execute(String group,
int count,
Template template,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses)
This implementation gets a list of acceptable node names to encode the group into, then it
simultaneously runs the nodes and applies options to them.
|
Map<?,Future<Void>> |
CreateNodesWithGroupEncodedIntoNameThenAddToSet.execute(String group,
int count,
Template template,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses)
This implementation gets a list of acceptable node names to encode the group into, then it
simultaneously runs the nodes and applies options to them.
|
Map<?,Future<Void>> |
CreateNodesWithGroupEncodedIntoNameThenAddToSet.execute(String group,
int count,
Template template,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses)
This implementation gets a list of acceptable node names to encode the group into, then it
simultaneously runs the nodes and applies options to them.
|
Constructor and Description |
---|
AdaptingComputeServiceStrategies(Map<String,Credentials> credentialStore,
PrioritizeCredentialsFromTemplate prioritizeCredentialsFromTemplate,
ComputeServiceAdapter<N,H,I,L> client,
com.google.common.base.Function<N,NodeMetadata> nodeMetadataAdapter) |
Modifier and Type | Field and Description |
---|---|
protected static com.google.common.cache.LoadingCache<String,ConcurrentMap<String,NodeMetadata>> |
StubComputeServiceDependenciesModule.backing |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
StubComputeServiceAdapter.getNode(String id) |
Modifier and Type | Method and Description |
---|---|
Iterable<NodeMetadata> |
StubComputeServiceAdapter.listNodes() |
protected ConcurrentMap<String,NodeMetadata> |
StubComputeServiceDependenciesModule.provideNodesForIdentity(String identity) |
Modifier and Type | Method and Description |
---|---|
protected void |
StubComputeServiceAdapter.setStateOnNode(NodeState state,
NodeMetadata node) |
protected void |
StubComputeServiceAdapter.setStateOnNodeAfterDelay(NodeState state,
NodeMetadata node,
long millis) |
Constructor and Description |
---|
StubComputeServiceAdapter(ConcurrentMap<String,NodeMetadata> nodes,
ExecutorService ioThreads,
com.google.common.base.Supplier<Location> location,
Provider<Integer> idProvider,
String publicIpPrefix,
String privateIpPrefix,
String passwordPrefix,
JustProvider locationSupplier,
Map<OsFamily,Map<String,String>> osToVersionMap) |
StubComputeServiceDependenciesModule.StubSocketOpen(ConcurrentMap<String,NodeMetadata> nodes,
String publicIpPrefix) |
Modifier and Type | Method and Description |
---|---|
static void |
ComputeServiceUtils.checkNodeHasIps(NodeMetadata node) |
static IPSocket |
ComputeServiceUtils.findReachableSocketOnNode(RetryIfSocketNotYetOpen socketTester,
NodeMetadata node,
int port) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
InstanceToNodeMetadata.apply(Instance from) |
Modifier and Type | Method and Description |
---|---|
protected void |
EC2ComputeService.cleanUpIncidentalResourcesOfDeadNodes(Set<? extends NodeMetadata> deadNodes)
Cleans implicit keypairs and security groups.
|
Constructor and Description |
---|
EC2ComputeService(ComputeServiceContext context,
Map<String,Credentials> credentialStore,
com.google.common.base.Supplier<Set<? extends Image>> images,
com.google.common.base.Supplier<Set<? extends Hardware>> sizes,
com.google.common.base.Supplier<Set<? extends Location>> locations,
ListNodesStrategy listNodesStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
Provider<TemplateBuilder> templateBuilderProvider,
Provider<TemplateOptions> templateOptionsProvider,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeTerminated,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeSuspended,
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory initScriptRunnerFactory,
RunScriptOnNode.Factory runScriptOnNodeFactory,
InitAdminAccess initAdminAccess,
PersistNodeCredentials persistNodeCredentials,
ComputeServiceConstants.Timeouts timeouts,
ExecutorService executor,
EC2Client ec2Client,
ConcurrentMap<RegionAndName,KeyPair> credentialsMap,
com.google.common.cache.LoadingCache<RegionAndName,String> securityGroupMap) |
EC2ComputeService(ComputeServiceContext context,
Map<String,Credentials> credentialStore,
com.google.common.base.Supplier<Set<? extends Image>> images,
com.google.common.base.Supplier<Set<? extends Hardware>> sizes,
com.google.common.base.Supplier<Set<? extends Location>> locations,
ListNodesStrategy listNodesStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
Provider<TemplateBuilder> templateBuilderProvider,
Provider<TemplateOptions> templateOptionsProvider,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeTerminated,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeSuspended,
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory initScriptRunnerFactory,
RunScriptOnNode.Factory runScriptOnNodeFactory,
InitAdminAccess initAdminAccess,
PersistNodeCredentials persistNodeCredentials,
ComputeServiceConstants.Timeouts timeouts,
ExecutorService executor,
EC2Client ec2Client,
ConcurrentMap<RegionAndName,KeyPair> credentialsMap,
com.google.common.cache.LoadingCache<RegionAndName,String> securityGroupMap) |
EC2ComputeService(ComputeServiceContext context,
Map<String,Credentials> credentialStore,
com.google.common.base.Supplier<Set<? extends Image>> images,
com.google.common.base.Supplier<Set<? extends Hardware>> sizes,
com.google.common.base.Supplier<Set<? extends Location>> locations,
ListNodesStrategy listNodesStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
Provider<TemplateBuilder> templateBuilderProvider,
Provider<TemplateOptions> templateOptionsProvider,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeTerminated,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeSuspended,
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory initScriptRunnerFactory,
RunScriptOnNode.Factory runScriptOnNodeFactory,
InitAdminAccess initAdminAccess,
PersistNodeCredentials persistNodeCredentials,
ComputeServiceConstants.Timeouts timeouts,
ExecutorService executor,
EC2Client ec2Client,
ConcurrentMap<RegionAndName,KeyPair> credentialsMap,
com.google.common.cache.LoadingCache<RegionAndName,String> securityGroupMap) |
Modifier and Type | Method and Description |
---|---|
com.google.common.base.Function<RunningInstance,NodeMetadata> |
EC2ComputeServiceDependenciesModule.bindNodeConverter(RunningInstanceToNodeMetadata baseConverter,
AddElasticIpsToNodemetadata addElasticIpsToNodemetadata,
boolean autoAllocateElasticIps)
only add the overhead of looking up ips when we have enabled the auto-allocate functionality
|
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
AddElasticIpsToNodemetadata.apply(NodeMetadata arg0) |
NodeMetadata |
RunningInstanceToNodeMetadata.apply(RunningInstance instance) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
AddElasticIpsToNodemetadata.apply(NodeMetadata arg0) |
Modifier and Type | Field and Description |
---|---|
protected com.google.common.base.Function<RunningInstance,NodeMetadata> |
EC2ListNodesStrategy.runningInstanceToNodeMetadata |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
EC2DestroyNodeStrategy.destroyNode(String id) |
NodeMetadata |
EC2GetNodeMetadataStrategy.getNode(String id) |
NodeMetadata |
EC2RebootNodeStrategy.rebootNode(String id) |
NodeMetadata |
EC2ResumeNodeStrategy.resumeNode(String id) |
NodeMetadata |
EC2SuspendNodeStrategy.suspendNode(String id) |
Modifier and Type | Method and Description |
---|---|
Set<? extends NodeMetadata> |
EC2ListNodesStrategy.listDetailsOnNodesMatching(com.google.common.base.Predicate<ComputeMetadata> filter) |
Modifier and Type | Method and Description |
---|---|
Map<?,Future<Void>> |
EC2CreateNodesInGroupThenAddToSet.execute(String group,
int count,
Template template,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Map<?,Future<Void>> |
EC2CreateNodesInGroupThenAddToSet.execute(String group,
int count,
Template template,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Map<?,Future<Void>> |
EC2CreateNodesInGroupThenAddToSet.execute(String group,
int count,
Template template,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Constructor and Description |
---|
EC2CreateNodesInGroupThenAddToSet(EC2Client client,
com.google.common.cache.LoadingCache<RegionAndName,String> elasticIpCache,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
Provider<TemplateBuilder> templateBuilderProvider,
CreateKeyPairAndSecurityGroupsAsNeededAndReturnRunOptions createKeyPairAndSecurityGroupsAsNeededAndReturncustomize,
InstancePresent instancePresent,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata,
com.google.common.cache.LoadingCache<RunningInstance,Credentials> instanceToCredentials,
Map<String,Credentials> credentialStore,
ComputeUtils utils) |
EC2CreateNodesInGroupThenAddToSet(EC2Client client,
com.google.common.cache.LoadingCache<RegionAndName,String> elasticIpCache,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
Provider<TemplateBuilder> templateBuilderProvider,
CreateKeyPairAndSecurityGroupsAsNeededAndReturnRunOptions createKeyPairAndSecurityGroupsAsNeededAndReturncustomize,
InstancePresent instancePresent,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata,
com.google.common.cache.LoadingCache<RunningInstance,Credentials> instanceToCredentials,
Map<String,Credentials> credentialStore,
ComputeUtils utils) |
EC2GetNodeMetadataStrategy(EC2Client client,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata) |
EC2ListNodesStrategy(EC2AsyncClient client,
com.google.common.base.Supplier<Set<String>> regions,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata,
ExecutorService executor) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
ServerInfoToNodeMetadata.apply(ServerInfo from) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
ServerDetailsToNodeMetadata.apply(ServerDetails from) |
Constructor and Description |
---|
GoGridComputeService(ComputeServiceContext context,
Map<String,Credentials> credentialStore,
com.google.common.base.Supplier<Set<? extends Image>> images,
com.google.common.base.Supplier<Set<? extends Hardware>> hardwareProfiles,
com.google.common.base.Supplier<Set<? extends Location>> locations,
ListNodesStrategy listNodesStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
Provider<TemplateBuilder> templateBuilderProvider,
Provider<TemplateOptions> templateOptionsProvider,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeTerminated,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeSuspended,
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory initScriptRunnerFactory,
InitAdminAccess initAdminAccess,
RunScriptOnNode.Factory runScriptOnNodeFactory,
PersistNodeCredentials persistNodeCredentials,
ComputeServiceConstants.Timeouts timeouts,
ExecutorService executor) |
GoGridComputeService(ComputeServiceContext context,
Map<String,Credentials> credentialStore,
com.google.common.base.Supplier<Set<? extends Image>> images,
com.google.common.base.Supplier<Set<? extends Hardware>> hardwareProfiles,
com.google.common.base.Supplier<Set<? extends Location>> locations,
ListNodesStrategy listNodesStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
Provider<TemplateBuilder> templateBuilderProvider,
Provider<TemplateOptions> templateOptionsProvider,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeTerminated,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeSuspended,
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory initScriptRunnerFactory,
InitAdminAccess initAdminAccess,
RunScriptOnNode.Factory runScriptOnNodeFactory,
PersistNodeCredentials persistNodeCredentials,
ComputeServiceConstants.Timeouts timeouts,
ExecutorService executor) |
GoGridComputeService(ComputeServiceContext context,
Map<String,Credentials> credentialStore,
com.google.common.base.Supplier<Set<? extends Image>> images,
com.google.common.base.Supplier<Set<? extends Hardware>> hardwareProfiles,
com.google.common.base.Supplier<Set<? extends Location>> locations,
ListNodesStrategy listNodesStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
Provider<TemplateBuilder> templateBuilderProvider,
Provider<TemplateOptions> templateOptionsProvider,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeTerminated,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeSuspended,
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory initScriptRunnerFactory,
InitAdminAccess initAdminAccess,
RunScriptOnNode.Factory runScriptOnNodeFactory,
PersistNodeCredentials persistNodeCredentials,
ComputeServiceConstants.Timeouts timeouts,
ExecutorService executor) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
ServerToNodeMetadata.apply(Server from) |
Modifier and Type | Method and Description |
---|---|
B |
LoadBalancerServiceAdapter.createLoadBalancerInLocation(Location location,
String loadBalancerName,
String protocol,
int loadBalancerPort,
int instancePort,
Iterable<? extends NodeMetadata> nodes) |
LoadBalancerMetadata |
LoadBalancerService.createLoadBalancerInLocation(Location location,
String loadBalancerName,
String protocol,
int loadBalancerPort,
int instancePort,
Iterable<? extends NodeMetadata> nodes) |
Modifier and Type | Method and Description |
---|---|
LoadBalancerMetadata |
BaseLoadBalancerService.createLoadBalancerInLocation(Location location,
String loadBalancerName,
String protocol,
int loadBalancerPort,
int instancePort,
Iterable<? extends NodeMetadata> nodes) |
Modifier and Type | Method and Description |
---|---|
LoadBalancerMetadata |
LoadBalanceNodesStrategy.createLoadBalancerInLocation(Location location,
String name,
String protocol,
int loadBalancerPort,
int instancePort,
Iterable<? extends NodeMetadata> nodes) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
ServerToNodeMetadata.apply(Server from) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
ServerToNodeMetadata.apply(Server from) |
Modifier and Type | Field and Description |
---|---|
protected com.google.common.base.Function<Server,NodeMetadata> |
RimuHostingCreateNodeWithGroupEncodedIntoName.serverToNodeMetadata |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
RimuHostingCreateNodeWithGroupEncodedIntoName.createNodeWithGroupEncodedIntoName(String group,
String name,
Template template) |
NodeMetadata |
RimuHostingDestroyNodeStrategy.destroyNode(String id) |
NodeMetadata |
RimuHostingGetNodeMetadataStrategy.getNode(String id) |
NodeMetadata |
RimuHostingLifeCycleStrategy.rebootNode(String id) |
NodeMetadata |
RimuHostingLifeCycleStrategy.resumeNode(String id) |
NodeMetadata |
RimuHostingLifeCycleStrategy.suspendNode(String id) |
Modifier and Type | Method and Description |
---|---|
Iterable<? extends NodeMetadata> |
RimuHostingListNodesStrategy.listDetailsOnNodesMatching(com.google.common.base.Predicate<ComputeMetadata> filter) |
Constructor and Description |
---|
RimuHostingCreateNodeWithGroupEncodedIntoName(RimuHostingClient client,
Map<String,Credentials> credentialStore,
com.google.common.base.Function<Server,NodeMetadata> serverToNodeMetadata) |
RimuHostingGetNodeMetadataStrategy(RimuHostingClient client,
com.google.common.base.Function<Server,NodeMetadata> serverToNodeMetadata) |
RimuHostingListNodesStrategy(RimuHostingClient client,
com.google.common.base.Function<Server,NodeMetadata> serverToNodeMetadata) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
VMToNodeMetadata.apply(VM from) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
ServerToNodeMetadata.apply(Server from) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
SliceToNodeMetadata.apply(Slice from) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
VirtualGuestToNodeMetadata.apply(VirtualGuest from) |
Modifier and Type | Method and Description |
---|---|
protected void |
TerremarkVCloudComputeService.cleanUpIncidentalResourcesOfDeadNodes(Set<? extends NodeMetadata> deadNodes)
Cleans implicit keypairs.
|
Constructor and Description |
---|
TerremarkVCloudComputeService(ComputeServiceContext context,
Map<String,Credentials> credentialStore,
com.google.common.base.Supplier<Set<? extends Image>> images,
com.google.common.base.Supplier<Set<? extends Hardware>> sizes,
com.google.common.base.Supplier<Set<? extends Location>> locations,
ListNodesStrategy listNodesStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
Provider<TemplateBuilder> templateBuilderProvider,
Provider<TemplateOptions> templateOptionsProvider,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeTerminated,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeSuspended,
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory initScriptRunnerFactory,
RunScriptOnNode.Factory runScriptOnNodeFactory,
InitAdminAccess initAdminAccess,
PersistNodeCredentials persistNodeCredentials,
ComputeServiceConstants.Timeouts timeouts,
ExecutorService executor,
CleanupOrphanKeys cleanupOrphanKeys) |
TerremarkVCloudComputeService(ComputeServiceContext context,
Map<String,Credentials> credentialStore,
com.google.common.base.Supplier<Set<? extends Image>> images,
com.google.common.base.Supplier<Set<? extends Hardware>> sizes,
com.google.common.base.Supplier<Set<? extends Location>> locations,
ListNodesStrategy listNodesStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
Provider<TemplateBuilder> templateBuilderProvider,
Provider<TemplateOptions> templateOptionsProvider,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeTerminated,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeSuspended,
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory initScriptRunnerFactory,
RunScriptOnNode.Factory runScriptOnNodeFactory,
InitAdminAccess initAdminAccess,
PersistNodeCredentials persistNodeCredentials,
ComputeServiceConstants.Timeouts timeouts,
ExecutorService executor,
CleanupOrphanKeys cleanupOrphanKeys) |
TerremarkVCloudComputeService(ComputeServiceContext context,
Map<String,Credentials> credentialStore,
com.google.common.base.Supplier<Set<? extends Image>> images,
com.google.common.base.Supplier<Set<? extends Hardware>> sizes,
com.google.common.base.Supplier<Set<? extends Location>> locations,
ListNodesStrategy listNodesStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
Provider<TemplateBuilder> templateBuilderProvider,
Provider<TemplateOptions> templateOptionsProvider,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeTerminated,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeSuspended,
InitializeRunScriptOnNodeOrPlaceInBadMap.Factory initScriptRunnerFactory,
RunScriptOnNode.Factory runScriptOnNodeFactory,
InitAdminAccess initAdminAccess,
PersistNodeCredentials persistNodeCredentials,
ComputeServiceConstants.Timeouts timeouts,
ExecutorService executor,
CleanupOrphanKeys cleanupOrphanKeys) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
VAppToNodeMetadata.apply(VApp from) |
Modifier and Type | Method and Description |
---|---|
OrgAndName |
NodeMetadataToOrgAndName.apply(NodeMetadata from) |
Modifier and Type | Field and Description |
---|---|
protected com.google.common.base.Function<VApp,NodeMetadata> |
TerremarkVCloudGetNodeMetadataStrategy.vAppToNodeMetadata |
protected com.google.common.base.Function<VApp,NodeMetadata> |
StartVAppWithGroupEncodedIntoName.vAppToNodeMetadata |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
StartVAppWithGroupEncodedIntoName.createNodeWithGroupEncodedIntoName(String group,
String name,
Template template) |
NodeMetadata |
TerremarkVCloudDestroyNodeStrategy.destroyNode(String id) |
NodeMetadata |
TerremarkVCloudGetNodeMetadataStrategy.getNode(String in) |
NodeMetadata |
TerremarkVCloudLifeCycleStrategy.rebootNode(String in) |
NodeMetadata |
TerremarkVCloudLifeCycleStrategy.resumeNode(String in) |
NodeMetadata |
TerremarkVCloudLifeCycleStrategy.suspendNode(String in) |
Modifier and Type | Method and Description |
---|---|
Iterable<NodeMetadata> |
TerremarkVCloudListNodesStrategy.listDetailsOnNodesMatching(com.google.common.base.Predicate<ComputeMetadata> filter) |
Modifier and Type | Method and Description |
---|---|
void |
CleanupOrphanKeys.execute(Iterable<? extends NodeMetadata> deadOnes) |
Map<?,Future<Void>> |
TerremarkEncodeTagIntoNameRunNodesAndAddToSetStrategy.execute(String tag,
int count,
Template template,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Map<?,Future<Void>> |
TerremarkEncodeTagIntoNameRunNodesAndAddToSetStrategy.execute(String tag,
int count,
Template template,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Map<?,Future<Void>> |
TerremarkEncodeTagIntoNameRunNodesAndAddToSetStrategy.execute(String tag,
int count,
Template template,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Constructor and Description |
---|
StartVAppWithGroupEncodedIntoName(TerremarkVCloudComputeClient computeClient,
com.google.common.base.Function<VApp,NodeMetadata> vAppToNodeMetadata,
TemplateToInstantiateOptions getOptions,
Map<String,Credentials> credentialStore,
PrioritizeCredentialsFromTemplate prioritizeCredentialsFromTemplate) |
TerremarkVCloudGetNodeMetadataStrategy(TerremarkVCloudClient client,
com.google.common.base.Function<VApp,NodeMetadata> vAppToNodeMetadata) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
VAppToNodeMetadata.apply(VApp from) |
Copyright © 2009-2012 jclouds. All Rights Reserved.