| Modifier and Type | Field and Description |
|---|---|
protected DiscoCache |
DiscoveryMessageResultsCollector.discoCache |
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
DiscoCache.copy(AffinityTopologyVersion ver,
@Nullable DiscoveryDataClusterState state) |
DiscoCache |
DiscoveryCustomMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
GridDiscoveryManager.createDiscoCacheOnCacheChange(AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates discovery cache after
DynamicCacheChangeBatch received. |
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.
|
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
DiscoveryCustomMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
GridDiscoveryManager.createDiscoCacheOnCacheChange(AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates discovery cache after
DynamicCacheChangeBatch received. |
void |
DiscoveryMessageResultsCollector.init(DiscoCache discoCache) |
void |
GridDiscoveryManager.metricsUpdateEvent(DiscoCache discoCache,
ClusterNode node)
Adds metrics update event to discovery worker queue.
|
protected abstract boolean |
DiscoveryMessageResultsCollector.waitForNode(DiscoCache discoCache,
ClusterNode node) |
| 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 |
|---|---|
IdealAffinityAssignment |
GridAffinityAssignmentCache.calculate(AffinityTopologyVersion topVer,
@Nullable ExchangeDiscoveryEvents events,
@Nullable DiscoCache discoCache)
Calculates ideal assignment for given topology version and events happened since last calculation.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoCache |
UserAcceptedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
@Nullable DiscoCache |
UserProposedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoCache |
UserAcceptedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
@Nullable DiscoCache |
UserProposedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoCache |
ClientCacheChangeDummyDiscoveryMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
@Nullable DiscoCache |
CacheAffinityChangeMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
TxTimeoutOnPartitionMapExchangeChangeMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
@Nullable DiscoCache |
ClientCacheChangeDiscoveryMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
CacheStatisticsModeChangeMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
DynamicCacheChangeBatch.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
DynamicCacheChangeFailureMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
CacheStatisticsClearMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
WalStateAbstractMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
PendingDiscoveryEvent.discoCache() |
DiscoCache |
ExchangeDiscoveryEvents.discoveryCache() |
| Modifier and Type | Method and Description |
|---|---|
GridDhtPartitionTopology |
GridCachePartitionExchangeManager.clientTopology(int grpId,
DiscoCache discoCache) |
@Nullable DiscoCache |
ClientCacheChangeDummyDiscoveryMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
@Nullable DiscoCache |
CacheAffinityChangeMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
TxTimeoutOnPartitionMapExchangeChangeMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
@Nullable DiscoCache |
ClientCacheChangeDiscoveryMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
CacheStatisticsModeChangeMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
DynamicCacheChangeBatch.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
DynamicCacheChangeFailureMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
CacheStatisticsClearMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
WalStateAbstractMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
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 |
|---|---|
@Nullable DiscoCache |
MetadataUpdateProposedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
@Nullable DiscoCache |
MetadataUpdateAcceptedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
@Nullable DiscoCache |
MetadataRemoveProposedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
@Nullable DiscoCache |
MetadataRemoveAcceptedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoCache |
MetadataUpdateProposedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
@Nullable DiscoCache |
MetadataUpdateAcceptedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
@Nullable DiscoCache |
MetadataRemoveProposedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
@Nullable DiscoCache |
MetadataRemoveAcceptedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
GridDhtAffinityAssignmentResponse.affinityAssignment(DiscoCache discoCache) |
List<List<ClusterNode>> |
GridDhtAffinityAssignmentResponse.idealAffinityAssignment(DiscoCache discoCache) |
| Constructor and Description |
|---|
GridDhtAssignmentFetchFuture(GridCacheSharedContext ctx,
int grpId,
AffinityTopologyVersion topVer,
DiscoCache discoCache) |
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
GridDhtPartitionsExchangeFuture.firstEventCache() |
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
CacheGroupAffinityMessage.createAssignments(Map<Long,ClusterNode> nodesByOrder,
DiscoCache discoCache) |
@Nullable List<List<ClusterNode>> |
CacheGroupAffinityMessage.createIdealAssignments(Map<Long,ClusterNode> nodesByOrder,
DiscoCache discoCache) |
void |
GridDhtPartitionsExchangeFuture.onEvent(GridDhtPartitionExchangeId exchId,
DiscoveryEvent discoEvt,
DiscoCache discoCache)
Event callback.
|
static List<ClusterNode> |
CacheGroupAffinityMessage.toNodes(GridLongList assign,
Map<Long,ClusterNode> nodesByOrder,
DiscoCache discoCache) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPartitionTopology.updateTopologyVersion(GridDhtTopologyFuture exchFut,
DiscoCache discoCache,
long updateSeq,
boolean stopping)
Updates topology version.
|
void |
GridDhtPartitionTopologyImpl.updateTopologyVersion(GridDhtTopologyFuture exchFut,
@NotNull DiscoCache discoCache,
long updSeq,
boolean stopping)
Updates topology version.
|
void |
GridClientPartitionTopology.updateTopologyVersion(GridDhtTopologyFuture exchFut,
DiscoCache discoCache,
long updSeq,
boolean stopping)
Updates topology version.
|
| Constructor and Description |
|---|
GridClientPartitionTopology(GridCacheSharedContext<?,?> cctx,
DiscoCache discoCache,
int grpId,
int parts,
Object similarAffKey,
PartitionLossPolicy partLossPlc) |
| Modifier and Type | Method and Description |
|---|---|
void |
MvccProcessor.onExchangeDone(DiscoCache discoCache)
Exchange done callback.
|
void |
MvccProcessorImpl.onExchangeDone(DiscoCache discoCache)
Exchange done callback.
|
void |
MvccProcessor.onLocalJoin(DiscoveryEvent evt,
DiscoCache discoCache)
Local join callback.
|
void |
MvccProcessorImpl.onLocalJoin(DiscoveryEvent evt,
DiscoCache discoCache)
Local join callback.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoCache |
ChangeGlobalStateFinishMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
ChangeGlobalStateMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridClusterStateProcessor.autoAdjustInMemoryClusterState(UUID nodeId,
Collection<ClusterNode> topSnapshot,
DiscoCache discoCache,
long topVer,
int minorTopVer)
Update baseline locally if cluster is not persistent and baseline autoadjustment is enabled with zero timeout.
|
@Nullable DiscoCache |
ChangeGlobalStateFinishMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
ChangeGlobalStateMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
@Nullable IgniteInternalFuture<Boolean> |
IGridClusterStateProcessor.onLocalJoin(DiscoCache discoCache) |
@Nullable IgniteInternalFuture<Boolean> |
GridClusterStateProcessor.onLocalJoin(DiscoCache discoCache) |
boolean |
IGridClusterStateProcessor.onStateChangeMessage(AffinityTopologyVersion topVer,
ChangeGlobalStateMessage msg,
DiscoCache discoCache) |
boolean |
GridClusterStateProcessor.onStateChangeMessage(AffinityTopologyVersion topVer,
ChangeGlobalStateMessage msg,
DiscoCache discoCache) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoCache |
AbstractContinuousMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoCache |
AbstractContinuousMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoCache |
MappingAcceptedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
@Nullable DiscoCache |
MappingProposedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoCache |
MappingAcceptedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
@Nullable DiscoCache |
MappingProposedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoCache |
SchemaAbstractDiscoveryMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable DiscoCache |
SchemaAbstractDiscoveryMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
ServiceChangeBatchRequest.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
ServiceClusterDeploymentResultBatch.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
ServiceChangeBatchRequest.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
ServiceClusterDeploymentResultBatch.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
void |
IgniteServiceProcessor.onLocalJoin(DiscoveryEvent evt,
DiscoCache discoCache)
Callback for local join events for which the regular events are not generated.
|
void |
ServiceProcessorAdapter.onLocalJoin(DiscoveryEvent evt,
DiscoCache discoCache)
Callback for local join events for which the regular events are not generated.
|
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
InitMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
FullMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
InitMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
FullMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
TcpConnectionRequestDiscoveryMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
TcpConnectionRequestDiscoveryMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.0 Release Date : October 15 2020