Package | Description |
---|---|
com.hazelcast.instance.impl | |
com.hazelcast.internal.nio | |
com.hazelcast.internal.nio.ascii |
Contains SocketTextReader and SocketTextWriter classes;
|
com.hazelcast.internal.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()
Returns all active connections from the underlying EndpointManagers.
|
Set<TcpIpConnection> |
DefaultAggregateEndpointManager.getConnections() |
Collection<TcpIpConnection> |
UnifiedAggregateEndpointManager.getConnections() |
Collection<TcpIpConnection> |
AggregateEndpointManager.getConnections()
Returns all connections that have been successfully established by the underlying EndpointManagers.
|
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.internal.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 |
ClientViewUnifiedEndpointManager.getConnection(Address address) |
TcpIpConnection |
TextViewUnifiedEndpointManager.getConnection(Address address) |
TcpIpConnection |
MemberViewUnifiedEndpointManager.getConnection(Address address) |
TcpIpConnection |
TcpIpEndpointManager.getOrConnect(Address address) |
TcpIpConnection |
ClientViewUnifiedEndpointManager.getOrConnect(Address address) |
TcpIpConnection |
TextViewUnifiedEndpointManager.getOrConnect(Address address) |
TcpIpConnection |
MemberViewUnifiedEndpointManager.getOrConnect(Address address) |
TcpIpConnection |
TcpIpEndpointManager.getOrConnect(Address address,
boolean silent) |
TcpIpConnection |
ClientViewUnifiedEndpointManager.getOrConnect(Address address,
boolean silent) |
TcpIpConnection |
TextViewUnifiedEndpointManager.getOrConnect(Address address,
boolean silent) |
TcpIpConnection |
MemberViewUnifiedEndpointManager.getOrConnect(Address address,
boolean silent) |
Modifier and Type | Method and Description |
---|---|
Collection<TcpIpConnection> |
TcpIpEndpointManager.getActiveConnections() |
Set<TcpIpConnection> |
ClientViewUnifiedEndpointManager.getActiveConnections() |
Set<TcpIpConnection> |
TextViewUnifiedEndpointManager.getActiveConnections() |
Collection<TcpIpConnection> |
MemberViewUnifiedEndpointManager.getActiveConnections() |
Collection<TcpIpConnection> |
TcpIpEndpointManager.getConnections() |
Collection<TcpIpConnection> |
ClientViewUnifiedEndpointManager.getConnections() |
Collection<TcpIpConnection> |
TextViewUnifiedEndpointManager.getConnections() |
Collection<TcpIpConnection> |
MemberViewUnifiedEndpointManager.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 |
ClientViewUnifiedEndpointManager.registerConnection(Address address,
TcpIpConnection connection) |
boolean |
TextViewUnifiedEndpointManager.registerConnection(Address remoteEndPoint,
TcpIpConnection connection) |
boolean |
MemberViewUnifiedEndpointManager.registerConnection(Address address,
TcpIpConnection connection) |
boolean |
TcpIpEndpointManager.transmit(Packet packet,
TcpIpConnection connection) |
boolean |
ClientViewUnifiedEndpointManager.transmit(Packet packet,
TcpIpConnection connection) |
boolean |
TextViewUnifiedEndpointManager.transmit(Packet packet,
TcpIpConnection connection) |
boolean |
MemberViewUnifiedEndpointManager.transmit(Packet packet,
TcpIpConnection connection) |
Constructor and Description |
---|
PacketDecoder(TcpIpConnection connection,
Consumer<Packet> dst) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.