public class ExchangeActions extends Object
DynamicCacheChangeBatch event.| Modifier and Type | Class and Description |
|---|---|
static class |
ExchangeActions.CacheActionData |
static class |
ExchangeActions.CacheGroupActionData |
| Constructor and Description |
|---|
ExchangeActions() |
public boolean clientOnlyExchange()
True if server nodes should not participate in exchange.public Collection<ExchangeActions.CacheActionData> cacheStartRequests()
public Collection<ExchangeActions.CacheActionData> cacheStopRequests()
public void completeRequestFutures(GridCacheSharedContext ctx, Throwable err)
ctx - Context.err - Error if any.public boolean systemCachesStarting()
True if starting system caches.public boolean hasStop()
True if have cache stop requests.public Set<String> cachesToResetLostPartitions()
public boolean cacheStopped(int cacheId)
cacheId - Cache ID.True if cache stop was requested.public boolean cacheStarted(int cacheId)
cacheId - Cache ID.True if cache start was requested.public void stateChangeRequest(StateChangeRequest stateChange)
stateChange - Cluster state change request.public boolean deactivate()
True if has deactivate request.public boolean activate()
True if has activate request.public boolean changedClusterState()
True if cluster state was changed.public boolean changedBaseline()
True if has baseline topology change request.@Nullable public @Nullable StateChangeRequest stateChangeRequest()
public void addCacheToStop(DynamicCacheChangeRequest req, DynamicCacheDescriptor desc)
req - Request.desc - Cache descriptor.public List<ExchangeActions.CacheGroupActionData> cacheGroupsToStart()
public boolean cacheGroupStarting(int grpId)
grpId - Group ID.True if given cache group starting.public Collection<UUID> cacheStartRequiredAliveNodes()
public void cacheStartRequiredAliveNodes(Collection<UUID> cacheStartRequiredAliveNodes)
cacheStartRequiredAliveNodes - Server nodes on which a successful start of the cache(s) is required, if any
of these nodes fails when starting the cache(s), the whole procedure is
rolled back.public void addCacheGroupToStop(CacheGroupDescriptor grpDesc, boolean destroy)
grpDesc - Group descriptor.destroy - Destroy flag.public List<ExchangeActions.CacheGroupActionData> cacheGroupsToStop()
public boolean cacheGroupStopping(int grpId)
grpId - Group ID.True if given cache group stopping.public boolean empty()
True if there are no cache change actions.public void localJoinContext(LocalJoinCachesContext locJoinCtx)
locJoinCtx - Caches local join context.public LocalJoinCachesContext localJoinContext()
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.0 Release Date : September 11 2021