Package | Description |
---|---|
com.hazelcast.instance |
This package contains Hazelcast Instance functionality.
|
com.hazelcast.nio |
This package contains classes related to New IO
|
com.hazelcast.nio.ascii |
Contains SocketTextReader and SocketTextWriter classes;
|
com.hazelcast.nio.tcp |
Contains functionality for the TCP/IP Networking for cluster members
This whole package is internal and no compatibility will be provided. |
Modifier and Type | Method and Description |
---|---|
InboundHandler[] |
DefaultNodeExtension.createInboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection,
IOService ioService) |
InboundHandler[] |
NodeExtension.createInboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection,
IOService ioService)
Creates a InboundHandler for given Connection instance.
|
OutboundHandler[] |
DefaultNodeExtension.createOutboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection,
IOService ioService) |
OutboundHandler[] |
NodeExtension.createOutboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection,
IOService ioService)
Creates a OutboundHandler for given Connection instance.
|
Modifier and Type | Method and Description |
---|---|
Set<TcpIpConnection> |
DefaultAggregateEndpointManager.getActiveConnections() |
Collection<TcpIpConnection> |
UnifiedAggregateEndpointManager.getActiveConnections() |
Collection<TcpIpConnection> |
AggregateEndpointManager.getActiveConnections() |
Set<TcpIpConnection> |
DefaultAggregateEndpointManager.getConnections() |
Collection<TcpIpConnection> |
UnifiedAggregateEndpointManager.getConnections() |
Collection<TcpIpConnection> |
AggregateEndpointManager.getConnections() |
EndpointManager<TcpIpConnection> |
DefaultAggregateEndpointManager.getEndpointManager(EndpointQualifier qualifier) |
EndpointManager<TcpIpConnection> |
UnifiedAggregateEndpointManager.getEndpointManager(EndpointQualifier qualifier) |
Modifier and Type | Method and Description |
---|---|
InboundHandler[] |
NodeIOService.createInboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection) |
InboundHandler[] |
IOService.createInboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection) |
OutboundHandler[] |
NodeIOService.createOutboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection) |
OutboundHandler[] |
IOService.createOutboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection) |
Constructor and Description |
---|
DefaultAggregateEndpointManager(ConcurrentMap<EndpointQualifier,EndpointManager<TcpIpConnection>> endpointManagers) |
UnifiedAggregateEndpointManager(TcpIpEndpointManager unified,
Map<EndpointQualifier,EndpointManager<TcpIpConnection>> views) |
Modifier and Type | Method and Description |
---|---|
void |
AllowingTextProtocolFilter.filterConnection(String commandLine,
TcpIpConnection connection) |
void |
RestApiFilter.filterConnection(String commandLine,
TcpIpConnection connection) |
Constructor and Description |
---|
MemcacheTextDecoder(TcpIpConnection connection,
TextEncoder encoder,
boolean rootDecoder) |
RestApiTextDecoder(TcpIpConnection connection,
TextEncoder encoder,
boolean rootDecoder) |
TextDecoder(TcpIpConnection connection,
TextEncoder encoder,
com.hazelcast.nio.ascii.TextProtocolFilter textProtocolFilter,
TextParsers textParsers,
boolean rootDecoder) |
TextEncoder(TcpIpConnection connection) |
Modifier and Type | Field and Description |
---|---|
protected TcpIpConnection |
PacketDecoder.connection |
Modifier and Type | Method and Description |
---|---|
TcpIpConnection |
TcpIpEndpointManager.getConnection(Address address) |
TcpIpConnection |
TcpIpEndpointManager.getOrConnect(Address address) |
TcpIpConnection |
TcpIpEndpointManager.getOrConnect(Address address,
boolean silent) |
Modifier and Type | Method and Description |
---|---|
Collection<TcpIpConnection> |
TcpIpEndpointManager.getActiveConnections() |
Collection<TcpIpConnection> |
TcpIpEndpointManager.getConnections() |
EndpointManager<TcpIpConnection> |
TcpIpNetworkingService.getEndpointManager(EndpointQualifier qualifier)
Returns the respective endpoint manager based on the qualifier.
|
Modifier and Type | Method and Description |
---|---|
void |
TcpIpEndpointManager.EndpointConnectionLifecycleListener.onConnectionClose(TcpIpConnection connection,
Throwable t,
boolean silent) |
boolean |
TcpIpEndpointManager.registerConnection(Address remoteEndPoint,
TcpIpConnection connection) |
boolean |
TcpIpEndpointManager.transmit(Packet packet,
TcpIpConnection connection) |
Constructor and Description |
---|
PacketDecoder(TcpIpConnection connection,
Consumer<Packet> dst) |
Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.