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.internal.cluster |
Contains the internals for cluster management like discovery, joining etc.
|
com.hazelcast.internal.cluster.impl |
This package contains the implementation of the cluster functionality.
|
com.hazelcast.internal.networking |
Contains the socket connection functionality.
|
com.hazelcast.internal.networking.nio |
Contains the non blocking
Networking functionality. |
com.hazelcast.monitor.impl |
Contains Hazelcast statistics implementations related to map, queue, topic, multimap, executor service etc.
|
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 |
EndpointConfig.getQualifier() |
EndpointQualifier |
RestServerEndpointConfig.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 |
---|---|
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.
|
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 |
DefaultNodeExtension.getSocketInterceptor(EndpointQualifier endpointQualifier) |
MemberSocketInterceptor |
NodeExtension.getSocketInterceptor(EndpointQualifier endpointQualifier)
Returns MemberSocketInterceptor for this Node if available,
otherwise returns null.
|
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> |
MemberInfo.getAddressMap() |
Constructor and Description |
---|
MemberInfo(Address address,
String uuid,
Map<String,Object> attributes,
boolean liteMember,
MemberVersion version,
int memberListJoinVersion,
Map<EndpointQualifier,Address> addressMap) |
MemberInfo(Address address,
String uuid,
Map<String,Object> attributes,
boolean liteMember,
MemberVersion version,
Map<EndpointQualifier,Address> addressMap) |
Constructor and Description |
---|
JoinRequest(byte packetVersion,
int buildNumber,
MemberVersion version,
Address address,
String uuid,
boolean liteMember,
ConfigCheck config,
Credentials credentials,
Map<String,Object> attributes,
Set<String> excludedMemberUuids,
Map<EndpointQualifier,Address> addresses) |
Modifier and Type | Method and Description |
---|---|
EndpointQualifier |
ServerSocketRegistry.Pair.getQualifier() |
Modifier and Type | Method and Description |
---|---|
ChannelInitializer |
ChannelInitializerProvider.provide(EndpointQualifier qualifier) |
Channel |
Networking.register(EndpointQualifier endpointQualifier,
ChannelInitializerProvider channelInitializerProvider,
SocketChannel socketChannel,
boolean clientMode)
Registers the SocketChannel to the EventLoop group and returns the
created Channel.
|
Constructor and Description |
---|
ServerSocketRegistry(Map<EndpointQualifier,ServerSocketChannel> map,
boolean unifiedSocket) |
Modifier and Type | Method and Description |
---|---|
Channel |
NioNetworking.register(EndpointQualifier endpointQualifier,
ChannelInitializerProvider channelInitializerProvider,
SocketChannel socketChannel,
boolean clientMode) |
Modifier and Type | Method and Description |
---|---|
Map<EndpointQualifier,Address> |
MemberStateImpl.getEndpoints() |
Modifier and Type | Method and Description |
---|---|
void |
MemberStateImpl.setEndpoints(Map<EndpointQualifier,Address> addressMap) |
Modifier and Type | Method and Description |
---|---|
Map<EndpointQualifier,Address> |
NodeIOService.getThisAddresses() |
Map<EndpointQualifier,Address> |
IOService.getThisAddresses() |
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 |
---|---|
protected Map<EndpointQualifier,ChannelInitializer> |
DefaultChannelInitializerProvider.buildInitializersMap(Config config) |
Modifier and Type | Method and Description |
---|---|
EndpointManager<TcpIpConnection> |
TcpIpNetworkingService.getEndpointManager(EndpointQualifier qualifier)
Returns the respective endpoint manager based on the qualifier.
|
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.