public class ClusterStateProvider extends Object
| Constructor and Description |
|---|
ClusterStateProvider(Ignite ignite,
Supplier<ClusterNode> locNodeSupplier,
TcpCommunicationSpi tcpCommSpi,
Supplier<Boolean> stoppedSupplier,
Supplier<IgniteSpiContext> spiCtxWithoutLatchSupplier,
IgniteLogger log,
Supplier<Ignite> igniteExSupplier)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
long |
clientFailureDetectionTimeout()
Deprecated.
Returns client failure detection timeout set to use for network related operations.
|
SSLEngine |
createSSLEngine()
Deprecated.
|
void |
dumpStats()
Deprecated.
Makes dump of
TcpCommunicationSpi stats. |
int |
getOutboundMessagesQueueSize()
Deprecated.
|
IgniteSpiContext |
getSpiContext()
Deprecated.
|
IgniteSpiContext |
getSpiContextWithoutInitialLatch()
Deprecated.
|
boolean |
isHandshakeWaitSupported()
Deprecated.
Checks whether remote nodes support
HandshakeWaitMessage. |
boolean |
isLocalNodeDisconnected()
Deprecated.
|
boolean |
isSslEnabled()
Deprecated.
|
boolean |
isStopping()
Deprecated.
|
NodeIdMessage |
nodeIdMessage()
Deprecated.
|
public ClusterStateProvider(Ignite ignite, Supplier<ClusterNode> locNodeSupplier, TcpCommunicationSpi tcpCommSpi, Supplier<Boolean> stoppedSupplier, Supplier<IgniteSpiContext> spiCtxWithoutLatchSupplier, IgniteLogger log, Supplier<Ignite> igniteExSupplier)
ignite - Ignite.locNodeSupplier - Local node supplier.tcpCommSpi - Tcp communication spi.stoppedSupplier - Stopped supplier.spiCtxWithoutLatchSupplier - Spi context without latchlog - Logger.igniteExSupplier - Returns already exists instance from spi.public boolean isLocalNodeDisconnected()
True if local node in disconnected state.public boolean isSslEnabled()
True if ssl enabled.public SSLEngine createSSLEngine()
SSLEngine for ssl connections.public boolean isStopping()
true if TcpCommunicationSpi stopped.public long clientFailureDetectionTimeout()
0 if the timeout is disabled.public IgniteSpiContext getSpiContext()
IgniteSpiContext of TcpCommunicationSpi.public IgniteSpiContext getSpiContextWithoutInitialLatch()
IgniteSpiContext of TcpCommunicationSpi.public int getOutboundMessagesQueueSize()
public void dumpStats()
TcpCommunicationSpi stats.public boolean isHandshakeWaitSupported()
HandshakeWaitMessage.True if remote nodes support HandshakeWaitMessage.public NodeIdMessage nodeIdMessage()
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.1 Release Date : December 20 2021