| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
GridDiscoveryManager.discoCache()
Gets discovery collection cache from SPI safely guarding against "floating" collections.
|
DiscoCache |
DiscoveryLocalJoinData.discoCache() |
DiscoCache |
GridDiscoveryManager.discoCache(AffinityTopologyVersion topVer)
Gets discovery collection cache from SPI safely guarding against "floating" collections.
|
| 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 |
|---|---|
List<List<ClusterNode>> |
GridAffinityAssignmentCache.calculate(AffinityTopologyVersion topVer,
DiscoveryEvent discoEvt,
DiscoCache discoCache)
Calculates affinity cache for given topology version.
|
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
PendingDiscoveryEvent.discoCache() |
| 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 |
|---|---|
List<List<ClusterNode>> |
GridDhtAffinityAssignmentResponse.affinityAssignment(DiscoCache discoCache) |
List<List<ClusterNode>> |
GridDhtAffinityAssignmentResponse.idealAffinityAssignment(DiscoCache discoCache) |
void |
GridDhtPartitionTopology.updateTopologyVersion(GridDhtTopologyFuture exchFut,
DiscoCache discoCache,
long updateSeq,
boolean stopping)
Updates topology version.
|
void |
GridClientPartitionTopology.updateTopologyVersion(GridDhtTopologyFuture exchFut,
DiscoCache discoCache,
long updSeq,
boolean stopping)
Updates topology version.
|
void |
GridDhtPartitionTopologyImpl.updateTopologyVersion(GridDhtTopologyFuture exchFut,
DiscoCache discoCache,
long updSeq,
boolean stopping)
Updates topology version.
|
| Constructor and Description |
|---|
GridDhtAssignmentFetchFuture(GridCacheSharedContext ctx,
int grpId,
AffinityTopologyVersion topVer,
DiscoCache discoCache) |
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
GridDhtPartitionsExchangeFuture.discoCache() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPartitionsExchangeFuture.onEvent(GridDhtPartitionExchangeId exchId,
DiscoveryEvent discoEvt,
DiscoCache discoCache)
Event callback.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridClusterStateProcessor.onLocalJoin(DiscoCache discoCache) |
boolean |
GridClusterStateProcessor.onStateChangeMessage(AffinityTopologyVersion topVer,
ChangeGlobalStateMessage msg,
DiscoCache discoCache) |
Follow @ApacheIgnite
Ignite Fabric : ver. 2.1.0 Release Date : July 20 2017