Package | Description |
---|---|
com.hazelcast.client.connection |
Provides connection interfaces/classes for com.hazelcast.client
Everything in this package and its subpackages is private.
|
com.hazelcast.client.connection.nio |
Contains classes related to New IO for com.hazelcast.client.connection
|
com.hazelcast.client.impl |
Implementation classes of the com.hazelcast.client interfaces
|
com.hazelcast.client.impl.clientside |
Contains most of the client side HazelcastInstance implementation functionality.
|
com.hazelcast.client.impl.protocol |
Client protocol related private implementation classes
|
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.client.impl.protocol.util |
Protocol utils
|
com.hazelcast.client.proxy.txn |
Contains classes related to proxy for client transactions
|
com.hazelcast.client.spi |
Contains classes/interfaces related to the Hazelcast client Service Provider Interface.
|
com.hazelcast.client.spi.impl |
Provides util classes for the Hazelcast client SPI.
|
com.hazelcast.client.spi.impl.listener | |
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.cluster.impl |
This package contains the implementation of the cluster functionality.
|
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.
|
com.hazelcast.spi.impl.operationservice.impl |
Contains the code for the
InternalOperationService implementation. |
Modifier and Type | Method and Description |
---|---|
Connection |
ClientConnectionManager.getActiveConnection(Address address) |
Connection |
ClientConnectionManager.getOrConnect(Address address) |
Connection |
ClientConnectionManager.getOrTriggerConnect(Address address,
boolean acquiresResource) |
Modifier and Type | Class and Description |
---|---|
class |
ClientConnection
Client implementation of
Connection . |
Modifier and Type | Method and Description |
---|---|
Connection |
ClientConnectionManagerImpl.getActiveConnection(Address target) |
Connection |
ClientConnectionManagerImpl.getOrConnect(Address address) |
Connection |
ClientConnectionManagerImpl.getOrConnect(Address address,
boolean asOwner) |
Connection |
ClientConnectionManagerImpl.getOrTriggerConnect(Address target,
boolean acquiresResources) |
Modifier and Type | Method and Description |
---|---|
void |
ClientICMPManager.connectionAdded(Connection connection) |
void |
ClusterConnectorServiceImpl.connectionAdded(Connection connection) |
void |
ClientICMPManager.connectionRemoved(Connection connection) |
void |
ClusterConnectorServiceImpl.connectionRemoved(Connection connection) |
Modifier and Type | Method and Description |
---|---|
Connection |
ClientEndpointImpl.getConnection() |
Connection |
ClientEndpoint.getConnection() |
Modifier and Type | Method and Description |
---|---|
MessageTask |
CompositeMessageTaskFactory.create(ClientMessage clientMessage,
Connection connection) |
ClientEndpoint |
ClientEndpointManager.getEndpoint(Connection connection)
Gets the endpoint for a given connection.
|
ClientEndpoint |
ClientEndpointManagerImpl.getEndpoint(Connection connection) |
Constructor and Description |
---|
ClientEndpointImpl(ClientEngine clientEngine,
NodeEngineImpl nodeEngine,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
void |
HazelcastClientInstanceImpl.onClusterConnect(Connection ownerConnection) |
Modifier and Type | Method and Description |
---|---|
Connection |
ClientMessage.getConnection() |
Modifier and Type | Method and Description |
---|---|
MessageTask |
MessageTaskFactory.create(ClientMessage clientMessage,
Connection connection) |
void |
ClientMessage.setConnection(Connection connection) |
Modifier and Type | Field and Description |
---|---|
protected Connection |
AbstractMessageTask.connection |
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 |
---|
ClientMessageDecoder(Connection connection,
Consumer<ClientMessage> dst) |
Modifier and Type | Method and Description |
---|---|
static ClientMessage |
ClientTransactionUtil.invoke(ClientMessage request,
String objectName,
HazelcastClientInstanceImpl client,
Connection connection)
Handles the invocation exception for transactions so that users will not see internal exceptions.
|
Modifier and Type | Method and Description |
---|---|
void |
ProxyManager.createDistributedObjectsOnCluster(Connection ownerConnection) |
Modifier and Type | Method and Description |
---|---|
void |
ClientUserCodeDeploymentService.deploy(HazelcastClientInstanceImpl client,
Connection ownerConnection) |
void |
ClientClusterServiceImpl.listenMembershipEvents(Connection ownerConnection) |
void |
ClientPartitionServiceImpl.listenPartitionTable(Connection ownerConnection) |
Constructor and Description |
---|
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
String objectName,
Connection connection)
Create an invocation that will be executed on given
connection . |
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
String objectName,
int partitionId,
Address address,
Connection connection) |
Modifier and Type | Field and Description |
---|---|
protected Map<ClientRegistrationKey,Map<Connection,ClientEventRegistration>> |
AbstractClientListenerService.registrations |
Modifier and Type | Method and Description |
---|---|
Connection |
ClientEventRegistration.getSubscriber()
This is used when removing the listener.
|
Modifier and Type | Method and Description |
---|---|
Map<ClientRegistrationKey,Map<Connection,ClientEventRegistration>> |
AbstractClientListenerService.getRegistrations() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractClientListenerService.connectionAdded(Connection connection) |
void |
AbstractClientListenerService.connectionRemoved(Connection connection) |
protected void |
AbstractClientListenerService.invoke(ClientRegistrationKey registrationKey,
Connection connection) |
Constructor and Description |
---|
ClientEventRegistration(String serverRegistrationId,
long callId,
Connection subscriber,
ListenerMessageCodec codec) |
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 | Method and Description |
---|---|
<T extends Connection> |
Node.getEndpointManager(EndpointQualifier qualifier) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterJoinManager.answerWhoisMasterQuestion(JoinMessage joinMessage,
Connection connection)
Respond to a
WhoisMasterOp . |
void |
ClusterServiceImpl.connectionAdded(Connection connection) |
void |
ClusterServiceImpl.connectionRemoved(Connection connection) |
void |
ClusterJoinManager.handleJoinRequest(JoinRequest joinRequest,
Connection connection)
Handle a
JoinRequestOp . |
Modifier and Type | Interface and Description |
---|---|
interface |
ConnectionLifecycleListener<T extends Connection> |
interface |
EndpointManager<T extends Connection>
Responsible for managing
Connection objects. |
interface |
NetworkingService<T extends Connection>
Networking service, it initializes the endpoints, the acceptor and the reactive networking stack
Given an
EndpointQualifier an EndpointManager can be retrieved
by NetworkingService.getEndpointManager(EndpointQualifier) to create or get connections on that end. |
Modifier and Type | Method and Description |
---|---|
Connection |
Packet.getConn()
Gets the Connection this Packet was send with.
|
Modifier and Type | Method and Description |
---|---|
static void |
IOUtil.close(Connection conn,
String reason) |
void |
ConnectionListener.connectionAdded(Connection connection) |
void |
ConnectionListener.connectionRemoved(Connection connection) |
Packet |
Packet.setConn(Connection conn)
Sets the Connection this Packet is send with.
|
Modifier and Type | Class and Description |
---|---|
class |
TcpIpConnection
The Tcp/Ip implementation of the
Connection . |
Modifier and Type | Method and Description |
---|---|
Connection |
Operation.getConnection() |
Modifier and Type | Method and Description |
---|---|
static void |
OperationAccessor.setConnection(Operation op,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
boolean |
OutboundOperationHandler.send(Operation op,
Connection connection) |
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.