Package org.apache.cassandra.net

Class StartupClusterConnectivityChecker

java.lang.Object

org.apache.cassandra.net.StartupClusterConnectivityChecker

public class StartupClusterConnectivityChecker
extends Object

Method Summary

Modifier and Type	Method	Description
static StartupClusterConnectivityChecker	create(long timeoutSecs, boolean blockForRemoteDcs)
boolean	execute(Set<InetAddressAndPort> peers, Function<InetAddressAndPort,String> getDatacenterSource)

Methods inherited from class java.lang.Object

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

Method Details

create

public static StartupClusterConnectivityChecker create(long timeoutSecs,
 boolean blockForRemoteDcs)

execute

public boolean execute(Set<InetAddressAndPort> peers,
 Function<InetAddressAndPort,String> getDatacenterSource)

Parameters:

peers - The currently known peers in the cluster; argument is not modified.

getDatacenterSource - A function for mapping peers to their datacenter.

Returns:

true if the requested percentage of peers are marked ALIVE in gossip and have their connections opened; else false.