org.apache.brooklyn.location.jclouds

Class JcloudsUtil

java.lang.Object

org.apache.brooklyn.location.jclouds.JcloudsUtil

public class JcloudsUtil
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static java.util.Map<java.lang.Integer,java.lang.Integer>	dockerPortMappingsFor(JcloudsLocation docker, java.lang.String containerId)
static java.lang.String	getFirstReachableAddress(org.jclouds.compute.domain.NodeMetadata node, Duration timeout) Uses Networking.isReachablePredicate() to determine reachability.
static java.lang.String	getFirstReachableAddress(org.jclouds.compute.domain.NodeMetadata node, Duration timeout, <any> socketTester)
static java.lang.Iterable<HostAndPort>	getReachableAddresses(java.lang.Iterable<HostAndPort> sockets, Duration timeout, <any> socketTester) Uses ReachableSocketFinder to determine which sockets are reachable.
static java.lang.Iterable<HostAndPort>	getReachableAddresses(java.lang.Iterable<java.lang.String> hosts, int port, Duration timeout, <any> socketTester)
static java.lang.Iterable<HostAndPort>	getReachableAddresses(org.jclouds.compute.domain.NodeMetadata node, Duration timeout, <any> socketTester)
static java.lang.String	waitForPasswordOnAws(org.jclouds.compute.ComputeService computeService, org.jclouds.compute.domain.NodeMetadata node, long timeout, java.util.concurrent.TimeUnit timeUnit)

Methods inherited from class java.lang.Object

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

Method Detail

getFirstReachableAddress

public static java.lang.String getFirstReachableAddress(org.jclouds.compute.domain.NodeMetadata node,
                                                        Duration timeout)

Uses Networking.isReachablePredicate() to determine reachability.

See Also:

#getReachableAddresses(NodeMetadata, Duration, Predicate)

getFirstReachableAddress

public static java.lang.String getFirstReachableAddress(org.jclouds.compute.domain.NodeMetadata node,
                                                        Duration timeout,
                                                        <any> socketTester)

See Also:

#getReachableAddresses(NodeMetadata, Duration, Predicate)

getReachableAddresses

public static java.lang.Iterable<HostAndPort> getReachableAddresses(org.jclouds.compute.domain.NodeMetadata node,
                                                                    Duration timeout,
                                                                    <any> socketTester)

Returns:

The public and private addresses of node that are reachable.

See Also:

#getReachableAddresses(Iterable, Duration, Predicate)

getReachableAddresses

public static java.lang.Iterable<HostAndPort> getReachableAddresses(java.lang.Iterable<java.lang.String> hosts,
                                                                    int port,
                                                                    Duration timeout,
                                                                    <any> socketTester)

See Also:

#getReachableAddresses(Iterable, Duration, Predicate)

getReachableAddresses

public static java.lang.Iterable<HostAndPort> getReachableAddresses(java.lang.Iterable<HostAndPort> sockets,
                                                                    Duration timeout,
                                                                    <any> socketTester)

Uses ReachableSocketFinder to determine which sockets are reachable. Iterators are unmodifiable and are lazily evaluated.

Parameters:

sockets - The host-and-ports to test

timeout - Max time to try to connect to the ip:port

socketTester - A predicate determining reachability.

waitForPasswordOnAws

public static java.lang.String waitForPasswordOnAws(org.jclouds.compute.ComputeService computeService,
                                                    org.jclouds.compute.domain.NodeMetadata node,
                                                    long timeout,
                                                    java.util.concurrent.TimeUnit timeUnit)
                                             throws java.util.concurrent.TimeoutException

Throws:

java.util.concurrent.TimeoutException

dockerPortMappingsFor

public static java.util.Map<java.lang.Integer,java.lang.Integer> dockerPortMappingsFor(JcloudsLocation docker,
                                                                                       java.lang.String containerId)