| Package | Description |
|---|---|
| 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.cluster |
| Modifier and Type | Method and Description |
|---|---|
ExchangeActions |
DynamicCacheChangeFailureMessage.exchangeActions() |
ExchangeActions |
DynamicCacheChangeBatch.exchangeActions() |
ExchangeActions |
ClusterCachesInfo.onStateChangeRequest(ChangeGlobalStateMessage msg,
AffinityTopologyVersion topVer,
DiscoveryDataClusterState curState) |
ExchangeActions |
GridCacheProcessor.onStateChangeRequest(ChangeGlobalStateMessage msg,
AffinityTopologyVersion topVer,
DiscoveryDataClusterState curState) |
| Modifier and Type | Method and Description |
|---|---|
GridDhtPartitionsSingleMessage |
GridCachePartitionExchangeManager.createPartitionsSingleMessage(@Nullable GridDhtPartitionExchangeId exchangeId,
boolean clientOnlyExchange,
boolean sndCounters,
boolean newCntrMap,
ExchangeActions exchActions)
Creates partitions single message for all cache groups.
|
GridDhtPartitionsSingleMessage |
GridCachePartitionExchangeManager.createPartitionsSingleMessage(@Nullable GridDhtPartitionExchangeId exchangeId,
boolean clientOnlyExchange,
boolean sndCounters,
boolean newCntrMap,
ExchangeActions exchActions,
Collection<CacheGroupContext> grps)
Creates partitions single message for selected cache groups.
|
void |
DynamicCacheChangeFailureMessage.exchangeActions(ExchangeActions exchangeActions) |
void |
CacheAffinitySharedManager.forceCloseCaches(GridDhtPartitionsExchangeFuture fut,
boolean crd,
ExchangeActions exchActions)
Called during the rollback of the exchange partitions procedure in order to stop the given cache even if it's not
fully initialized (e.g. failed on cache init stage).
|
IgniteInternalFuture<?> |
CacheAffinitySharedManager.onCacheChangeRequest(GridDhtPartitionsExchangeFuture fut,
boolean crd,
ExchangeActions exchActions)
Called on exchange initiated for cache start/stop request.
|
void |
CacheAffinitySharedManager.onCustomMessageNoAffinityChange(GridDhtPartitionsExchangeFuture fut,
@Nullable ExchangeActions exchActions) |
void |
GridCacheProcessor.onExchangeDone(AffinityTopologyVersion cacheStartVer,
@Nullable ExchangeActions exchActions,
@Nullable Throwable err)
Callback invoked when first exchange future for dynamic cache is completed.
|
IgniteInternalFuture<?> |
CachesRegistry.update(ExchangeActions exchActions)
Adds caches and cache groups to start from
exchActions. |
| Modifier and Type | Method and Description |
|---|---|
@Nullable ExchangeActions |
GridDhtPartitionsExchangeFuture.exchangeActions()
Gets exchanges actions (such as cache start or stop) associated with the exchange future.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPartitionsExchangeFuture.exchangeActions(ExchangeActions exchActions)
Sets exchange actions associated with the exchange future (such as cache start or stop).
|
| Constructor and Description |
|---|
GridDhtPartitionsExchangeFuture(GridCacheSharedContext cctx,
ReadWriteLock busyLock,
GridDhtPartitionExchangeId exchId,
ExchangeActions exchActions,
CacheAffinityChangeMessage affChangeMsg) |
| Modifier and Type | Method and Description |
|---|---|
ExchangeActions |
GridClusterStateProcessor.autoAdjustExchangeActions(ExchangeActions exchActs)
Add fake state change request into exchange actions if cluster is not persistent and baseline autoadjustment
is enabled with zero timeout.
|
@Nullable ExchangeActions |
ChangeGlobalStateMessage.exchangeActions() |
| Modifier and Type | Method and Description |
|---|---|
ExchangeActions |
GridClusterStateProcessor.autoAdjustExchangeActions(ExchangeActions exchActs)
Add fake state change request into exchange actions if cluster is not persistent and baseline autoadjustment
is enabled with zero timeout.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.15.0 Release Date : April 25 2023