Modifier and Type | Method and Description |
---|---|
NodeMetadata |
VirtualMachineToNodeMetadata.apply(VirtualMachine vm) |
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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
com.google.common.base.Optional<ImageExtension> imageExtension,
GroupNamingConvention.Factory namingConvention) |
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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
com.google.common.base.Optional<ImageExtension> imageExtension,
GroupNamingConvention.Factory namingConvention) |
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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
com.google.common.base.Optional<ImageExtension> imageExtension,
GroupNamingConvention.Factory namingConvention) |
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,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
CreateKeyPairPlacementAndSecurityGroupsAsNeededAndReturnRunOptions createKeyPairAndSecurityGroupsAsNeededAndReturncustomize,
AWSEC2InstancePresent instancePresent,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata,
com.google.common.cache.LoadingCache<RunningInstance,com.google.common.base.Optional<LoginCredentials>> 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,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
CreateKeyPairPlacementAndSecurityGroupsAsNeededAndReturnRunOptions createKeyPairAndSecurityGroupsAsNeededAndReturncustomize,
AWSEC2InstancePresent instancePresent,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata,
com.google.common.cache.LoadingCache<RunningInstance,com.google.common.base.Optional<LoginCredentials>> 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 |
DeploymentToNodeMetadata.apply(Deployment input) |
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 |
---|---|
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 statusRunning,
ComputeServiceConstants.Timeouts timeouts,
ComputeServiceConstants.PollPeriod period) |
protected com.google.common.base.Predicate<AtomicReference<NodeMetadata>> |
ComputeServiceTimeoutsModule.serverSuspended(AtomicNodeSuspended statusSuspended,
ComputeServiceConstants.Timeouts timeouts,
ComputeServiceConstants.PollPeriod period) |
protected com.google.common.base.Predicate<AtomicReference<NodeMetadata>> |
ComputeServiceTimeoutsModule.serverTerminated(AtomicNodeTerminated statusTerminated,
ComputeServiceConstants.Timeouts timeouts,
ComputeServiceConstants.PollPeriod period) |
Constructor and Description |
---|
JCloudsNativeComputeServiceAdapterContextModule(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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
com.google.common.base.Optional<ImageExtension> imageExtension) |
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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
com.google.common.base.Optional<ImageExtension> imageExtension) |
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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
com.google.common.base.Optional<ImageExtension> imageExtension) |
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 |
---|---|
protected NodeMetadata |
AtomicNodeTerminated.refreshOrNull(NodeMetadata resource) |
Modifier and Type | Method and Description |
---|---|
static com.google.common.base.Predicate<NodeMetadata> |
NodePredicates.hasGroup()
Return nodes who have a value for
getGroup() |
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 |
---|---|
protected NodeMetadata |
AtomicNodeTerminated.refreshOrNull(NodeMetadata resource) |
Modifier and Type | Method and Description |
---|---|
protected NodeMetadata |
RefreshNodeAndDoubleCheckOnFailUnlessStatusInvalid.refreshOrNull(NodeMetadata resource) |
Modifier and Type | Method and Description |
---|---|
protected NodeMetadata |
RefreshNodeAndDoubleCheckOnFailUnlessStatusInvalid.refreshOrNull(NodeMetadata resource) |
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 |
---|---|
AtomicReference<NodeMetadata> |
CreateNodesWithGroupEncodedIntoNameThenAddToSet.AddNode.call() |
protected Future<AtomicReference<NodeMetadata>> |
CreateNodesWithGroupEncodedIntoNameThenAddToSet.createNodeInGroupWithNameAndTemplate(String group,
String name,
Template template)
This calls logic necessary to create a node and convert it from its provider-specific object
to the jclouds
NodeMetadata object. |
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,
com.google.common.base.Function<I,Image> imageAdapter) |
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(com.google.common.base.Supplier<Credentials> creds) |
Modifier and Type | Method and Description |
---|---|
protected void |
StubComputeServiceAdapter.setStateOnNode(NodeMetadata.Status status,
NodeMetadata node) |
protected void |
StubComputeServiceAdapter.setStateOnNodeAfterDelay(NodeMetadata.Status status,
NodeMetadata node,
long millis) |
Constructor and Description |
---|
StubComputeServiceAdapter(ConcurrentMap<String,NodeMetadata> nodes,
ExecutorService ioThreads,
com.google.common.base.Supplier<Location> location,
javax.inject.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 |
---|---|
com.google.common.net.HostAndPort |
OpenSocketFinder.findOpenSocketOnNode(NodeMetadata node,
int port,
long timeoutValue,
TimeUnit timeUnits) |
com.google.common.net.HostAndPort |
ConcurrentOpenSocketFinder.findOpenSocketOnNode(NodeMetadata node,
int port,
long timeoutValue,
TimeUnit timeUnits) |
Constructor and Description |
---|
ConcurrentOpenSocketFinder(SocketOpen socketTester,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
ExecutorService userThreads) |
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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
com.google.common.base.Optional<ImageExtension> imageExtension,
GroupNamingConvention.Factory namingConvention) |
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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
com.google.common.base.Optional<ImageExtension> imageExtension,
GroupNamingConvention.Factory namingConvention) |
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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
com.google.common.base.Optional<ImageExtension> imageExtension,
GroupNamingConvention.Factory namingConvention) |
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,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
CreateKeyPairAndSecurityGroupsAsNeededAndReturnRunOptions createKeyPairAndSecurityGroupsAsNeededAndReturncustomize,
InstancePresent instancePresent,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata,
com.google.common.cache.LoadingCache<RunningInstance,com.google.common.base.Optional<LoginCredentials>> 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,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
CreateKeyPairAndSecurityGroupsAsNeededAndReturnRunOptions createKeyPairAndSecurityGroupsAsNeededAndReturncustomize,
InstancePresent instancePresent,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata,
com.google.common.cache.LoadingCache<RunningInstance,com.google.common.base.Optional<LoginCredentials>> 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 |
---|---|
LoadBalancerMetadata |
ELBLoadBalanceNodesStrategy.createLoadBalancerInLocation(Location location,
String name,
String protocol,
int loadBalancerPort,
int instancePort,
Iterable<? extends NodeMetadata> nodes) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
VServerMetadataToNodeMetadata.apply(VServerMetadata 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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
com.google.common.base.Optional<ImageExtension> imageExtension) |
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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
com.google.common.base.Optional<ImageExtension> imageExtension) |
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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
com.google.common.base.Optional<ImageExtension> imageExtension) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
ServerToNodeMetadata.apply(Server from) |
Modifier and Type | Field and Description |
---|---|
protected com.google.common.base.Function<Set<? extends NodeMetadata>,com.google.common.collect.Multimap<String,String>> |
JoyentCloudComputeService.orphanedGroupsByDatacenterId |
Modifier and Type | Method and Description |
---|---|
protected void |
JoyentCloudComputeService.cleanUpIncidentalResourcesOfDeadNodes(Set<? extends NodeMetadata> deadNodes) |
Constructor and Description |
---|
JoyentCloudComputeService(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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
JoyentCloudApi novaApi,
com.google.common.cache.LoadingCache<DatacenterAndName,KeyAndPrivateKey> keyCache,
com.google.common.base.Function<Set<? extends NodeMetadata>,com.google.common.collect.Multimap<String,String>> orphanedGroupsByDatacenterId,
GroupNamingConvention.Factory namingConvention,
com.google.common.base.Optional<ImageExtension> imageExtension) |
JoyentCloudComputeService(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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
JoyentCloudApi novaApi,
com.google.common.cache.LoadingCache<DatacenterAndName,KeyAndPrivateKey> keyCache,
com.google.common.base.Function<Set<? extends NodeMetadata>,com.google.common.collect.Multimap<String,String>> orphanedGroupsByDatacenterId,
GroupNamingConvention.Factory namingConvention,
com.google.common.base.Optional<ImageExtension> imageExtension) |
JoyentCloudComputeService(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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
JoyentCloudApi novaApi,
com.google.common.cache.LoadingCache<DatacenterAndName,KeyAndPrivateKey> keyCache,
com.google.common.base.Function<Set<? extends NodeMetadata>,com.google.common.collect.Multimap<String,String>> orphanedGroupsByDatacenterId,
GroupNamingConvention.Factory namingConvention,
com.google.common.base.Optional<ImageExtension> imageExtension) |
JoyentCloudComputeService(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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
JoyentCloudApi novaApi,
com.google.common.cache.LoadingCache<DatacenterAndName,KeyAndPrivateKey> keyCache,
com.google.common.base.Function<Set<? extends NodeMetadata>,com.google.common.collect.Multimap<String,String>> orphanedGroupsByDatacenterId,
GroupNamingConvention.Factory namingConvention,
com.google.common.base.Optional<ImageExtension> imageExtension) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
MachineInDatacenterToNodeMetadata.apply(MachineInDatacenter machineInDatacenter) |
Modifier and Type | Method and Description |
---|---|
com.google.common.collect.Multimap<String,String> |
OrphanedGroupsByDatacenterId.apply(Set<? extends NodeMetadata> deadNodes) |
Modifier and Type | Method and Description |
---|---|
Map<?,Future<Void>> |
ApplyJoyentCloudTemplateOptionsCreateNodesWithGroupEncodedIntoNameThenAddToSet.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>> |
ApplyJoyentCloudTemplateOptionsCreateNodesWithGroupEncodedIntoNameThenAddToSet.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>> |
ApplyJoyentCloudTemplateOptionsCreateNodesWithGroupEncodedIntoNameThenAddToSet.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 |
---|---|
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 |
BaseNodePoolComputeServiceAdapter.getNode(String id) |
NodeMetadata |
NodeMetadataStoreCache.load(NodeMetadata backendNode) |
NodeMetadata |
NodeMetadataStore.load(NodeMetadata backendNode)
Loads the previously stored user
NodeMetadata corresponding to the provided backend
NodeMetadata . |
NodeMetadata |
JsonNodeMetadataStore.load(NodeMetadata backendNodeMetadata) |
NodeMetadata |
NodeMetadataStoreCache.store(NodeMetadata backendNode,
TemplateOptions userOptions,
String userGroup) |
NodeMetadata |
NodeMetadataStore.store(NodeMetadata backendNode,
TemplateOptions userOptions,
String userGroup)
Associates the provided user options and group with the provided backend
NodeMetadata ,
then build a frontend version of node metadata that has some fields from the backend node such
as id, name or location, and some fields from the provided userOptions, such as userMetadata
or tags. |
NodeMetadata |
JsonNodeMetadataStore.store(NodeMetadata backendNodeMetadata,
TemplateOptions userOptions,
String userGroup) |
Modifier and Type | Method and Description |
---|---|
protected Set<? extends NodeMetadata> |
BaseNodePoolComputeServiceAdapter.addToPool(int number) |
protected Set<NodeMetadata> |
BaseNodePoolComputeServiceAdapter.getBackendNodes() |
Iterable<NodeMetadata> |
BaseNodePoolComputeServiceAdapter.listNodes() |
Set<NodeMetadata> |
NodeMetadataStoreCache.loadAll(Set<NodeMetadata> backendNodes) |
Set<NodeMetadata> |
NodeMetadataStore.loadAll(Set<NodeMetadata> backendNodes)
Loads frontend
NodeMetadata for all provided backend nodes. |
Set<NodeMetadata> |
JsonNodeMetadataStore.loadAll(Set<NodeMetadata> backendNodes) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
NodeMetadataStoreCache.load(NodeMetadata backendNode) |
NodeMetadata |
NodeMetadataStore.load(NodeMetadata backendNode)
Loads the previously stored user
NodeMetadata corresponding to the provided backend
NodeMetadata . |
NodeMetadata |
JsonNodeMetadataStore.load(NodeMetadata backendNodeMetadata) |
NodeMetadata |
NodeMetadataStoreCache.store(NodeMetadata backendNode,
TemplateOptions userOptions,
String userGroup) |
NodeMetadata |
NodeMetadataStore.store(NodeMetadata backendNode,
TemplateOptions userOptions,
String userGroup)
Associates the provided user options and group with the provided backend
NodeMetadata ,
then build a frontend version of node metadata that has some fields from the backend node such
as id, name or location, and some fields from the provided userOptions, such as userMetadata
or tags. |
NodeMetadata |
JsonNodeMetadataStore.store(NodeMetadata backendNodeMetadata,
TemplateOptions userOptions,
String userGroup) |
Modifier and Type | Method and Description |
---|---|
Set<NodeMetadata> |
NodeMetadataStoreCache.loadAll(Set<NodeMetadata> backendNodes) |
Set<NodeMetadata> |
NodeMetadataStore.loadAll(Set<NodeMetadata> backendNodes)
Loads frontend
NodeMetadata for all provided backend nodes. |
Set<NodeMetadata> |
JsonNodeMetadataStore.loadAll(Set<NodeMetadata> backendNodes) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
ServerToNodeMetadata.apply(Server from) |
Modifier and Type | Field and Description |
---|---|
protected com.google.common.base.Function<Set<? extends NodeMetadata>,com.google.common.collect.Multimap<String,String>> |
NovaComputeService.orphanedGroupsByZoneId |
Modifier and Type | Method and Description |
---|---|
protected void |
NovaComputeService.cleanUpIncidentalResourcesOfDeadNodes(Set<? extends NodeMetadata> deadNodes) |
Constructor and Description |
---|
NovaComputeService(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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
NovaApi novaApi,
com.google.common.cache.LoadingCache<ZoneAndName,SecurityGroupInZone> securityGroupMap,
com.google.common.cache.LoadingCache<ZoneAndName,KeyPair> keyPairCache,
com.google.common.base.Function<Set<? extends NodeMetadata>,com.google.common.collect.Multimap<String,String>> orphanedGroupsByZoneId,
GroupNamingConvention.Factory namingConvention,
com.google.common.base.Optional<ImageExtension> imageExtension) |
NovaComputeService(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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
NovaApi novaApi,
com.google.common.cache.LoadingCache<ZoneAndName,SecurityGroupInZone> securityGroupMap,
com.google.common.cache.LoadingCache<ZoneAndName,KeyPair> keyPairCache,
com.google.common.base.Function<Set<? extends NodeMetadata>,com.google.common.collect.Multimap<String,String>> orphanedGroupsByZoneId,
GroupNamingConvention.Factory namingConvention,
com.google.common.base.Optional<ImageExtension> imageExtension) |
NovaComputeService(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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
NovaApi novaApi,
com.google.common.cache.LoadingCache<ZoneAndName,SecurityGroupInZone> securityGroupMap,
com.google.common.cache.LoadingCache<ZoneAndName,KeyPair> keyPairCache,
com.google.common.base.Function<Set<? extends NodeMetadata>,com.google.common.collect.Multimap<String,String>> orphanedGroupsByZoneId,
GroupNamingConvention.Factory namingConvention,
com.google.common.base.Optional<ImageExtension> imageExtension) |
NovaComputeService(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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy startNodeStrategy,
SuspendNodeStrategy stopNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
NovaApi novaApi,
com.google.common.cache.LoadingCache<ZoneAndName,SecurityGroupInZone> securityGroupMap,
com.google.common.cache.LoadingCache<ZoneAndName,KeyPair> keyPairCache,
com.google.common.base.Function<Set<? extends NodeMetadata>,com.google.common.collect.Multimap<String,String>> orphanedGroupsByZoneId,
GroupNamingConvention.Factory namingConvention,
com.google.common.base.Optional<ImageExtension> imageExtension) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
ServerInZoneToNodeMetadata.apply(ServerInZone serverInZone) |
Modifier and Type | Method and Description |
---|---|
AtomicReference<NodeMetadata> |
AllocateAndAddFloatingIpToNode.apply(AtomicReference<NodeMetadata> input) |
Modifier and Type | Method and Description |
---|---|
AtomicReference<NodeMetadata> |
AllocateAndAddFloatingIpToNode.apply(AtomicReference<NodeMetadata> input) |
com.google.common.collect.Multimap<String,String> |
OrphanedGroupsByZoneId.apply(Set<? extends NodeMetadata> deadNodes) |
Constructor and Description |
---|
AllocateAndAddFloatingIpToNode(com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
NovaApi novaApi,
com.google.common.cache.LoadingCache<ZoneAndId,Iterable<? extends FloatingIP>> floatingIpCache) |
Modifier and Type | Method and Description |
---|---|
protected Future<AtomicReference<NodeMetadata>> |
ApplyNovaTemplateOptionsCreateNodesWithGroupEncodedIntoNameThenAddToSet.createNodeInGroupWithNameAndTemplate(String group,
String name,
Template template) |
Modifier and Type | Method and Description |
---|---|
Map<?,Future<Void>> |
ApplyNovaTemplateOptionsCreateNodesWithGroupEncodedIntoNameThenAddToSet.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>> |
ApplyNovaTemplateOptionsCreateNodesWithGroupEncodedIntoNameThenAddToSet.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>> |
ApplyNovaTemplateOptionsCreateNodesWithGroupEncodedIntoNameThenAddToSet.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 |
---|---|
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 |
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 |
VMToNodeMetadata.apply(VM 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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
com.google.common.base.Optional<ImageExtension> imageExtension) |
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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
com.google.common.base.Optional<ImageExtension> imageExtension) |
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,
GetImageStrategy getImageStrategy,
GetNodeMetadataStrategy getNodeMetadataStrategy,
CreateNodesInGroupThenAddToSet runNodesAndAddToSetStrategy,
RebootNodeStrategy rebootNodeStrategy,
DestroyNodeStrategy destroyNodeStrategy,
ResumeNodeStrategy resumeNodeStrategy,
SuspendNodeStrategy suspendNodeStrategy,
javax.inject.Provider<TemplateBuilder> templateBuilderProvider,
javax.inject.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,
com.google.common.base.Optional<ImageExtension> imageExtension) |
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) |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
VmToNodeMetadata.apply(Vm from) |
Constructor and Description |
---|
VirtualBoxImageExtension(ComputeServiceAdapter<org.virtualbox_4_1.IMachine,Hardware,Image,Location> vboxAdapter,
com.google.common.base.Function<org.virtualbox_4_1.IMachine,NodeMetadata> machineToNode,
com.google.common.base.Supplier<org.virtualbox_4_1.VirtualBoxManager> manager,
String workingDir,
com.google.common.base.Function<org.virtualbox_4_1.IMachine,Image> imachineToImage,
MachineUtils machineUtils) |
Modifier and Type | Method and Description |
---|---|
protected com.google.common.base.Supplier<NodeMetadata> |
HardcodeLocalhostAsNodeMetadataSupplier.lazySupplyHostAsNodeMetadata()
Lazy so that we don't hang up the injector reading a file
|
protected com.google.common.base.Function<com.google.common.base.Supplier<NodeMetadata>,org.virtualbox_4_1.VirtualBoxManager> |
VirtualBoxComputeServiceContextModule.provideVBox() |
Modifier and Type | Method and Description |
---|---|
NodeMetadata |
IMachineToNodeMetadata.apply(org.virtualbox_4_1.IMachine vm) |
NodeMetadata |
HardcodedHostToHostNodeMetadata.apply(NodeMetadata host) |
Modifier and Type | Method and Description |
---|---|
List<BridgedIf> |
RetrieveActiveBridgedInterfaces.apply(NodeMetadata host) |
NodeMetadata |
HardcodedHostToHostNodeMetadata.apply(NodeMetadata host) |
Constructor and Description |
---|
IMachineToSshClient(SshClient.Factory sshClientFactory,
RunScriptOnNode.Factory scriptRunnerFactory,
com.google.common.base.Supplier<NodeMetadata> hostSupplier,
MachineUtils machineUtils) |
MastersLoadingCache(String version,
String installationKeySequence,
String preconfigurationUrl,
String workingDir,
com.google.common.base.Function<MasterSpec,org.virtualbox_4_1.IMachine> masterLoader,
com.google.common.base.Supplier<Map<Image,YamlImage>> yamlMapper,
com.google.common.base.Supplier<org.virtualbox_4_1.VirtualBoxManager> manager,
RunScriptOnNode.Factory runScriptOnNodeFactory,
RetryIfSocketNotYetOpen socketTester,
com.google.common.base.Supplier<NodeMetadata> host,
com.google.common.base.Supplier<URI> providerSupplier,
HardcodedHostToHostNodeMetadata hardcodedHostToHostNodeMetadata) |
NodeCreator(com.google.common.base.Supplier<org.virtualbox_4_1.VirtualBoxManager> manager,
com.google.common.base.Function<CloneSpec,org.virtualbox_4_1.IMachine> cloner,
RunScriptOnNode.Factory runScriptOnNodeFactory,
MachineUtils machineUtils,
RunScriptOnNode.Factory scriptRunnerFactory,
MachineController machineController,
com.google.common.base.Supplier<NodeMetadata> host,
com.google.common.base.Supplier<URI> providerSupplier,
com.google.common.base.Supplier<Credentials> credentials) |
Constructor and Description |
---|
StartVBoxIfNotAlreadyRunning(com.google.common.base.Function<com.google.common.base.Supplier<NodeMetadata>,org.virtualbox_4_1.VirtualBoxManager> managerForNode,
RunScriptOnNode.Factory runScriptOnNodeFactory,
RetryIfSocketNotYetOpen socketTester,
com.google.common.base.Supplier<NodeMetadata> host,
com.google.common.base.Supplier<URI> providerSupplier,
HardcodedHostToHostNodeMetadata hardcodedHostToHostNodeMetadata) |
StartVBoxIfNotAlreadyRunning(com.google.common.base.Function<com.google.common.base.Supplier<NodeMetadata>,org.virtualbox_4_1.VirtualBoxManager> managerForNode,
RunScriptOnNode.Factory runScriptOnNodeFactory,
RetryIfSocketNotYetOpen socketTester,
com.google.common.base.Supplier<NodeMetadata> host,
com.google.common.base.Supplier<URI> providerSupplier,
HardcodedHostToHostNodeMetadata hardcodedHostToHostNodeMetadata) |
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<ExecResponse> |
MachineUtils.runScriptOnNode(NodeMetadata metadata,
Statement statement,
RunScriptOptions options) |
Copyright © 2009-2013 jclouds. All Rights Reserved.