| Package | Description |
|---|---|
| org.apache.ignite.internal.events | |
| org.apache.ignite.internal.managers.discovery |
TODO.
|
| org.apache.ignite.internal.processors.authentication | |
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.cache.binary |
Implementation of binary processor.
|
| org.apache.ignite.internal.processors.cache.persistence.snapshot | |
| org.apache.ignite.internal.processors.cluster | |
| org.apache.ignite.internal.processors.continuous | |
| org.apache.ignite.internal.processors.marshaller | |
| org.apache.ignite.internal.processors.query.schema.message | |
| org.apache.ignite.internal.processors.service | |
| org.apache.ignite.internal.util.distributed | |
| org.apache.ignite.spi.communication.tcp.internal |
Contains connection health-checkers for TCP/IP-based implementation of communication SPI.
|
| Modifier and Type | Method and Description |
|---|---|
DiscoveryCustomMessage |
DiscoveryCustomEvent.customMessage() |
| Modifier and Type | Method and Description |
|---|---|
void |
DiscoveryCustomEvent.customMessage(DiscoveryCustomMessage customMsg) |
static boolean |
DiscoveryCustomEvent.requiresCentralizedAffinityAssignment(@Nullable DiscoveryCustomMessage msg) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
CustomEventListener<T extends DiscoveryCustomMessage>
Listener interface.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
DiscoveryServerOnlyCustomMessage
DiscoveryServerOnlyCustomMessage is the special subtype of the DiscoveryCustomMessage message
that is delivered only on server nodes of the cluster.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends DiscoveryCustomMessage> |
GridDiscoveryManager.setCustomEventListener(Class<T> msgCls,
CustomEventListener<T> lsnr) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoveryCustomMessage |
DiscoveryCustomMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
CustomMessageWrapper.delegate() |
@NotNull DiscoveryCustomMessage |
IncompleteDeserializationException.message() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDiscoveryManager.sendCustomEvent(DiscoveryCustomMessage msg) |
| Constructor and Description |
|---|
CustomMessageWrapper(DiscoveryCustomMessage delegate) |
IncompleteDeserializationException(@NotNull DiscoveryCustomMessage m) |
| Modifier and Type | Class and Description |
|---|---|
class |
UserAcceptedMessage
Is sent as an acknowledgement for end (with success or error) of user management operation on the cluster
(see
UserProposedMessage and UserManagementOperation). |
class |
UserProposedMessage
A node sends this message when it wants to propose user operation (add / update / remove).
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoveryCustomMessage |
UserAcceptedMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
UserProposedMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CacheAffinityChangeMessage |
class |
CacheStatisticsClearMessage
Cache statistics clear discovery message.
|
class |
CacheStatisticsModeChangeMessage
Cache statistics mode change discovery message.
|
class |
ClientCacheChangeDiscoveryMessage
Sent from cache client node to asynchronously notify about started.closed client caches.
|
class |
ClientCacheChangeDummyDiscoveryMessage
Dummy discovery message which is not really sent via ring, it is just added in local discovery worker queue.
|
class |
DynamicCacheChangeBatch
Cache change batch.
|
class |
DynamicCacheChangeFailureMessage
This class represents discovery message that is used to provide information about dynamic cache start failure.
|
class |
TxTimeoutOnPartitionMapExchangeChangeMessage
Discovery message for changing transaction timeout on partition map exchange.
|
class |
WalStateAbstractMessage
WAL state change abstract message.
|
class |
WalStateFinishMessage
WAL state finish message.
|
class |
WalStateProposeMessage
WAL state propose message.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoveryCustomMessage |
CacheStatisticsClearMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
DynamicCacheChangeBatch.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
DynamicCacheChangeFailureMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
CacheAffinityChangeMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
TxTimeoutOnPartitionMapExchangeChangeMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
ClientCacheChangeDummyDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
CacheStatisticsModeChangeMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
WalStateAbstractMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
ClientCacheChangeDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
| Modifier and Type | Method and Description |
|---|---|
CachePartitionExchangeWorkerTask |
GridCacheProcessor.exchangeTaskForCustomDiscoveryMessage(DiscoveryCustomMessage msg)
Create exchange worker task for custom discovery message.
|
boolean |
GridCacheProcessor.onCustomEvent(DiscoveryCustomMessage msg,
AffinityTopologyVersion topVer,
ClusterNode node)
Callback invoked from discovery thread when discovery custom message is received.
|
void |
GridCacheProcessor.onDiscoveryEvent(int type,
@Nullable DiscoveryCustomMessage customMsg,
ClusterNode node,
AffinityTopologyVersion topVer,
DiscoveryDataClusterState state) |
| Modifier and Type | Class and Description |
|---|---|
class |
MetadataRemoveAcceptedMessage
Acknowledge message for
MetadataRemoveProposedMessage: see its javadoc for detailed description of protocol. |
class |
MetadataRemoveProposedMessage
MetadataRemoveProposedMessage and
MetadataRemoveAcceptedMessage messages make a basis for
discovery-based protocol for manage metadata describing objects in binary format
stored in Ignite caches. |
class |
MetadataUpdateAcceptedMessage
Acknowledge message for
MetadataUpdateProposedMessage: see its javadoc for detailed description of protocol. |
class |
MetadataUpdateProposedMessage
MetadataUpdateProposedMessage and
MetadataUpdateAcceptedMessage messages make a basis for
discovery-based protocol for exchanging metadata describing objects in binary format stored in Ignite caches. |
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoveryCustomMessage |
MetadataUpdateAcceptedMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
MetadataRemoveAcceptedMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
MetadataRemoveProposedMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
MetadataUpdateProposedMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
SnapshotDiscoveryMessage
Initial snapshot discovery message with possibility to trigger exchange.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ChangeGlobalStateFinishMessage |
class |
ChangeGlobalStateMessage
Message represent request for change cluster global state.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoveryCustomMessage |
ChangeGlobalStateMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
ChangeGlobalStateFinishMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractContinuousMessage |
class |
StartRoutineAckDiscoveryMessage |
class |
StartRoutineDiscoveryMessage
Discovery message used for Continuous Query registration.
|
class |
StartRoutineDiscoveryMessageV2 |
class |
StopRoutineAckDiscoveryMessage |
class |
StopRoutineDiscoveryMessage |
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoveryCustomMessage |
StopRoutineAckDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
StopRoutineDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
StartRoutineAckDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
StartRoutineDiscoveryMessageV2.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
StartRoutineDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MappingAcceptedMessage
Is sent as an acknowledgement for successfully proposed new mapping (see
MappingProposedMessage). |
class |
MappingProposedMessage
Node sends this message when it wants to propose new marshaller mapping and to ensure that there are no conflicts
with this mapping on other nodes in cluster.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoveryCustomMessage |
MappingAcceptedMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
MappingProposedMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SchemaAbstractDiscoveryMessage
Abstract discovery message for schema operations.
|
class |
SchemaFinishDiscoveryMessage
Schema change finish discovery message.
|
class |
SchemaProposeDiscoveryMessage
Schema change propose discovery message.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoveryCustomMessage |
SchemaFinishDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
SchemaProposeDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ServiceChangeBatchRequest
Service change batch request discovery message.
|
class |
ServiceClusterDeploymentResultBatch
Batch of services cluster deployment result.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoveryCustomMessage |
ServiceChangeBatchRequest.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
ServiceClusterDeploymentResultBatch.ackMessage()
Called when custom message has been handled by all nodes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FullMessage<R extends Serializable>
Full process message.
|
class |
InitMessage<I extends Serializable>
Initiate message.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoveryCustomMessage |
FullMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
@Nullable DiscoveryCustomMessage |
InitMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TcpConnectionRequestDiscoveryMessage
Message is part of communication via discovery protocol.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoveryCustomMessage |
TcpConnectionRequestDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.1 Release Date : December 9 2020