Package | Description |
---|---|
com.hazelcast.config |
Provides classes for configuring HazelcastInstance.
|
com.hazelcast.core |
Provides core API interfaces/classes.
|
com.hazelcast.instance |
This package contains Hazelcast Instance functionality.
|
com.hazelcast.nio |
This package contains classes related to New IO
|
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. |
com.hazelcast.spi |
Provides interfaces/classes for the Hazelcast SPI for building distributed data structures and services.
|
Modifier and Type | Method and Description |
---|---|
EndpointQualifier |
RestServerEndpointConfig.getQualifier() |
EndpointQualifier |
EndpointConfig.getQualifier() |
Modifier and Type | Method and Description |
---|---|
Map<EndpointQualifier,EndpointConfig> |
AdvancedNetworkConfig.getEndpointConfigs() |
Modifier and Type | Method and Description |
---|---|
AdvancedNetworkConfig |
AdvancedNetworkConfig.setEndpointConfigs(Map<EndpointQualifier,EndpointConfig> endpointConfigs) |
Modifier and Type | Method and Description |
---|---|
Map<EndpointQualifier,Address> |
Member.getAddressMap() |
Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
Member.getSocketAddress(EndpointQualifier qualifier)
Returns the socket address of this member.
|
Modifier and Type | Field and Description |
---|---|
static EndpointQualifier |
EndpointQualifier.CLIENT |
static EndpointQualifier |
EndpointQualifier.MEMBER |
static EndpointQualifier |
EndpointQualifier.MEMCACHE |
static EndpointQualifier |
EndpointQualifier.REST |
Modifier and Type | Field and Description |
---|---|
protected Map<EndpointQualifier,Address> |
AbstractMember.addressMap |
Modifier and Type | Method and Description |
---|---|
static EndpointQualifier |
EndpointQualifier.resolve(ProtocolType protocolType,
String name) |
Modifier and Type | Method and Description |
---|---|
Map<EndpointQualifier,Address> |
AbstractMember.getAddressMap() |
Map<EndpointQualifier,Address> |
AddressPicker.getPublicAddressMap() |
Map<EndpointQualifier,ServerSocketChannel> |
AddressPicker.getServerSocketChannels()
Returns all
ServerSocketChannel s of this member, mapped by corresponding EndpointQualifier |
Modifier and Type | Method and Description |
---|---|
com.hazelcast.internal.networking.InboundHandler[] |
NodeExtension.createInboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection,
IOService ioService)
Creates a InboundHandler for given Connection instance.
|
com.hazelcast.internal.networking.InboundHandler[] |
DefaultNodeExtension.createInboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection,
IOService ioService) |
com.hazelcast.internal.networking.OutboundHandler[] |
NodeExtension.createOutboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection,
IOService ioService)
Creates a OutboundHandler for given Connection instance.
|
com.hazelcast.internal.networking.OutboundHandler[] |
DefaultNodeExtension.createOutboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection,
IOService ioService) |
Address |
AddressPicker.getBindAddress(EndpointQualifier qualifier)
Returns a server socket listener address.
|
<T extends Connection> |
Node.getEndpointManager(EndpointQualifier qualifier) |
Address |
AddressPicker.getPublicAddress(EndpointQualifier qualifier)
Returns a public address to be advertised to other cluster members and clients.
|
ServerSocketChannel |
AddressPicker.getServerSocketChannel(EndpointQualifier qualifier)
Returns a server channel.
|
InetSocketAddress |
AbstractMember.getSocketAddress(EndpointQualifier qualifier) |
MemberSocketInterceptor |
NodeExtension.getSocketInterceptor(EndpointQualifier endpointQualifier)
Returns MemberSocketInterceptor for this Node if available,
otherwise returns null.
|
MemberSocketInterceptor |
DefaultNodeExtension.getSocketInterceptor(EndpointQualifier endpointQualifier) |
Constructor and Description |
---|
AbstractMember(Map<EndpointQualifier,Address> addresses,
MemberVersion version,
String uuid,
Map<String,Object> attributes,
boolean liteMember) |
Builder(Map<EndpointQualifier,Address> addresses) |
Modifier and Type | Method and Description |
---|---|
Map<EndpointQualifier,Address> |
NodeIOService.getThisAddresses() |
Map<EndpointQualifier,Address> |
IOService.getThisAddresses() |
Modifier and Type | Method and Description |
---|---|
com.hazelcast.internal.networking.InboundHandler[] |
NodeIOService.createInboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection) |
com.hazelcast.internal.networking.InboundHandler[] |
IOService.createInboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection) |
com.hazelcast.internal.networking.OutboundHandler[] |
NodeIOService.createOutboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection) |
com.hazelcast.internal.networking.OutboundHandler[] |
IOService.createOutboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection) |
EndpointManager<TcpIpConnection> |
UnifiedAggregateEndpointManager.getEndpointManager(EndpointQualifier qualifier) |
EndpointManager<T> |
NetworkingService.getEndpointManager(EndpointQualifier qualifier)
Returns the relevant
EndpointManager given an EndpointQualifier
On single-endpoint setups (legacy mode), then a View relevant to the requested Endpoint is returned which purely acts
as a facade to hide the API differences and maintain common signatures. |
EndpointManager<TcpIpConnection> |
DefaultAggregateEndpointManager.getEndpointManager(EndpointQualifier qualifier) |
Collection<Integer> |
NodeIOService.getOutboundPorts(EndpointQualifier endpointQualifier) |
Collection<Integer> |
IOService.getOutboundPorts(EndpointQualifier endpointQualifier) |
int |
NodeIOService.getSocketConnectTimeoutSeconds(EndpointQualifier endpointQualifier) |
int |
IOService.getSocketConnectTimeoutSeconds(EndpointQualifier endpointQualifier) |
MemberSocketInterceptor |
NodeIOService.getSocketInterceptor(EndpointQualifier endpointQualifier) |
MemberSocketInterceptor |
IOService.getSocketInterceptor(EndpointQualifier endpointQualifier) |
SocketInterceptorConfig |
NodeIOService.getSocketInterceptorConfig(EndpointQualifier endpointQualifier) |
SSLConfig |
NodeIOService.getSSLConfig(EndpointQualifier endpointQualifier) |
SSLConfig |
IOService.getSSLConfig(EndpointQualifier endpointQualifier) |
SymmetricEncryptionConfig |
NodeIOService.getSymmetricEncryptionConfig(EndpointQualifier endpointQualifier) |
SymmetricEncryptionConfig |
IOService.getSymmetricEncryptionConfig(EndpointQualifier endpointQualifier) |
void |
NodeIOService.interceptSocket(EndpointQualifier endpointQualifier,
Socket socket,
boolean onAccept) |
void |
IOService.interceptSocket(EndpointQualifier endpointQualifier,
Socket socket,
boolean onAccept) |
boolean |
NodeIOService.isSocketInterceptorEnabled(EndpointQualifier endpointQualifier) |
boolean |
IOService.isSocketInterceptorEnabled(EndpointQualifier endpointQualifier) |
Constructor and Description |
---|
DefaultAggregateEndpointManager(ConcurrentMap<EndpointQualifier,EndpointManager<TcpIpConnection>> endpointManagers) |
UnifiedAggregateEndpointManager(TcpIpEndpointManager unified,
Map<EndpointQualifier,EndpointManager<TcpIpConnection>> views) |
Modifier and Type | Method and Description |
---|---|
EndpointQualifier |
TcpIpEndpointManager.getEndpointQualifier() |
Modifier and Type | Method and Description |
---|---|
EndpointManager<TcpIpConnection> |
TcpIpNetworkingService.getEndpointManager(EndpointQualifier qualifier)
Returns the respective endpoint manager based on the qualifier.
|
com.hazelcast.internal.networking.ChannelInitializer |
DefaultChannelInitializerProvider.provide(EndpointQualifier qualifier) |
Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
MemberAddressProvider.getBindAddress(EndpointQualifier qualifier) |
InetSocketAddress |
MemberAddressProvider.getPublicAddress(EndpointQualifier qualifier) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.