| Package | Description |
|---|---|
| org.apache.ignite.cache.affinity |
Contains cache node affinity implementations.
|
| org.apache.ignite.internal.events | |
| org.apache.ignite.internal.managers.discovery |
TODO.
|
| org.apache.ignite.internal.managers.eventstorage |
TODO.
|
| org.apache.ignite.internal.processors.affinity |
Data affinity processor.
|
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.cache.distributed.dht.preloader | |
| org.apache.ignite.internal.processors.cache.mvcc | |
| org.apache.ignite.internal.processors.cache.persistence.snapshot | |
| org.apache.ignite.internal.processors.service | |
| org.apache.ignite.internal.visor.util |
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoveryEvent |
AffinityFunctionContext.discoveryEvent()
Gets discovery event caused topology change.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DiscoveryCustomEvent
Custom event.
|
| Modifier and Type | Method and Description |
|---|---|
static boolean |
DiscoveryCustomEvent.requiresCentralizedAffinityAssignment(DiscoveryEvent evt) |
| Modifier and Type | Method and Description |
|---|---|
DiscoveryEvent |
DiscoveryLocalJoinData.event() |
DiscoveryEvent |
GridDiscoveryManager.localJoinEvent() |
| Constructor and Description |
|---|
DiscoveryLocalJoinData(DiscoveryEvent evt,
DiscoCache discoCache,
@Nullable IgniteInternalFuture<Boolean> transitionWaitFut,
boolean active) |
| Modifier and Type | Method and Description |
|---|---|
void |
DiscoveryEventListener.onEvent(DiscoveryEvent evt,
DiscoCache discoCache) |
void |
GridEventStorageManager.record(DiscoveryEvent evt,
DiscoCache discoCache)
Records discovery events.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoveryEvent |
GridAffinityFunctionContextImpl.discoveryEvent()
Gets discovery event caused topology change.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridAffinityAssignmentCache.clientEventTopologyChange(DiscoveryEvent evt,
AffinityTopologyVersion topVer)
Copies previous affinity assignment when discovery event does not cause affinity assignment changes
(e.g. client node joins on leaves).
|
| Constructor and Description |
|---|
GridAffinityFunctionContextImpl(List<ClusterNode> topSnapshot,
List<List<ClusterNode>> prevAssignment,
DiscoveryEvent discoEvt,
@NotNull AffinityTopologyVersion topVer,
int backups) |
| Modifier and Type | Method and Description |
|---|---|
DiscoveryEvent |
PendingDiscoveryEvent.event() |
DiscoveryEvent |
ExchangeDiscoveryEvents.lastEvent() |
| Modifier and Type | Method and Description |
|---|---|
Collection<DiscoveryEvent> |
ExchangeDiscoveryEvents.events() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCachePartitionExchangeManager.onLocalJoin(DiscoveryEvent evt,
DiscoCache cache)
Callback for local join event (needed since regular event for local join is not generated).
|
static boolean |
ExchangeDiscoveryEvents.serverJoinEvent(DiscoveryEvent evt) |
static boolean |
ExchangeDiscoveryEvents.serverLeftEvent(DiscoveryEvent evt) |
| Constructor and Description |
|---|
PendingDiscoveryEvent(DiscoveryEvent evt,
DiscoCache cache) |
| Modifier and Type | Method and Description |
|---|---|
DiscoveryEvent |
GridDhtPartitionsExchangeFuture.firstEvent() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtForceKeysFuture.onDiscoveryEvent(DiscoveryEvent evt) |
void |
GridDhtPartitionsExchangeFuture.onEvent(GridDhtPartitionExchangeId exchId,
DiscoveryEvent discoEvt,
DiscoCache discoCache)
Event callback.
|
| Constructor and Description |
|---|
GridDhtPartitionExchangeId(UUID nodeId,
DiscoveryEvent discoEvt,
AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
void |
MvccProcessorImpl.onLocalJoin(DiscoveryEvent evt,
DiscoCache discoCache)
Local join callback.
|
void |
MvccProcessor.onLocalJoin(DiscoveryEvent evt,
DiscoCache discoCache)
Local join callback.
|
| Modifier and Type | Method and Description |
|---|---|
static boolean |
IgniteSnapshotManager.isSnapshotOperation(DiscoveryEvent evt) |
@Nullable IgniteInternalFuture |
IgniteCacheSnapshotManager.tryStartLocalSnapshotOperation(@Nullable DiscoveryEvent discoveryEvt,
AffinityTopologyVersion topVer)
Deprecated.
Try to start local snapshot operation if it's required by discovery event.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ServiceProcessorAdapter.onLocalJoin(DiscoveryEvent evt,
DiscoCache discoCache)
Callback for local join events for which the regular events are not generated.
|
void |
IgniteServiceProcessor.onLocalJoin(DiscoveryEvent evt,
DiscoCache discoCache)
Callback for local join events for which the regular events are not generated.
|
| Modifier and Type | Method and Description |
|---|---|
protected VisorGridEvent |
VisorEventMapper.discoveryEvent(DiscoveryEvent de,
int type,
IgniteUuid id,
String name,
UUID nid,
long ts,
String msg,
String shortDisplay) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.10.0 Release Date : March 10 2021