| Package | Description |
|---|---|
| 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.connection |
Provides connection interfaces/classes for com.hazelcast.client
Everything in this package and its subpackages is private.
|
| com.hazelcast.client.impl.connection.nio |
Contains classes related to New IO for com.hazelcast.client.connection
|
| 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.cache |
Client protocol tasks implementations for JCache
|
| com.hazelcast.client.impl.protocol.task.cardinality | |
| 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.map |
Client protocol tasks implementations for map
|
| com.hazelcast.client.impl.protocol.task.metrics | |
| 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.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.impl.proxy.txn |
Contains classes related to proxy for client transactions
|
| com.hazelcast.client.impl.spi |
Contains classes/interfaces related to the Hazelcast client Service Provider Interface.
|
| com.hazelcast.client.impl.spi.impl |
Provides util classes for the Hazelcast client SPI.
|
| com.hazelcast.client.impl.spi.impl.listener | |
| com.hazelcast.cp.internal.client |
Client support classes for CP subsystem
|
| 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.impl | |
| com.hazelcast.internal.ascii |
This package contains Ascii functionality for Hazelcast.
This is required for Memcached and the REST api. |
| com.hazelcast.internal.ascii.rest |
This package contains Reset functionality for Hazelcast.
|
| com.hazelcast.internal.cluster.impl |
This package contains the implementation of the cluster functionality.
|
| com.hazelcast.internal.longregister.client.task |
Client protocol tasks implementations for AtomicLong
|
| com.hazelcast.internal.nio | |
| com.hazelcast.internal.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.security |
Provides interfaces/classes for Hazelcast security implementation.
|
| com.hazelcast.spi.impl.operationservice |
Contains the
com.hazelcast.spi.impl.operationservice.InternalOperationService API. |
| com.hazelcast.spi.impl.operationservice.impl |
Contains the code for the
com.hazelcast.spi.impl.operationservice.InternalOperationService implementation. |
| 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 |
ClientConnectionManager.getActiveConnection(Address address) |
Connection |
ClientConnectionManager.getOrConnect(Address address) |
Connection |
ClientConnectionManager.getOrTriggerConnect(Address address) |
| 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.getOrTriggerConnect(Address target) |
| 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 |
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 |
|---|
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 |
|---|
ReadMetricsMessageTask(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 |
|---|
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,
HazelcastProperties properties) |
| Modifier and Type | Method and Description |
|---|---|
static ClientMessage |
ClientTransactionUtil.invoke(ClientMessage request,
Object 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 connection) |
| Constructor and Description |
|---|
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
Object objectName,
Connection connection)
Create an invocation that will be executed on given
connection. |
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
Object 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(UUID serverRegistrationId,
long callId,
Connection subscriber,
ListenerMessageCodec codec) |
| 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 | Method and Description |
|---|---|
<T extends Connection> |
Node.getEndpointManager(EndpointQualifier qualifier) |
| Modifier and Type | Method and Description |
|---|---|
default TextCommand |
CommandParser.parser(TextDecoder decoder,
String cmd,
int space,
Connection connection) |
| Modifier and Type | Method and Description |
|---|---|
protected Connection |
HttpPostCommand.getConnection() |
| Modifier and Type | Method and Description |
|---|---|
TextCommand |
HttpPostCommandParser.parser(TextDecoder decoder,
String cmd,
int space,
Connection connection) |
| Constructor and Description |
|---|
HttpPostCommand(TextDecoder decoder,
String uri,
Connection connection) |
| 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. |
| Constructor and Description |
|---|
LongRegisterAddAndGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LongRegisterDecrementAndGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LongRegisterGetAndAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LongRegisterGetAndIncrementMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LongRegisterGetAndSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LongRegisterGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LongRegisterIncrementAndGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LongRegisterSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
| 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 |
|---|---|
LoginContext |
SecurityContext.createClientLoginContext(Credentials credentials,
Connection connection)
Creates client
LoginContext. |
LoginContext |
SecurityContext.createMemberLoginContext(Credentials credentials,
Connection connection)
Creates member
LoginContext. |
| 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 © 2019 Hazelcast, Inc.. All rights reserved.