| 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 | |
| org.apache.ignite.internal.processors.cache.distributed.dht | |
| org.apache.ignite.internal.processors.cache.distributed.dht.preloader | |
| org.apache.ignite.internal.processors.cache.persistence.snapshot | |
| org.apache.ignite.internal.visor.util |
| Modifier and Type | Method and Description |
|---|---|
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 |
|---|---|
DiscoveryEvent |
DiscoveryLocalJoinData.event() |
DiscoveryEvent |
GridDiscoveryManager.localJoinEvent() |
| Constructor and Description |
|---|
DiscoveryLocalJoinData(DiscoveryEvent evt,
DiscoCache discoCache,
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 |
|---|---|
DiscoveryEvent |
GridAffinityFunctionContextImpl.discoveryEvent()
Gets discovery event caused topology change.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
GridAffinityAssignmentCache.calculate(AffinityTopologyVersion topVer,
DiscoveryEvent discoEvt,
DiscoCache discoCache)
Calculates affinity cache for given topology version.
|
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,
AffinityTopologyVersion topVer,
int backups) |
| Modifier and Type | Method and Description |
|---|---|
DiscoveryEvent |
PendingDiscoveryEvent.event() |
| 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).
|
| Constructor and Description |
|---|
PendingDiscoveryEvent(DiscoveryEvent evt,
DiscoCache cache) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDhtPartitionTopology.detectLostPartitions(DiscoveryEvent discoEvt)
Checks if there is at least one owner for each partition in the cache topology.
|
boolean |
GridClientPartitionTopology.detectLostPartitions(DiscoveryEvent discoEvt)
Checks if there is at least one owner for each partition in the cache topology.
|
boolean |
GridDhtPartitionTopologyImpl.detectLostPartitions(DiscoveryEvent discoEvt)
Checks if there is at least one owner for each partition in the cache topology.
|
| Modifier and Type | Method and Description |
|---|---|
DiscoveryEvent |
GridDhtPartitionsExchangeFuture.discoveryEvent() |
| 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 |
|---|
GridDhtPartitionsExchangeFuture(GridCacheSharedContext cctx,
boolean reassign,
DiscoveryEvent discoEvt,
GridDhtPartitionExchangeId exchId)
Dummy future created to trigger reassignments if partition
topology changed while preloading.
|
GridDhtPartitionsExchangeFuture(GridCacheSharedContext cctx,
DiscoveryEvent discoEvt,
GridDhtPartitionExchangeId exchId,
GridCompoundFuture<Boolean,Boolean> forcedRebFut)
Force preload future created to trigger reassignments if partition
topology changed while preloading.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture |
IgniteCacheSnapshotManager.tryStartLocalSnapshotOperation(DiscoveryEvent discoveryEvent)
Try to start local snapshot operation if it's required by discovery event.
|
| 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 Fabric : ver. 2.1.0 Release Date : July 20 2017