Package | Description |
---|---|
com.hazelcast.client.impl |
Implementation classes of the com.hazelcast.client interfaces
|
com.hazelcast.client.impl.protocol.util |
Protocol utils
|
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.impl |
Contains implementations for Hazelcast SPI.
|
com.hazelcast.spi.impl.eventservice |
Contains the code for the
InternalEventService . |
com.hazelcast.spi.impl.eventservice.impl |
Contains the code for the
InternalEventService implementation. |
com.hazelcast.spi.impl.operationexecutor |
Contains the
OperationRunner code. |
com.hazelcast.spi.impl.operationexecutor.impl |
Contains the
OperationExecutorImpl code. |
com.hazelcast.spi.impl.operationservice.impl |
Contains the code for the
InternalOperationService implementation. |
com.hazelcast.util.collection |
The Agrona project backport: collections.
|
com.hazelcast.wan.merkletree |
This package contains Merkle tree based anti-entropy implementation
|
Modifier and Type | Interface and Description |
---|---|
interface |
ClientEngine
The client Engine.
|
Modifier and Type | Class and Description |
---|---|
class |
ClientEngineImpl
Class that requests, listeners from client handled in node side.
|
Constructor and Description |
---|
ClientMessageDecoder(Connection connection,
Consumer<ClientMessage> dst) |
Modifier and Type | Class and Description |
---|---|
class |
TcpIpConnectionManager |
Constructor and Description |
---|
PacketDecoder(TcpIpConnection connection,
Consumer<Packet> dst) |
Modifier and Type | Class and Description |
---|---|
class |
PacketDispatcher
|
Modifier and Type | Method and Description |
---|---|
Consumer<Packet> |
NodeEngineImpl.getPacketDispatcher() |
Constructor and Description |
---|
PacketDispatcher(ILogger logger,
Consumer<Packet> operationExecutor,
Consumer<Packet> responseHandler,
Consumer<Packet> invocationMonitor,
Consumer<Packet> eventService,
Consumer<Packet> connectionManager,
Consumer<Packet> jetService) |
PacketDispatcher(ILogger logger,
Consumer<Packet> operationExecutor,
Consumer<Packet> responseHandler,
Consumer<Packet> invocationMonitor,
Consumer<Packet> eventService,
Consumer<Packet> connectionManager,
Consumer<Packet> jetService) |
PacketDispatcher(ILogger logger,
Consumer<Packet> operationExecutor,
Consumer<Packet> responseHandler,
Consumer<Packet> invocationMonitor,
Consumer<Packet> eventService,
Consumer<Packet> connectionManager,
Consumer<Packet> jetService) |
PacketDispatcher(ILogger logger,
Consumer<Packet> operationExecutor,
Consumer<Packet> responseHandler,
Consumer<Packet> invocationMonitor,
Consumer<Packet> eventService,
Consumer<Packet> connectionManager,
Consumer<Packet> jetService) |
PacketDispatcher(ILogger logger,
Consumer<Packet> operationExecutor,
Consumer<Packet> responseHandler,
Consumer<Packet> invocationMonitor,
Consumer<Packet> eventService,
Consumer<Packet> connectionManager,
Consumer<Packet> jetService) |
PacketDispatcher(ILogger logger,
Consumer<Packet> operationExecutor,
Consumer<Packet> responseHandler,
Consumer<Packet> invocationMonitor,
Consumer<Packet> eventService,
Consumer<Packet> connectionManager,
Consumer<Packet> jetService) |
Modifier and Type | Interface and Description |
---|---|
interface |
InternalEventService
The InternalEventService is an
EventService interface that adds additional capabilities
we don't want to expose to the end user. |
Modifier and Type | Class and Description |
---|---|
class |
EventServiceImpl
Service responsible for routing and dispatching local and remote events and keeping track of listener
registrations.
|
Modifier and Type | Interface and Description |
---|---|
interface |
OperationExecutor
The OperationExecutor is responsible for scheduling work (packets/operations)
to be executed.
|
Modifier and Type | Class and Description |
---|---|
class |
OperationExecutorImpl
A
OperationExecutor that schedules:
partition specific operations to a specific partition-operation-thread (using a mod on the partition ID)
non specific operations to generic-operation-threads
The OperationExecutorImpl.execute(Object, int, boolean) accepts an Object instead of a runnable to prevent needing to
create wrapper runnables around tasks. |
Modifier and Type | Class and Description |
---|---|
class |
InboundResponseHandler
Responsible for handling responses for invocations.
|
class |
InvocationMonitor
The InvocationMonitor monitors all pending invocations and determines if there are any problems like timeouts.
|
Modifier and Type | Method and Description |
---|---|
Consumer<Packet> |
InboundResponseHandlerSupplier.get() |
Modifier and Type | Method and Description |
---|---|
void |
BiInt2ObjectMap.forEach(Consumer<V> consumer)
Iterate over the values in the map
|
Modifier and Type | Method and Description |
---|---|
void |
MerkleTree.forEachKeyOfNode(int nodeOrder,
Consumer<Object> consumer)
Performs the given action for each key of the specified node
until all elements have been processed or the action throws an
exception.
|
void |
ArrayMerkleTree.forEachKeyOfNode(int nodeOrder,
Consumer<Object> consumer) |
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.