org.jclouds.ec2.compute.strategy
Class EC2ListNodesStrategy

java.lang.Object
  org.jclouds.ec2.compute.strategy.EC2ListNodesStrategy

All Implemented Interfaces:

org.jclouds.compute.strategy.ListNodesStrategy

@Singleton
public class EC2ListNodesStrategy
extends Object
implements org.jclouds.compute.strategy.ListNodesStrategy

Field Summary

protected EC2Api	client
protected org.jclouds.logging.Logger	logger
protected static Long	maxTime
protected com.google.common.base.Supplier<Set<String>>	regions
protected com.google.common.base.Function<RunningInstance,org.jclouds.compute.domain.NodeMetadata>	runningInstanceToNodeMetadata
protected com.google.common.util.concurrent.ListeningExecutorService	userExecutor

Constructor Summary

protected

EC2ListNodesStrategy(EC2Api client, com.google.common.base.Supplier<Set<String>> regions, com.google.common.base.Function<RunningInstance,org.jclouds.compute.domain.NodeMetadata> runningInstanceToNodeMetadata, com.google.common.util.concurrent.ListeningExecutorService userExecutor)

Method Summary

protected com.google.common.base.Function<String,Set<? extends Reservation<? extends RunningInstance>>>	allInstancesInRegion()
protected com.google.common.base.Function<String,Set<? extends Reservation<? extends RunningInstance>>>	instancesByIdInRegion(com.google.common.collect.Multimap<String,String> idsByRegions)
Set<? extends org.jclouds.compute.domain.NodeMetadata>	listDetailsOnNodesMatching(com.google.common.base.Predicate<org.jclouds.compute.domain.ComputeMetadata> filter)
Set<? extends org.jclouds.compute.domain.ComputeMetadata>	listNodes()
Set<? extends org.jclouds.compute.domain.NodeMetadata>	listNodesByIds(Iterable<String> ids)
protected Iterable<? extends RunningInstance>	pollRunningInstances()
protected Iterable<? extends RunningInstance>	pollRunningInstancesByRegionsAndIds(com.google.common.collect.Multimap<String,String> idsByRegions)
protected com.google.common.base.Function<String,String>	splitHandle(int pos)

Methods inherited from class java.lang.Object

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

Field Detail

logger

@Named(value="jclouds.compute")
protected org.jclouds.logging.Logger logger

maxTime

@Inject(optional=true)
@Named(value="jclouds.request-timeout")
protected static Long maxTime

client

protected final EC2Api client

regions

protected final com.google.common.base.Supplier<Set<String>> regions

runningInstanceToNodeMetadata

protected final com.google.common.base.Function<RunningInstance,org.jclouds.compute.domain.NodeMetadata> runningInstanceToNodeMetadata

userExecutor

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

Constructor Detail

EC2ListNodesStrategy

@Inject
protected EC2ListNodesStrategy(EC2Api client,
                                      com.google.common.base.Supplier<Set<String>> regions,
                                      com.google.common.base.Function<RunningInstance,org.jclouds.compute.domain.NodeMetadata> runningInstanceToNodeMetadata,
                                      @Named(value="jclouds.user-threads")
                                      com.google.common.util.concurrent.ListeningExecutorService userExecutor)

Method Detail

listNodes

public Set<? extends org.jclouds.compute.domain.ComputeMetadata> listNodes()

Specified by:

listNodes in interface org.jclouds.compute.strategy.ListNodesStrategy

listNodesByIds

public Set<? extends org.jclouds.compute.domain.NodeMetadata> listNodesByIds(Iterable<String> ids)

Specified by:

listNodesByIds in interface org.jclouds.compute.strategy.ListNodesStrategy

listDetailsOnNodesMatching

public Set<? extends org.jclouds.compute.domain.NodeMetadata> listDetailsOnNodesMatching(com.google.common.base.Predicate<org.jclouds.compute.domain.ComputeMetadata> filter)

Specified by:

listDetailsOnNodesMatching in interface org.jclouds.compute.strategy.ListNodesStrategy

pollRunningInstances

protected Iterable<? extends RunningInstance> pollRunningInstances()

pollRunningInstancesByRegionsAndIds

protected Iterable<? extends RunningInstance> pollRunningInstancesByRegionsAndIds(com.google.common.collect.Multimap<String,String> idsByRegions)

splitHandle

protected com.google.common.base.Function<String,String> splitHandle(int pos)

allInstancesInRegion

protected com.google.common.base.Function<String,Set<? extends Reservation<? extends RunningInstance>>> allInstancesInRegion()

instancesByIdInRegion

protected com.google.common.base.Function<String,Set<? extends Reservation<? extends RunningInstance>>> instancesByIdInRegion(com.google.common.collect.Multimap<String,String> idsByRegions)