| Package | Description |
|---|---|
| com.hazelcast.client.impl |
Implementation classes of the com.hazelcast.client interfaces
|
| com.hazelcast.client.impl.protocol.task |
Client tasks associated with requests.
|
| com.hazelcast.client.impl.protocol.task.atomiclong |
Client protocol tasks implementations for AtomicLong
|
| com.hazelcast.client.impl.protocol.task.atomicreference |
Client protocol tasks implementations for AtomicReference
|
| com.hazelcast.client.impl.protocol.task.cache |
Client protocol tasks implementations for JCache
|
| com.hazelcast.client.impl.protocol.task.cardinality | |
| com.hazelcast.client.impl.protocol.task.condition |
Client protocol tasks implementations for Condition
|
| com.hazelcast.client.impl.protocol.task.countdownlatch |
Client protocol tasks implementations for CountDownLatch
|
| com.hazelcast.client.impl.protocol.task.crdt.pncounter | |
| com.hazelcast.client.impl.protocol.task.dynamicconfig | |
| com.hazelcast.client.impl.protocol.task.executorservice |
Client protocol tasks implementations for ExecutorService
|
| com.hazelcast.client.impl.protocol.task.executorservice.durable | |
| com.hazelcast.client.impl.protocol.task.list |
Client protocol tasks implementations for List
|
| com.hazelcast.client.impl.protocol.task.lock |
Client protocol tasks implementations for ILock
|
| com.hazelcast.client.impl.protocol.task.map |
Client protocol tasks implementations for map
|
| com.hazelcast.client.impl.protocol.task.mapreduce |
Client protocol tasks implementations for map reduce
|
| com.hazelcast.client.impl.protocol.task.multimap |
Client protocol tasks implementations for multi map
|
| com.hazelcast.client.impl.protocol.task.queue |
Client protocol tasks implementations for Queue
|
| com.hazelcast.client.impl.protocol.task.replicatedmap |
Client protocol tasks implementations for ReplicatedMap
|
| com.hazelcast.client.impl.protocol.task.ringbuffer |
Client protocol tasks implementations for Ringbuffer
|
| com.hazelcast.client.impl.protocol.task.scheduledexecutor | |
| com.hazelcast.client.impl.protocol.task.semaphore |
Client protocol tasks implementations for Semaphore
|
| com.hazelcast.client.impl.protocol.task.set |
Client protocol tasks implementations for set
|
| com.hazelcast.client.impl.protocol.task.topic |
Client protocol tasks implementations for Topic
|
| com.hazelcast.client.impl.protocol.task.transaction |
Client protocol tasks implementations for Transaction related
|
| com.hazelcast.client.impl.protocol.task.transactionallist |
Client protocol tasks implementations for Transactional List
|
| com.hazelcast.client.impl.protocol.task.transactionalmap |
Client protocol tasks implementations for Transactional Map
|
| com.hazelcast.client.impl.protocol.task.transactionalmultimap |
Client protocol tasks implementations for Transactional MultiMap
|
| com.hazelcast.client.impl.protocol.task.transactionalqueue |
Client protocol tasks implementations for Transactional Queue
|
| com.hazelcast.client.impl.protocol.task.transactionalset |
Client protocol tasks implementations for Transactional Set
|
| com.hazelcast.cluster.impl | |
| com.hazelcast.cp.internal.client | |
| com.hazelcast.cp.internal.datastructures.atomiclong.client |
Client protocol tasks for the Raft-based AtomicLong implementation
|
| com.hazelcast.cp.internal.datastructures.atomicref.client |
Client protocol tasks for the Raft-based AtomicReference implementation
|
| com.hazelcast.cp.internal.datastructures.countdownlatch.client |
Client protocol tasks for the Raft-based CountDownLatch implementation
|
| com.hazelcast.cp.internal.datastructures.lock.client |
Client protocol tasks for the Raft-based Lock implementation
|
| com.hazelcast.cp.internal.datastructures.semaphore.client |
Client protocol tasks for the Raft-based Semaphore implementation
|
| com.hazelcast.cp.internal.datastructures.spi.client |
Contains utilities for creating Raft groups and fetching Raft group ids
from clients
|
| com.hazelcast.cp.internal.session.client |
Client protocol tasks for the Raft-based Session implementation
|
| com.hazelcast.flakeidgen.impl.client | |
| com.hazelcast.instance |
This package contains Hazelcast Instance functionality.
|
| com.hazelcast.internal.ascii |
This package contains Ascii functionality for Hazelcast.
This is required for Memcached and the REST api. |
| com.hazelcast.internal.cluster.impl |
This package contains the implementation of the cluster functionality.
|
| com.hazelcast.internal.diagnostics |
Contains functionality what is happening in a HazelcastInstance.
|
| com.hazelcast.internal.jmx |
Contains Hazelcast management bean classes.
|
| com.hazelcast.internal.partition.impl |
Contains the actual implementation of the
InternalPartitionService. |
| 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.scheduledexecutor.impl | |
| com.hazelcast.spi |
Provides interfaces/classes for the Hazelcast SPI for building distributed data structures and services.
|
| com.hazelcast.spi.impl |
Contains implementations for Hazelcast SPI.
|
| com.hazelcast.spi.impl.operationservice.impl |
Contains the code for the
InternalOperationService implementation. |
| com.hazelcast.util |
This package contains classes to support the inner workings of Hazelcast
as well as some backports of newer Java features / data structures to
support older Java versions in a clean and nice way.
|
| com.hazelcast.wan |
This package contains the WAN replication API
|
| com.hazelcast.wan.impl |
This package contains the opensource implementation of WAN replication
|
| Constructor and Description |
|---|
ClientEngineImpl(Node node) |
ClientServiceProxy(Node node) |
| Constructor and Description |
|---|
CardinalityEstimatorAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CardinalityEstimatorEstimateMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
ConditionAwaitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ConditionBeforeAwaitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ConditionSignalAllMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ConditionSignalMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
CountDownLatchAwaitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CountDownLatchCountDownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CountDownLatchGetCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CountDownLatchTrySetCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
PNCounterAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
PNCounterGetConfiguredReplicaCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
PNCounterGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
ExecutorServiceCancelOnAddressMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceCancelOnPartitionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceIsShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceSubmitToAddressMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceSubmitToPartitionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
DurableExecutorDisposeResultMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DurableExecutorIsShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DurableExecutorRetrieveAndDisposeResultMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DurableExecutorRetrieveResultMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DurableExecutorShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DurableExecutorSubmitToPartitionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
LockForceUnlockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockGetLockCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockGetRemainingLeaseTimeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockIsLockedByCurrentThreadMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockIsLockedMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockLockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockTryLockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockUnlockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
AbstractMapReduceTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceCancelMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForCustomMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForListMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForMapMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForMultiMapMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceJobProcessInformationMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
RingbufferAddAllMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferCapacityMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferHeadSequenceMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferReadManyMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferReadOneMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferRemainingCapacityMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferTailSequenceMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
SemaphoreAcquireMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreAvailablePermitsMessageTasks(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreDrainPermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreIncreasePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreInitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreReducePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreReleaseMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreTryAcquireMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
TopicAddMessageListenerMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TopicPublishMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TopicRemoveMessageListenerMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
TransactionalListAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalListRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalListSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
TransactionalMultiMapGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapPutMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapRemoveEntryMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapValueCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
TransactionalQueueOfferMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueuePeekMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueuePollMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueueSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueueTakeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
TransactionalSetAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalSetRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalSetSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
TcpIpJoiner(Node node) |
| Constructor and Description |
|---|
AbstractCPMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
AddAndGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
AlterMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ApplyMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CompareAndSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetAndAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetAndSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
ApplyMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CompareAndSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ContainsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
AwaitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CountDownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetRoundMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TrySetCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
GetLockOwnershipStateMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TryLockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
UnlockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
AcquirePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
AvailablePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ChangePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DrainPermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetSemaphoreTypeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
InitSemaphoreMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ReleasePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
CreateRaftGroupMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DestroyRaftObjectMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
CloseSessionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CreateSessionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GenerateThreadIdMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
HeartbeatSessionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Constructor and Description |
|---|
NewIdBatchMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| Modifier and Type | Field and Description |
|---|---|
protected Node |
DefaultNodeExtension.node |
Node |
HazelcastInstanceImpl.node |
| Modifier and Type | Method and Description |
|---|---|
protected Node |
HazelcastInstanceImpl.createNode(Config config,
NodeContext nodeContext) |
| Modifier and Type | Method and Description |
|---|---|
static NodeExtension |
NodeExtensionFactory.create(Node node,
List<String> extensionPriorityList)
Uses the Hazelcast ServiceLoader to discover all registered
NodeExtension classes and identify the one to instantiate and use as
the provided node's extension. |
AddressPicker |
NodeContext.createAddressPicker(Node node) |
AddressPicker |
DefaultNodeContext.createAddressPicker(Node node) |
Joiner |
NodeContext.createJoiner(Node node) |
Joiner |
DefaultNodeContext.createJoiner(Node node) |
NetworkingService |
NodeContext.createNetworkingService(Node node,
ServerSocketRegistry registry) |
NetworkingService |
DefaultNodeContext.createNetworkingService(Node node,
ServerSocketRegistry registry) |
NodeExtension |
NodeContext.createNodeExtension(Node node) |
NodeExtension |
DefaultNodeContext.createNodeExtension(Node node) |
static void |
NodeShutdownHelper.shutdownNodeByFiringEvents(Node node,
boolean terminate)
Shutdowns a node by firing lifecycle events.
|
| Constructor and Description |
|---|
DefaultNodeExtension(Node node) |
| Modifier and Type | Method and Description |
|---|---|
Node |
TextCommandServiceImpl.getNode() |
Node |
TextCommandService.getNode() |
| Constructor and Description |
|---|
TextCommandServiceImpl(Node node) |
| Modifier and Type | Field and Description |
|---|---|
protected Node |
AbstractJoiner.node |
| Modifier and Type | Method and Description |
|---|---|
static MulticastService |
MulticastService.createMulticastService(Address bindAddress,
Node node,
Config config,
ILogger logger) |
| Constructor and Description |
|---|
AbstractJoiner(Node node) |
ClusterServiceImpl(Node node,
MemberImpl localMember) |
DiscoveryJoiner(Node node,
DiscoveryService discoveryService,
boolean usePublicAddress) |
MulticastJoiner(Node node) |
NodeMulticastListener(Node node) |
SplitBrainMulticastListener(Node node,
BlockingDeque<SplitBrainJoinMessage> deque) |
| Constructor and Description |
|---|
HealthMonitor(Node node) |
| Constructor and Description |
|---|
NodeMBean(HazelcastInstance hazelcastInstance,
Node node,
ManagementService service) |
| Constructor and Description |
|---|
InternalPartitionServiceImpl(Node node) |
PartitionEventManager(Node node) |
PartitionStateManager(Node node,
InternalPartitionServiceImpl partitionService,
PartitionListener listener) |
| Constructor and Description |
|---|
LocalOperationStatsImpl(Node node) |
| Constructor and Description |
|---|
NodeIOService(Node node,
NodeEngineImpl nodeEngine) |
| Modifier and Type | Method and Description |
|---|---|
void |
ScheduledRunnableAdapter.setNode(Node node) |
| Modifier and Type | Method and Description |
|---|---|
void |
NodeAware.setNode(Node node) |
| Modifier and Type | Method and Description |
|---|---|
Node |
NodeEngineImpl.getNode() |
| Modifier and Type | Method and Description |
|---|---|
void |
BinaryOperationFactory.setNode(Node node) |
| Constructor and Description |
|---|
NodeEngineImpl(Node node) |
| Constructor and Description |
|---|
OutboundOperationHandler(Node node,
Address thisAddress,
InternalSerializationService serializationService) |
| Modifier and Type | Method and Description |
|---|---|
void |
PhoneHome.check(Node hazelcastNode) |
PhoneHome.PhoneHomeParameterCreator |
PhoneHome.createParameters(Node hazelcastNode) |
Map<String,String> |
PhoneHome.phoneHome(Node hazelcastNode) |
| Constructor and Description |
|---|
PhoneHome(Node hazelcastNode) |
| Modifier and Type | Method and Description |
|---|---|
void |
WanReplicationEndpoint.init(Node node,
WanReplicationConfig wanReplicationConfig,
WanPublisherConfig publisherConfig)
Initializes the endpoint using the given arguments.
|
| Constructor and Description |
|---|
WanReplicationServiceImpl(Node node) |
Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.