@GridToStringExclude public class GridCacheSharedContext<K,V> extends Object
| Constructor and Description |
|---|
GridCacheSharedContext(GridKernalContext kernalCtx,
IgniteTxManager txMgr,
GridCacheVersionManager verMgr,
GridCacheMvccManager mvccMgr,
GridCacheDeploymentManager<K,V> depMgr,
GridCachePartitionExchangeManager<K,V> exchMgr,
GridCacheIoManager ioMgr) |
public GridCacheSharedContext(GridKernalContext kernalCtx, IgniteTxManager txMgr, GridCacheVersionManager verMgr, GridCacheMvccManager mvccMgr, GridCacheDeploymentManager<K,V> depMgr, GridCachePartitionExchangeManager<K,V> exchMgr, GridCacheIoManager ioMgr)
txMgr - Transaction manager.verMgr - Version manager.mvccMgr - MVCC manager.public Collection<GridCacheContext> cacheContexts()
public GridCacheProcessor cache()
public void addCacheContext(GridCacheContext cacheCtx) throws IgniteCheckedException
cacheCtx - Cache context to add.IgniteCheckedExceptionpublic void removeCacheContext(GridCacheContext cacheCtx)
cacheCtx - Cache context to remove.public boolean closed(GridCacheContext ctx)
ctx - Cache context to check.True if cache context is closed.public List<GridCacheSharedManager<K,V>> managers()
public GridCacheContext<K,V> cacheContext(int cacheId)
cacheId - Cache ID.public String gridName()
public TransactionConfiguration txConfig()
public long preloadExchangeTimeout()
4 times
bigger than network timeout by default.public boolean deploymentEnabled()
public byte dataCenterId()
public IgniteInternalFuture<Object> preloadersStartFuture()
public TransactionMetricsAdapter txMetrics()
public void resetTxMetrics()
public IgniteTxManager tm()
public GridCachePartitionExchangeManager<K,V> exchange()
public GridCacheVersionManager versions()
public GridCacheMvccManager mvcc()
public GridCacheIoManager io()
public GridCacheDeploymentManager<K,V> deploy()
public Marshaller marshaller()
public IgniteConfiguration gridConfig()
public GridKernalContext kernalContext()
public GridIoManager gridIO()
public GridDeploymentManager gridDeploy()
public GridEventStorageManager gridEvents()
public GridDiscoveryManager discovery()
public GridTimeoutProcessor time()
public UUID localNodeId()
public ClusterNode localNode()
public ClusterNode node(UUID nodeId)
nodeId - Node ID.null.public IgniteLogger logger(Class<?> cls)
cls - Class to get logger for.public IgniteLogger logger(String category)
category - Category.public IgniteInternalFuture<?> partitionReleaseFuture(AffinityTopologyVersion topVer)
topVer - Topology version.true if waiting was successful.public boolean txCompatible(IgniteInternalTx tx, Iterable<Integer> activeCacheIds, GridCacheContext<K,V> cacheCtx)
tx - Transaction to check.activeCacheIds - Active cache IDs.cacheCtx - Cache context.True if cross-cache transaction can include this new cache.public void cleanup()
public void endTx(IgniteInternalTx tx) throws IgniteCheckedException
tx - Transaction to close.IgniteCheckedException - If failed.public IgniteInternalFuture<IgniteInternalTx> commitTxAsync(IgniteInternalTx tx)
tx - Transaction to commit.public IgniteInternalFuture rollbackTxAsync(IgniteInternalTx tx) throws IgniteCheckedException
tx - Transaction to rollback.IgniteCheckedException - If failed.
Follow @ApacheIgnite
Ignite Fabric : ver. 1.1.0-incubating Release Date : May 20 2015