| 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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
AWSEC2Api client,
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,
com.google.common.base.Optional<ImageExtension> imageExtension,
GroupNamingConvention.Factory namingConvention,
boolean generateInstanceNames,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
AWSEC2Api client,
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,
com.google.common.base.Optional<ImageExtension> imageExtension,
GroupNamingConvention.Factory namingConvention,
boolean generateInstanceNames,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
AWSEC2Api client,
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,
com.google.common.base.Optional<ImageExtension> imageExtension,
GroupNamingConvention.Factory namingConvention,
boolean generateInstanceNames,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
| Constructor and Description |
|---|
AWSEC2CreateNodesInGroupThenAddToSet(AWSEC2Api client,
com.google.common.cache.LoadingCache<RegionAndName,String> elasticIpCache,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
boolean generateInstanceNames,
CreateKeyPairPlacementAndSecurityGroupsAsNeededAndReturnRunOptions createKeyPairAndSecurityGroupsAsNeededAndReturncustomize,
PresentSpotRequestsAndInstances 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(AWSEC2Api client,
com.google.common.cache.LoadingCache<RegionAndName,String> elasticIpCache,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
boolean generateInstanceNames,
CreateKeyPairPlacementAndSecurityGroupsAsNeededAndReturnRunOptions createKeyPairAndSecurityGroupsAsNeededAndReturncustomize,
PresentSpotRequestsAndInstances 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(AWSEC2Api client,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata,
SpotInstanceRequestToAWSRunningInstance spotConverter) |
AWSEC2ListNodesStrategy(AWSEC2Api client,
com.google.common.base.Supplier<Set<String>> regions,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
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() |
Iterable<NodeMetadata> |
BYONComputeServiceAdapter.listNodesByIds(Iterable<String> ids) |
| Modifier and Type | Field and Description |
|---|---|
protected com.google.common.base.Function<Set<? extends NodeMetadata>,com.google.common.collect.Multimap<String,String>> |
CloudStackComputeService.orphanedGroupsByZoneId |
| Modifier and Type | Method and Description |
|---|---|
protected void |
CloudStackComputeService.cleanUpIncidentalResourcesOfDeadNodes(Set<? extends NodeMetadata> deadNodes) |
| Constructor and Description |
|---|
CloudStackComputeService(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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
CloudStackApi client,
com.google.common.cache.LoadingCache<ZoneAndName,SecurityGroup> securityGroupMap,
com.google.common.cache.LoadingCache<String,SshKeyPair> keyPairCache,
com.google.common.base.Function<Set<? extends NodeMetadata>,com.google.common.collect.Multimap<String,String>> orphanedGroupsByZoneId,
GroupNamingConvention.Factory namingConvention,
com.google.common.base.Supplier<com.google.common.cache.LoadingCache<String,Zone>> zoneIdToZone,
com.google.common.base.Optional<ImageExtension> imageExtension,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
CloudStackComputeService(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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
CloudStackApi client,
com.google.common.cache.LoadingCache<ZoneAndName,SecurityGroup> securityGroupMap,
com.google.common.cache.LoadingCache<String,SshKeyPair> keyPairCache,
com.google.common.base.Function<Set<? extends NodeMetadata>,com.google.common.collect.Multimap<String,String>> orphanedGroupsByZoneId,
GroupNamingConvention.Factory namingConvention,
com.google.common.base.Supplier<com.google.common.cache.LoadingCache<String,Zone>> zoneIdToZone,
com.google.common.base.Optional<ImageExtension> imageExtension,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
CloudStackComputeService(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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
CloudStackApi client,
com.google.common.cache.LoadingCache<ZoneAndName,SecurityGroup> securityGroupMap,
com.google.common.cache.LoadingCache<String,SshKeyPair> keyPairCache,
com.google.common.base.Function<Set<? extends NodeMetadata>,com.google.common.collect.Multimap<String,String>> orphanedGroupsByZoneId,
GroupNamingConvention.Factory namingConvention,
com.google.common.base.Supplier<com.google.common.cache.LoadingCache<String,Zone>> zoneIdToZone,
com.google.common.base.Optional<ImageExtension> imageExtension,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
CloudStackComputeService(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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
CloudStackApi client,
com.google.common.cache.LoadingCache<ZoneAndName,SecurityGroup> securityGroupMap,
com.google.common.cache.LoadingCache<String,SshKeyPair> keyPairCache,
com.google.common.base.Function<Set<? extends NodeMetadata>,com.google.common.collect.Multimap<String,String>> orphanedGroupsByZoneId,
GroupNamingConvention.Factory namingConvention,
com.google.common.base.Supplier<com.google.common.cache.LoadingCache<String,Zone>> zoneIdToZone,
com.google.common.base.Optional<ImageExtension> imageExtension,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
| Modifier and Type | Method and Description |
|---|---|
NodeMetadata |
VirtualMachineToNodeMetadata.apply(VirtualMachine from) |
| Modifier and Type | Method and Description |
|---|---|
com.google.common.collect.Multimap<String,String> |
OrphanedGroupsByZoneId.apply(Set<? extends NodeMetadata> deadNodes) |
| 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.listNodesByIds(Iterable<String> ids) |
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.
|
Set<? extends NodeMetadata> |
ComputeService.rebootNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
Set<? extends NodeMetadata> |
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) |
com.google.common.base.Function<NodeMetadata,SshClient> |
Utils.sshForNode() |
Set<? extends NodeMetadata> |
ComputeService.suspendNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
| 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.
|
Set<? extends NodeMetadata> |
ComputeService.rebootNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
Set<? extends NodeMetadata> |
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) |
Set<? extends NodeMetadata> |
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) |
| Modifier and Type | Method and Description |
|---|---|
RunScriptOnNode |
BaseComputeServiceContextModule.RunScriptOnNodeFactoryImpl.create(NodeMetadata node,
Statement runScript,
RunScriptOptions options) |
BlockUntilInitScriptStatusIsZeroThenReturnOutput |
BaseComputeServiceContextModule.RunScriptOnNodeFactoryImpl.submit(NodeMetadata node,
Statement script,
RunScriptOptions options) |
| 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 |
|---|---|
AtomicReference<NodeMetadata> |
PollNodeRunning.apply(AtomicReference<NodeMetadata> node) |
| Modifier and Type | Method and Description |
|---|---|
SshClient |
CreateSshClientOncePortIsListeningOnNode.apply(NodeMetadata node) |
| Modifier and Type | Method and Description |
|---|---|
AtomicReference<NodeMetadata> |
PollNodeRunning.apply(AtomicReference<NodeMetadata> node) |
| Constructor and Description |
|---|
PollNodeRunning(com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning) |
| 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.listNodesByIds(Iterable<String> ids) |
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.
|
Set<? extends NodeMetadata> |
BaseComputeService.rebootNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
Set<? extends NodeMetadata> |
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) |
com.google.common.base.Function<NodeMetadata,SshClient> |
UtilsImpl.sshForNode() |
Set<? extends NodeMetadata> |
BaseComputeService.suspendNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
| 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.
|
Set<? extends NodeMetadata> |
BaseComputeService.rebootNodesMatching(com.google.common.base.Predicate<NodeMetadata> filter)
nodes matching the filter are treated as a logical set.
|
Set<? extends NodeMetadata> |
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) |
Set<? extends NodeMetadata> |
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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
com.google.common.base.Optional<ImageExtension> imageExtension,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
com.google.common.base.Optional<ImageExtension> imageExtension,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
com.google.common.base.Optional<ImageExtension> imageExtension,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
| 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.SUSPENDED
Match nodes with State == SUSPENDED
|
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) |
Iterable<? extends NodeMetadata> |
ListNodesStrategy.listNodesByIds(Iterable<String> ids) |
| 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<?,com.google.common.util.concurrent.ListenableFuture<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<?,com.google.common.util.concurrent.ListenableFuture<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<?,com.google.common.util.concurrent.ListenableFuture<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 com.google.common.util.concurrent.ListenableFuture<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) |
Iterable<? extends NodeMetadata> |
AdaptingComputeServiceStrategies.listNodesByIds(Iterable<String> ids) |
| Modifier and Type | Method and Description |
|---|---|
Map<?,com.google.common.util.concurrent.ListenableFuture<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<?,com.google.common.util.concurrent.ListenableFuture<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<?,com.google.common.util.concurrent.ListenableFuture<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,
ComputeServiceAdapterContextModule.AddDefaultCredentialsToImage addDefaultCredentialsToImage) |
| 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() |
Iterable<NodeMetadata> |
StubComputeServiceAdapter.listNodesByIds(Iterable<String> ids) |
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,
com.google.common.util.concurrent.ListeningExecutorService executor,
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,
com.google.common.collect.Multimap<String,SecurityGroup> groupsForNodes,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
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 timeout,
TimeUnit timeUnits) |
| Modifier and Type | Method and Description |
|---|---|
static String |
ComputeServiceUtils.createNodeErrorMessage(Map<? extends NodeMetadata,? extends Throwable> failedNodes) |
Map<?,com.google.common.util.concurrent.ListenableFuture<Void>> |
ComputeUtils.customizeNodesAndAddToGoodMapOrPutExceptionIntoBadMap(TemplateOptions options,
Iterable<NodeMetadata> runningNodes,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Map<?,com.google.common.util.concurrent.ListenableFuture<Void>> |
ComputeUtils.customizeNodesAndAddToGoodMapOrPutExceptionIntoBadMap(TemplateOptions options,
Iterable<NodeMetadata> runningNodes,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Map<?,com.google.common.util.concurrent.ListenableFuture<Void>> |
ComputeUtils.customizeNodesAndAddToGoodMapOrPutExceptionIntoBadMap(TemplateOptions options,
Iterable<NodeMetadata> runningNodes,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
Map<?,com.google.common.util.concurrent.ListenableFuture<Void>> |
ComputeUtils.customizeNodesAndAddToGoodMapOrPutExceptionIntoBadMap(TemplateOptions options,
Iterable<NodeMetadata> runningNodes,
Set<NodeMetadata> goodNodes,
Map<NodeMetadata,Exception> badNodes,
com.google.common.collect.Multimap<NodeMetadata,CustomizationResponse> customizationResponses) |
| Modifier and Type | Method and Description |
|---|---|
Set<? extends NodeMetadata> |
EC2ComputeService.createNodesInGroup(String group,
int count,
Template template) |
| 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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
EC2Api client,
ConcurrentMap<RegionAndName,KeyPair> credentialsMap,
com.google.common.cache.LoadingCache<RegionAndName,String> securityGroupMap,
com.google.common.base.Optional<ImageExtension> imageExtension,
GroupNamingConvention.Factory namingConvention,
boolean generateInstanceNames,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
EC2Api client,
ConcurrentMap<RegionAndName,KeyPair> credentialsMap,
com.google.common.cache.LoadingCache<RegionAndName,String> securityGroupMap,
com.google.common.base.Optional<ImageExtension> imageExtension,
GroupNamingConvention.Factory namingConvention,
boolean generateInstanceNames,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
EC2Api client,
ConcurrentMap<RegionAndName,KeyPair> credentialsMap,
com.google.common.cache.LoadingCache<RegionAndName,String> securityGroupMap,
com.google.common.base.Optional<ImageExtension> imageExtension,
GroupNamingConvention.Factory namingConvention,
boolean generateInstanceNames,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
| 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) |
Set<? extends NodeMetadata> |
EC2ListNodesStrategy.listNodesByIds(Iterable<String> ids) |
| Modifier and Type | Method and Description |
|---|---|
Map<?,com.google.common.util.concurrent.ListenableFuture<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<?,com.google.common.util.concurrent.ListenableFuture<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<?,com.google.common.util.concurrent.ListenableFuture<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(EC2Api client,
com.google.common.cache.LoadingCache<RegionAndName,String> elasticIpCache,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
CreateKeyPairAndSecurityGroupsAsNeededAndReturnRunOptions createKeyPairAndSecurityGroupsAsNeededAndReturncustomize,
PresentInstances presentInstances,
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(EC2Api client,
com.google.common.cache.LoadingCache<RegionAndName,String> elasticIpCache,
com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
CreateKeyPairAndSecurityGroupsAsNeededAndReturnRunOptions createKeyPairAndSecurityGroupsAsNeededAndReturncustomize,
PresentInstances presentInstances,
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(EC2Api client,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata) |
EC2ListNodesStrategy(EC2Api client,
com.google.common.base.Supplier<Set<String>> regions,
com.google.common.base.Function<RunningInstance,NodeMetadata> runningInstanceToNodeMetadata,
com.google.common.util.concurrent.ListeningExecutorService userExecutor) |
| 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,
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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
com.google.common.base.Optional<ImageExtension> imageExtension,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
com.google.common.base.Optional<ImageExtension> imageExtension,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
com.google.common.base.Optional<ImageExtension> imageExtension,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
| 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 |
|---|---|
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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
CleanupServer cleanupServer,
com.google.common.base.Optional<ImageExtension> imageExtension,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
CleanupServer cleanupServer,
com.google.common.base.Optional<ImageExtension> imageExtension,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
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,
com.google.common.util.concurrent.ListeningExecutorService userExecutor,
CleanupServer cleanupServer,
com.google.common.base.Optional<ImageExtension> imageExtension,
com.google.common.base.Optional<SecurityGroupExtension> securityGroupExtension) |
| Modifier and Type | Method and Description |
|---|---|
NodeMetadata |
ServerInRegionToNodeMetadata.apply(ServerInRegion serverInRegion) |
| Modifier and Type | Method and Description |
|---|---|
AtomicReference<NodeMetadata> |
AllocateAndAddFloatingIpToNode.apply(AtomicReference<NodeAndNovaTemplateOptions> input) |
| Modifier and Type | Method and Description |
|---|---|
com.google.common.collect.Multimap<String,String> |
OrphanedGroupsByRegionId.apply(Set<? extends NodeMetadata> deadNodes) |
| Constructor and Description |
|---|
AllocateAndAddFloatingIpToNode(com.google.common.base.Predicate<AtomicReference<NodeMetadata>> nodeRunning,
NovaApi novaApi,
com.google.common.cache.LoadingCache<RegionAndId,Iterable<? extends FloatingIP>> floatingIpCache,
CleanupServer cleanupServer) |
| Modifier and Type | Method and Description |
|---|---|
AtomicReference<NodeMetadata> |
NodeAndNovaTemplateOptions.getNodeMetadata() |
| Modifier and Type | Method and Description |
|---|---|
static AtomicReference<NodeAndNovaTemplateOptions> |
NodeAndNovaTemplateOptions.newAtomicReference(AtomicReference<NodeMetadata> node,
AtomicReference<NovaTemplateOptions> options) |
static NodeAndNovaTemplateOptions |
NodeAndNovaTemplateOptions.newReference(AtomicReference<NodeMetadata> node,
AtomicReference<NovaTemplateOptions> options) |
| Constructor and Description |
|---|
NodeAndNovaTemplateOptions(AtomicReference<NodeMetadata> nodeMetadata,
AtomicReference<NovaTemplateOptions> novaTemplateOptions) |
| Modifier and Type | Method and Description |
|---|---|
protected com.google.common.util.concurrent.ListenableFuture<AtomicReference<NodeMetadata>> |
ApplyNovaTemplateOptionsCreateNodesWithGroupEncodedIntoNameThenAddToSet.createNodeInGroupWithNameAndTemplate(String group,
String name,
Template template) |
| Modifier and Type | Method and Description |
|---|---|
Map<?,com.google.common.util.concurrent.ListenableFuture<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<?,com.google.common.util.concurrent.ListenableFuture<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<?,com.google.common.util.concurrent.ListenableFuture<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 |
VirtualGuestToNodeMetadata.apply(VirtualGuest from) |
Copyright © 2009-2016 The Apache Software Foundation. All Rights Reserved.