Uses of Interface
org.apache.ignite.internal.util.nio.GridCommunicationClient
-
Packages that use GridCommunicationClient Package Description org.apache.ignite.internal.util.nio NIO server interfaces and common utility classes for NIO.org.apache.ignite.spi.communication.tcp Contains default TCP/IP-based implementation for communication SPI.org.apache.ignite.spi.communication.tcp.internal Contains connection health-checkers for TCP/IP-based implementation of communication SPI. -
-
Uses of GridCommunicationClient in org.apache.ignite.internal.util.nio
Classes in org.apache.ignite.internal.util.nio that implement GridCommunicationClient Modifier and Type Class Description classGridAbstractCommunicationClientImplements basic lifecycle for communication clients.classGridTcpNioCommunicationClientGrid client for NIO server. -
Uses of GridCommunicationClient in org.apache.ignite.spi.communication.tcp
Methods in org.apache.ignite.spi.communication.tcp that return GridCommunicationClient Modifier and Type Method Description protected GridCommunicationClientTcpCommunicationSpi. createTcpClient(ClusterNode node, int connIdx)Establish TCP connection to remote node and returns client. -
Uses of GridCommunicationClient in org.apache.ignite.spi.communication.tcp.internal
Methods in org.apache.ignite.spi.communication.tcp.internal that return GridCommunicationClient Modifier and Type Method Description GridCommunicationClient[]ConnectionClientPool. clientFor(UUID id)@Nullable GridCommunicationClientConnectionClientPool. createCommunicationClient(ClusterNode node, int connIdx)GridCommunicationClientGridNioServerWrapper. createTcpClient(ClusterNode node, int connIdx, boolean backwardCompatibility)Deprecated.Establish TCP connection to remote node and returns client.GridCommunicationClientConnectionClientPool. reserveClient(ClusterNode node, int connIdx)Returns existing or just created client to node.Methods in org.apache.ignite.spi.communication.tcp.internal that return types with arguments of type GridCommunicationClient Modifier and Type Method Description GridFutureAdapter<GridCommunicationClient>ConnectionClientPool. getFut(ConnectionKey connKey)GridFutureAdapter<GridCommunicationClient>ConnectionClientPool. putIfAbsentFut(ConnectionKey key, GridFutureAdapter<GridCommunicationClient> fut)Methods in org.apache.ignite.spi.communication.tcp.internal with parameters of type GridCommunicationClient Modifier and Type Method Description voidConnectionClientPool. addNodeClient(ClusterNode node, int connIdx, GridCommunicationClient addClient)StringConnectionClientPool. clientString(GridCommunicationClient client, ClusterNode node)Returns the string representation of client with protection from null client value.booleanConnectionClientPool. removeNodeClient(UUID nodeId, GridCommunicationClient rmvClient)Method parameters in org.apache.ignite.spi.communication.tcp.internal with type arguments of type GridCommunicationClient Modifier and Type Method Description GridFutureAdapter<GridCommunicationClient>ConnectionClientPool. putIfAbsentFut(ConnectionKey key, GridFutureAdapter<GridCommunicationClient> fut)voidConnectionClientPool. removeFut(ConnectionKey connKey, GridFutureAdapter<GridCommunicationClient> fut)Constructor parameters in org.apache.ignite.spi.communication.tcp.internal with type arguments of type GridCommunicationClient Constructor Description GridNioServerWrapper(IgniteLogger log, TcpCommunicationConfiguration cfg, AttributeNames attributeNames, Tracing tracing, Function<UUID,ClusterNode> nodeGetter, Supplier<ClusterNode> locNodeSupplier, ConnectGateway connectGate, ClusterStateProvider stateProvider, Supplier<IgniteExceptionRegistry> eRegistrySupplier, CommunicationWorker commWorker, IgniteConfiguration igniteCfg, GridNioServerListener<Message> srvLsnr, String igniteInstanceName, WorkersRegistry workersRegistry, @Nullable GridMetricManager metricMgr, ThrowableBiFunction<ClusterNode,Integer,GridCommunicationClient,IgniteCheckedException> createTcpClientFun, CommunicationListener<Message> lsnr, TcpHandshakeExecutor tcpHandshakeExecutor)Deprecated.
-