Package | Description |
---|---|
com.hazelcast.client.impl |
Contains most of the client side HazelcastInstance implementation functionality.
|
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.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.executorservice |
Client protocol tasks implementations for ExecutorService
|
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.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 |
This package contains the implementation of the cluster functionality.
|
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.jmx |
Contains Hazelcast management bean classes.
|
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.partition.impl |
Contains the actual implementation of the
InternalPartitionService . |
com.hazelcast.spi |
Provides interfaces/classes for Hazelcast SPI.
|
com.hazelcast.spi.impl |
Contains implementations for Hazelcast SPI.
|
com.hazelcast.spi.impl.transceiver.impl |
Contains the implementation of the
PacketTransceiver . |
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 |
---|
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 |
---|
AbstractExecutorServiceCancelMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
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 |
---|
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 |
---|
SemaphoreAcquireMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreAvailablePermitsMessageTasks(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreDrainPermitsMessageTask(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) |
Modifier and Type | Field and Description |
---|---|
protected Node |
AbstractJoiner.node |
Constructor and Description |
---|
AbstractJoiner(Node node) |
ClusterServiceImpl(Node node) |
MulticastJoiner(Node node) |
MulticastService(Node node,
MulticastSocket multicastSocket) |
NodeMulticastListener(Node node) |
TcpIpJoiner(Node node) |
TcpIpJoinerOverAWS(Node node) |
Modifier and Type | Field and Description |
---|---|
protected Node |
DefaultNodeExtension.node |
Node |
HazelcastInstanceImpl.node |
Modifier and Type | Method and Description |
---|---|
void |
DefaultNodeExtension.afterStart(Node node) |
void |
NodeExtension.afterStart(Node node)
Called after node is started
|
void |
DefaultNodeExtension.beforeStart(Node node) |
void |
NodeExtension.beforeStart(Node node)
Called before node is started
|
AddressPicker |
NodeContext.createAddressPicker(Node node) |
AddressPicker |
DefaultNodeContext.createAddressPicker(Node node) |
ConnectionManager |
NodeContext.createConnectionManager(Node node,
ServerSocketChannel serverSocketChannel) |
ConnectionManager |
DefaultNodeContext.createConnectionManager(Node node,
ServerSocketChannel serverSocketChannel) |
Joiner |
NodeContext.createJoiner(Node node) |
Joiner |
DefaultNodeContext.createJoiner(Node node) |
MessageTaskFactory |
DefaultNodeExtension.createMessageTaskFactory(Node node) |
MessageTaskFactory |
NodeExtension.createMessageTaskFactory(Node node)
Creates factory method that creates server side client message handlers
|
void |
DefaultNodeExtension.printNodeInfo(Node node) |
void |
NodeExtension.printNodeInfo(Node node)
Called to print node information during startup
|
static void |
NodeShutdownHelper.shutdownNodeByFiringEvents(Node node,
boolean terminate)
Shutdowns a node by firing lifecycle events.
|
Modifier and Type | Method and Description |
---|---|
Node |
TextCommandServiceImpl.getNode() |
Node |
TextCommandService.getNode() |
Constructor and Description |
---|
TextCommandServiceImpl(Node node) |
Constructor and Description |
---|
NodeMBean(HazelcastInstance hazelcastInstance,
Node node,
ManagementService service) |
Constructor and Description |
---|
LocalOperationStatsImpl(Node node) |
Constructor and Description |
---|
NodeIOService(Node node,
NodeEngineImpl nodeEngine) |
Modifier and Type | Method and Description |
---|---|
Node |
InternalPartitionServiceImpl.getNode() |
Constructor and Description |
---|
InternalPartitionServiceImpl(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 |
---|
PacketTransceiverImpl(Node node,
ILogger logger,
InternalOperationService operationService,
InternalEventService eventService,
WanReplicationService wanReplicationService,
ExecutionService executionService) |
Modifier and Type | Method and Description |
---|---|
void |
VersionCheck.check(Node hazelcastNode,
String version,
boolean isEnterprise) |
Map<String,String> |
VersionCheck.doCheck(Node hazelcastNode,
String version,
boolean isEnterprise) |
Modifier and Type | Method and Description |
---|---|
void |
WanReplicationEndpoint.init(Node node,
String groupName,
String password,
String... targets)
Initializes the endpoint using the given arguments.
|
Modifier and Type | Method and Description |
---|---|
void |
WanNoDelayReplication.init(Node node,
String groupName,
String password,
String... targets) |
Constructor and Description |
---|
WanReplicationServiceImpl(Node node) |
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.