| Modifier and Type | Method and Description |
|---|---|
DiscoveryCustomMessage |
DiscoveryCustomEvent.customMessage() |
| Modifier and Type | Method and Description |
|---|---|
void |
DiscoveryCustomEvent.customMessage(DiscoveryCustomMessage customMsg) |
static boolean |
DiscoveryCustomEvent.requiresCentralizedAffinityAssignment(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 |
|---|---|
DiscoveryCustomMessage |
DiscoveryCustomMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
CustomMessageWrapper.delegate() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDiscoveryManager.sendCustomEvent(DiscoveryCustomMessage msg) |
| 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 |
|---|---|
DiscoveryCustomMessage |
UserProposedMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
UserAcceptedMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CacheAffinityChangeMessage |
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 |
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 |
|---|---|
DiscoveryCustomMessage |
WalStateAbstractMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
ClientCacheChangeDummyDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
TxTimeoutOnPartitionMapExchangeChangeMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
ClientCacheChangeDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
DynamicCacheChangeBatch.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
CacheAffinityChangeMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
CacheStatisticsModeChangeMessage.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,
DiscoveryCustomMessage customMsg,
ClusterNode node,
AffinityTopologyVersion topVer,
DiscoveryDataClusterState state) |
| Modifier and Type | Class and Description |
|---|---|
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 |
|---|---|
DiscoveryCustomMessage |
MetadataUpdateAcceptedMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
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 |
|---|---|
DiscoveryCustomMessage |
ChangeGlobalStateMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
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 |
class |
StartRoutineDiscoveryMessageV2 |
class |
StopRoutineAckDiscoveryMessage |
class |
StopRoutineDiscoveryMessage |
| Modifier and Type | Method and Description |
|---|---|
DiscoveryCustomMessage |
StartRoutineDiscoveryMessageV2.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
StopRoutineAckDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
StartRoutineAckDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
StartRoutineDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
StopRoutineDiscoveryMessage.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 |
|---|---|
DiscoveryCustomMessage |
MappingAcceptedMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
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 |
|---|---|
DiscoveryCustomMessage |
SchemaProposeDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
DiscoveryCustomMessage |
SchemaFinishDiscoveryMessage.ackMessage()
Called when custom message has been handled by all nodes.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 2.6.0 Release Date : July 10 2018