Package | Description |
---|---|
com.hazelcast.client.impl.protocol.util |
Protocol utils
|
com.hazelcast.instance |
This package contains Hazelcast Instance functionality.
|
com.hazelcast.internal.networking |
Contains the socket connection functionality.
|
com.hazelcast.internal.networking.nio |
Contains the non blocking
Networking 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 | Class and Description |
---|---|
class |
ClientMessageDecoder
Builds
ClientMessage s from byte chunks. |
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.
|
Modifier and Type | Method and Description |
---|---|
InboundPipeline |
InboundPipeline.addLast(InboundHandler... handlers)
Adds the handlers at the end of the pipeline.
|
InboundPipeline |
InboundPipeline.remove(InboundHandler handler)
Removes the given handler from the pipeline.
|
InboundPipeline |
InboundPipeline.replace(InboundHandler oldHandler,
InboundHandler... newHandlers)
Replaces the old InboundHandler by the new ones.
|
InboundPipeline |
InboundPipeline.replace(InboundHandler oldHandler,
InboundHandler... newHandlers)
Replaces the old InboundHandler by the new ones.
|
Modifier and Type | Class and Description |
---|---|
class |
InboundHandlerWithCounters<S,D>
Trigger for the ChannelReader to inject the appropriate counters.
|
Modifier and Type | Method and Description |
---|---|
InboundPipeline |
NioInboundPipeline.addLast(InboundHandler... addedHandlers) |
InboundPipeline |
NioInboundPipeline.remove(InboundHandler handler) |
InboundPipeline |
NioInboundPipeline.replace(InboundHandler oldHandler,
InboundHandler... addedHandlers) |
InboundPipeline |
NioInboundPipeline.replace(InboundHandler oldHandler,
InboundHandler... addedHandlers) |
Modifier and Type | Method and Description |
---|---|
InboundHandler[] |
NodeIOService.createInboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection) |
InboundHandler[] |
IOService.createInboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection) |
Modifier and Type | Class and Description |
---|---|
class |
MemcacheTextDecoder |
class |
RestApiTextDecoder |
class |
TextDecoder |
Modifier and Type | Class and Description |
---|---|
class |
PacketDecoder
The
InboundHandler for member to member communication. |
class |
SingleProtocolDecoder |
class |
TextHandshakeDecoder |
class |
UnifiedProtocolDecoder
A
InboundHandler that reads the protocol bytes
Protocols and based on the protocol it creates the
appropriate handlers. |
Modifier and Type | Field and Description |
---|---|
protected InboundHandler[] |
SingleProtocolDecoder.inboundHandlers |
Constructor and Description |
---|
SingleProtocolDecoder(ProtocolType supportedProtocol,
InboundHandler next) |
SingleProtocolDecoder(ProtocolType supportedProtocol,
InboundHandler[] next,
MemberProtocolEncoder encoder)
Decodes first 3 incoming bytes, validates against
supportedProtocol and, when
matching, replaces itself in the inbound pipeline with the next InboundHandler s. |
TextHandshakeDecoder(ProtocolType supportedProtocol,
InboundHandler next) |
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.