Package org.apache.cassandra.net

Class StartupClusterConnectivityChecker

java.lang.Object

org.apache.cassandra.net.StartupClusterConnectivityChecker

public class StartupClusterConnectivityChecker
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
static StartupClusterConnectivityChecker	create(long timeoutSecs, boolean blockForRemoteDcs)
boolean	execute(java.util.Set<InetAddressAndPort> peers, java.util.function.Function<InetAddressAndPort,java.lang.String> getDatacenterSource, java.util.function.Predicate<CassandraVersion> isUpgradingFromLowerVersionThan)

Methods inherited from class java.lang.Object

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

Method Detail

create

public static StartupClusterConnectivityChecker create(long timeoutSecs,
                                                       boolean blockForRemoteDcs)

execute

public boolean execute(java.util.Set<InetAddressAndPort> peers,
                       java.util.function.Function<InetAddressAndPort,java.lang.String> getDatacenterSource,
                       java.util.function.Predicate<CassandraVersion> isUpgradingFromLowerVersionThan)

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.