Uses of Interface
org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage
-
Packages that use DiscoveryCustomMessage 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. -
-
Uses of DiscoveryCustomMessage in org.apache.ignite.internal.events
Methods in org.apache.ignite.internal.events that return DiscoveryCustomMessage Modifier and Type Method Description DiscoveryCustomMessageDiscoveryCustomEvent. customMessage()Methods in org.apache.ignite.internal.events with parameters of type DiscoveryCustomMessage Modifier and Type Method Description voidDiscoveryCustomEvent. customMessage(DiscoveryCustomMessage customMsg)static booleanDiscoveryCustomEvent. requiresCentralizedAffinityAssignment(@Nullable DiscoveryCustomMessage msg) -
Uses of DiscoveryCustomMessage in org.apache.ignite.internal.managers.discovery
Classes in org.apache.ignite.internal.managers.discovery with type parameters of type DiscoveryCustomMessage Modifier and Type Interface Description interfaceCustomEventListener<T extends DiscoveryCustomMessage>Listener interface.Subinterfaces of DiscoveryCustomMessage in org.apache.ignite.internal.managers.discovery Modifier and Type Interface Description interfaceDiscoveryServerOnlyCustomMessageDiscoveryServerOnlyCustomMessage is the special subtype of the DiscoveryCustomMessage message that is delivered only on server nodes of the cluster.Methods in org.apache.ignite.internal.managers.discovery with type parameters of type DiscoveryCustomMessage Modifier and Type Method Description <T extends DiscoveryCustomMessage>
voidGridDiscoveryManager. setCustomEventListener(Class<T> msgCls, CustomEventListener<T> lsnr)Methods in org.apache.ignite.internal.managers.discovery that return DiscoveryCustomMessage Modifier and Type Method Description @Nullable DiscoveryCustomMessageDiscoveryCustomMessage. ackMessage()Called when custom message has been handled by all nodes.DiscoveryCustomMessageCustomMessageWrapper. delegate()@NotNull DiscoveryCustomMessageIncompleteDeserializationException. message()Methods in org.apache.ignite.internal.managers.discovery with parameters of type DiscoveryCustomMessage Modifier and Type Method Description voidGridDiscoveryManager. sendCustomEvent(DiscoveryCustomMessage msg)Constructors in org.apache.ignite.internal.managers.discovery with parameters of type DiscoveryCustomMessage Constructor Description CustomMessageWrapper(DiscoveryCustomMessage delegate)IncompleteDeserializationException(@NotNull DiscoveryCustomMessage m)SecurityAwareCustomMessageWrapper(DiscoveryCustomMessage delegate, UUID secSubjId) -
Uses of DiscoveryCustomMessage in org.apache.ignite.internal.processors.authentication
Classes in org.apache.ignite.internal.processors.authentication that implement DiscoveryCustomMessage Modifier and Type Class Description classUserAcceptedMessageIs sent as an acknowledgement for end (with success or error) of user management operation on the cluster (seeUserProposedMessageandUserManagementOperation).classUserProposedMessageA node sends this message when it wants to propose user operation (add / update / remove).Methods in org.apache.ignite.internal.processors.authentication that return DiscoveryCustomMessage Modifier and Type Method Description @Nullable DiscoveryCustomMessageUserAcceptedMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageUserProposedMessage. ackMessage()Called when custom message has been handled by all nodes. -
Uses of DiscoveryCustomMessage in org.apache.ignite.internal.processors.cache
Classes in org.apache.ignite.internal.processors.cache that implement DiscoveryCustomMessage Modifier and Type Class Description classCacheAffinityChangeMessageCacheAffinityChangeMessage represent a message that switches to a new affinity assignmentafter rebalance is finished.classCacheStatisticsClearMessageCache statistics clear discovery message.classCacheStatisticsModeChangeMessageCache statistics mode change discovery message.classClientCacheChangeDiscoveryMessageSent from cache client node to asynchronously notify about started.closed client caches.classClientCacheChangeDummyDiscoveryMessageDummy discovery message which is not really sent via ring, it is just added in local discovery worker queue.classDynamicCacheChangeBatchCache change batch.classDynamicCacheChangeFailureMessageThis class represents discovery message that is used to provide information about dynamic cache start failure.classTxTimeoutOnPartitionMapExchangeChangeMessageDiscovery message for changing transaction timeout on partition map exchange.classWalStateAbstractMessageWAL state change abstract message.classWalStateFinishMessageWAL state finish message.classWalStateProposeMessageWAL state propose message.Methods in org.apache.ignite.internal.processors.cache that return DiscoveryCustomMessage Modifier and Type Method Description @Nullable DiscoveryCustomMessageCacheAffinityChangeMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageCacheStatisticsClearMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageCacheStatisticsModeChangeMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageClientCacheChangeDiscoveryMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageClientCacheChangeDummyDiscoveryMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageDynamicCacheChangeBatch. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageDynamicCacheChangeFailureMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageTxTimeoutOnPartitionMapExchangeChangeMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageWalStateAbstractMessage. ackMessage()Called when custom message has been handled by all nodes.Methods in org.apache.ignite.internal.processors.cache with parameters of type DiscoveryCustomMessage Modifier and Type Method Description CachePartitionExchangeWorkerTaskGridCacheProcessor. exchangeTaskForCustomDiscoveryMessage(DiscoveryCustomMessage msg)Create exchange worker task for custom discovery message.booleanGridCacheProcessor. onCustomEvent(DiscoveryCustomMessage msg, AffinityTopologyVersion topVer, ClusterNode node)Callback invoked from discovery thread when discovery custom message is received.voidGridCacheProcessor. onDiscoveryEvent(int type, @Nullable DiscoveryCustomMessage customMsg, ClusterNode node, AffinityTopologyVersion topVer, DiscoveryDataClusterState state) -
Uses of DiscoveryCustomMessage in org.apache.ignite.internal.processors.cache.binary
Classes in org.apache.ignite.internal.processors.cache.binary that implement DiscoveryCustomMessage Modifier and Type Class Description classMetadataRemoveAcceptedMessageAcknowledge message forMetadataRemoveProposedMessage: see its javadoc for detailed description of protocol.classMetadataRemoveProposedMessageMetadataRemoveProposedMessage andMetadataRemoveAcceptedMessagemessages make a basis for discovery-based protocol for managemetadatadescribing objects in binary format stored in Ignite caches.classMetadataUpdateAcceptedMessageAcknowledge message forMetadataUpdateProposedMessage: see its javadoc for detailed description of protocol.classMetadataUpdateProposedMessageMetadataUpdateProposedMessage andMetadataUpdateAcceptedMessagemessages make a basis for discovery-based protocol for exchangingmetadatadescribing objects in binary format stored in Ignite caches.Methods in org.apache.ignite.internal.processors.cache.binary that return DiscoveryCustomMessage Modifier and Type Method Description @Nullable DiscoveryCustomMessageMetadataRemoveAcceptedMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageMetadataRemoveProposedMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageMetadataUpdateAcceptedMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageMetadataUpdateProposedMessage. ackMessage()Called when custom message has been handled by all nodes. -
Uses of DiscoveryCustomMessage in org.apache.ignite.internal.processors.cache.persistence.snapshot
Subinterfaces of DiscoveryCustomMessage in org.apache.ignite.internal.processors.cache.persistence.snapshot Modifier and Type Interface Description interfaceSnapshotDiscoveryMessageInitial snapshot discovery message with possibility to trigger exchange. -
Uses of DiscoveryCustomMessage in org.apache.ignite.internal.processors.cluster
Classes in org.apache.ignite.internal.processors.cluster that implement DiscoveryCustomMessage Modifier and Type Class Description classChangeGlobalStateFinishMessageclassChangeGlobalStateMessageMessage represent request for change cluster global state.Methods in org.apache.ignite.internal.processors.cluster that return DiscoveryCustomMessage Modifier and Type Method Description @Nullable DiscoveryCustomMessageChangeGlobalStateFinishMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageChangeGlobalStateMessage. ackMessage()Called when custom message has been handled by all nodes. -
Uses of DiscoveryCustomMessage in org.apache.ignite.internal.processors.continuous
Classes in org.apache.ignite.internal.processors.continuous that implement DiscoveryCustomMessage Modifier and Type Class Description classAbstractContinuousMessageclassStartRoutineAckDiscoveryMessageclassStartRoutineDiscoveryMessageDiscovery message used for Continuous Query registration.classStartRoutineDiscoveryMessageV2classStopRoutineAckDiscoveryMessageclassStopRoutineDiscoveryMessageMethods in org.apache.ignite.internal.processors.continuous that return DiscoveryCustomMessage Modifier and Type Method Description @Nullable DiscoveryCustomMessageStartRoutineAckDiscoveryMessage. ackMessage()Called when custom message has been handled by all nodes.DiscoveryCustomMessageStartRoutineDiscoveryMessage. ackMessage()Called when custom message has been handled by all nodes.DiscoveryCustomMessageStartRoutineDiscoveryMessageV2. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageStopRoutineAckDiscoveryMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageStopRoutineDiscoveryMessage. ackMessage()Called when custom message has been handled by all nodes. -
Uses of DiscoveryCustomMessage in org.apache.ignite.internal.processors.marshaller
Classes in org.apache.ignite.internal.processors.marshaller that implement DiscoveryCustomMessage Modifier and Type Class Description classMappingAcceptedMessageIs sent as an acknowledgement for successfully proposed new mapping (seeMappingProposedMessage).classMappingProposedMessageNode 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.Methods in org.apache.ignite.internal.processors.marshaller that return DiscoveryCustomMessage Modifier and Type Method Description @Nullable DiscoveryCustomMessageMappingAcceptedMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageMappingProposedMessage. ackMessage()Called when custom message has been handled by all nodes. -
Uses of DiscoveryCustomMessage in org.apache.ignite.internal.processors.query.schema.message
Classes in org.apache.ignite.internal.processors.query.schema.message that implement DiscoveryCustomMessage Modifier and Type Class Description classSchemaAbstractDiscoveryMessageAbstract discovery message for schema operations.classSchemaFinishDiscoveryMessageSchema change finish discovery message.classSchemaProposeDiscoveryMessageSchema change propose discovery message.Methods in org.apache.ignite.internal.processors.query.schema.message that return DiscoveryCustomMessage Modifier and Type Method Description @Nullable DiscoveryCustomMessageSchemaFinishDiscoveryMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageSchemaProposeDiscoveryMessage. ackMessage()Called when custom message has been handled by all nodes. -
Uses of DiscoveryCustomMessage in org.apache.ignite.internal.processors.service
Classes in org.apache.ignite.internal.processors.service that implement DiscoveryCustomMessage Modifier and Type Class Description classServiceChangeBatchRequestService change batch request discovery message.classServiceClusterDeploymentResultBatchBatch of services cluster deployment result.Methods in org.apache.ignite.internal.processors.service that return DiscoveryCustomMessage Modifier and Type Method Description @Nullable DiscoveryCustomMessageServiceChangeBatchRequest. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageServiceClusterDeploymentResultBatch. ackMessage()Called when custom message has been handled by all nodes. -
Uses of DiscoveryCustomMessage in org.apache.ignite.internal.util.distributed
Classes in org.apache.ignite.internal.util.distributed that implement DiscoveryCustomMessage Modifier and Type Class Description classFullMessage<R extends Serializable>Full process message.classInitMessage<I extends Serializable>Initiate message.Methods in org.apache.ignite.internal.util.distributed that return DiscoveryCustomMessage Modifier and Type Method Description @Nullable DiscoveryCustomMessageFullMessage. ackMessage()Called when custom message has been handled by all nodes.@Nullable DiscoveryCustomMessageInitMessage. ackMessage()Called when custom message has been handled by all nodes. -
Uses of DiscoveryCustomMessage in org.apache.ignite.spi.communication.tcp.internal
Classes in org.apache.ignite.spi.communication.tcp.internal that implement DiscoveryCustomMessage Modifier and Type Class Description classTcpConnectionRequestDiscoveryMessageMessage is part of communication via discovery protocol.Methods in org.apache.ignite.spi.communication.tcp.internal that return DiscoveryCustomMessage Modifier and Type Method Description @Nullable DiscoveryCustomMessageTcpConnectionRequestDiscoveryMessage. ackMessage()Called when custom message has been handled by all nodes.
-