Package org.jclouds.compute.strategy.impl

Class CreateNodesWithGroupEncodedIntoNameThenAddToSet

java.lang.Object

org.jclouds.compute.strategy.impl.CreateNodesWithGroupEncodedIntoNameThenAddToSet

All Implemented Interfaces:

CreateNodesInGroupThenAddToSet

Direct Known Subclasses:

ApplyNovaTemplateOptionsCreateNodesWithGroupEncodedIntoNameThenAddToSet, AssignDataCenterToTemplate, CreateKeyPairsThenCreateNodes, CreateNodesWithGroupEncodedIntoNameThenAddToSet, CreateResourcesThenCreateNodes, CreateSshKeysThenCreateNodes

@Singleton
public class CreateNodesWithGroupEncodedIntoNameThenAddToSet
extends Object
implements CreateNodesInGroupThenAddToSet

creates futures that correlate to

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	CreateNodesWithGroupEncodedIntoNameThenAddToSet.AddNode

Field Summary

Fields

Modifier and Type	Field	Description
protected final CreateNodeWithGroupEncodedIntoName	addNodeWithGroupStrategy
protected final CustomizeNodeAndAddToGoodMapOrPutExceptionIntoBadMap.Factory	customizeNodeAndAddToGoodMapOrPutExceptionIntoBadMapFactory
protected final ListNodesStrategy	listNodesStrategy
protected Logger	logger
protected final GroupNamingConvention.Factory	namingConvention
protected final com.google.common.util.concurrent.ListeningExecutorService	userExecutor

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CreateNodesWithGroupEncodedIntoNameThenAddToSet(CreateNodeWithGroupEncodedIntoName addNodeWithGroupStrategy, ListNodesStrategy listNodesStrategy, GroupNamingConvention.Factory namingConvention, com.google.common.util.concurrent.ListeningExecutorService userExecutor, CustomizeNodeAndAddToGoodMapOrPutExceptionIntoBadMap.Factory customizeNodeAndAddToGoodMapOrPutExceptionIntoBadMapFactory)

Method Summary

Modifier and Type	Method	Description
protected com.google.common.util.concurrent.ListenableFuture<AtomicReference<NodeMetadata>>	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.
Map<?,com.google.common.util.concurrent.ListenableFuture<Void>>	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.
protected Set<String>	getNextNames(String group, Template template, int count)	Find the next node names that can be used.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

logger

@Named("jclouds.compute")
protected Logger logger

addNodeWithGroupStrategy

protected final CreateNodeWithGroupEncodedIntoName addNodeWithGroupStrategy

listNodesStrategy

protected final ListNodesStrategy listNodesStrategy

namingConvention

protected final GroupNamingConvention.Factory namingConvention

userExecutor

protected final com.google.common.util.concurrent.ListeningExecutorService userExecutor

customizeNodeAndAddToGoodMapOrPutExceptionIntoBadMapFactory

protected final CustomizeNodeAndAddToGoodMapOrPutExceptionIntoBadMap.Factory customizeNodeAndAddToGoodMapOrPutExceptionIntoBadMapFactory

Constructor Details

CreateNodesWithGroupEncodedIntoNameThenAddToSet

@Inject
protected CreateNodesWithGroupEncodedIntoNameThenAddToSet(CreateNodeWithGroupEncodedIntoName addNodeWithGroupStrategy,
 ListNodesStrategy listNodesStrategy,
 GroupNamingConvention.Factory namingConvention,
 @Named("jclouds.user-threads")
 com.google.common.util.concurrent.ListeningExecutorService userExecutor,
 CustomizeNodeAndAddToGoodMapOrPutExceptionIntoBadMap.Factory customizeNodeAndAddToGoodMapOrPutExceptionIntoBadMapFactory)

Method Details

execute

public Map<?,com.google.common.util.concurrent.ListenableFuture<Void>> 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.

Specified by:

execute in interface CreateNodesInGroupThenAddToSet

createNodeInGroupWithNameAndTemplate

protected com.google.common.util.concurrent.ListenableFuture<AtomicReference<NodeMetadata>> 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. This call directly precedes customization, such as executing scripts.

The outcome of this operation does not imply the node is

invalid reference

running

. If you want to insert logic after the node is created, yet before an attempt to customize the node, then append your behaviour to this method. ex. to attach an ip address post-creation

 @Override
 protected ListenableFuture<AtomicReference<NodeMetadata>> createNodeInGroupWithNameAndTemplate(String group, String name,
          Template template) {
 
    ListenableFuture<AtomicReference<NodeMetadata>> future = super.addNodeIntoGroupWithNameAndTemplate(group, name, template);
    return Futures.compose(future, new Function<AtomicReference<NodeMetadata>, AtomicReference<NodeMetadata>>() {
 
       @Override
       public AtomicReference<NodeMetadata> apply(AtomicReference<NodeMetadata> input) {
          NodeMetadata node = input.get();
          // allocate and attach an ip
          input.set(NodeMetadataBuilder.fromNodeMetadata(node).publicAddresses(ImmutableSet.of(ip.getIp())).build());
          return input;
       }
 
    }, executor);
 }
 

Parameters:

group - group the node belongs to

name - generated name of the node

template - user-specified template

Returns:

node that is created, yet not necessarily in

invalid reference

Status#RUNNING

getNextNames

protected Set<String> getNextNames(String group,
 Template template,
 int count)

Find the next node names that can be used. If the nodeNames template option is not specified or is empty, these will be derived from the group and the template. We will pre-allocate a specified quantity, and attempt to verify that there is no name conflict with the current service. If the nodeNames option is specified, names from that will be used instead, without any check for name conflicts. If there are insufficient names in nodeNames, subsequent names will be generated in the default format.

Parameters:

group -

template -

count -

Returns: