Package | Description |
---|---|
org.infinispan.commands.tx |
Commands that represent transactional lifecycle transitions.
|
org.infinispan.container.versioning | |
org.infinispan.interceptors.locking |
Interceptors dealing with locking.
|
org.infinispan.metadata.impl | |
org.infinispan.partitionhandling.impl | |
org.infinispan.remoting.responses |
Abstractions of the different response types allowed during RPC.
|
org.infinispan.transaction.impl | |
org.infinispan.transaction.xa |
XA transaction support.
|
Modifier and Type | Method and Description |
---|---|
Map<Object,IncrementableEntryVersion> |
VersionedCommitCommand.getUpdatedVersions() |
Map<Object,IncrementableEntryVersion> |
VersionedPrepareCommand.getVersionsSeen() |
Modifier and Type | Method and Description |
---|---|
void |
VersionedCommitCommand.setUpdatedVersions(Map<Object,IncrementableEntryVersion> updatedVersions) |
void |
VersionedPrepareCommand.setVersionsSeen(Map<Object,IncrementableEntryVersion> versionsSeen) |
Modifier and Type | Class and Description |
---|---|
class |
NumericVersion
Numeric version
|
class |
SimpleClusteredVersion
A simple versioning scheme that is cluster-aware
|
Modifier and Type | Method and Description |
---|---|
IncrementableEntryVersion |
VersionGenerator.generateNew()
Generates a new entry version
|
IncrementableEntryVersion |
NumericVersionGenerator.generateNew() |
IncrementableEntryVersion |
SimpleClusteredVersionGenerator.generateNew() |
IncrementableEntryVersion |
VersionGenerator.increment(IncrementableEntryVersion initialVersion) |
IncrementableEntryVersion |
NumericVersionGenerator.increment(IncrementableEntryVersion initialVersion) |
IncrementableEntryVersion |
SimpleClusteredVersionGenerator.increment(IncrementableEntryVersion initialVersion) |
IncrementableEntryVersion |
VersionGenerator.nonExistingVersion() |
IncrementableEntryVersion |
NumericVersionGenerator.nonExistingVersion() |
IncrementableEntryVersion |
SimpleClusteredVersionGenerator.nonExistingVersion() |
Modifier and Type | Method and Description |
---|---|
IncrementableEntryVersion |
VersionGenerator.increment(IncrementableEntryVersion initialVersion) |
IncrementableEntryVersion |
NumericVersionGenerator.increment(IncrementableEntryVersion initialVersion) |
IncrementableEntryVersion |
SimpleClusteredVersionGenerator.increment(IncrementableEntryVersion initialVersion) |
Modifier and Type | Method and Description |
---|---|
CompletionStage<Map<Object,IncrementableEntryVersion>> |
ClusteringDependentLogic.createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator,
TxInvocationContext context,
VersionedPrepareCommand prepareCommand) |
CompletionStage<Map<Object,IncrementableEntryVersion>> |
ClusteringDependentLogic.AbstractClusteringDependentLogic.createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator,
TxInvocationContext context,
VersionedPrepareCommand prepareCommand) |
CompletionStage<Map<Object,IncrementableEntryVersion>> |
OrderedClusteringDependentLogic.createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator,
TxInvocationContext context,
VersionedPrepareCommand prepareCommand) |
Modifier and Type | Method and Description |
---|---|
IncrementableEntryVersion |
PrivateMetadata.entryVersion() |
Modifier and Type | Method and Description |
---|---|
PrivateMetadata.Builder |
PrivateMetadata.Builder.entryVersion(IncrementableEntryVersion entryVersion)
Sets the
IncrementableEntryVersion to store. |
Modifier and Type | Method and Description |
---|---|
boolean |
AvailablePartitionHandlingManager.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
Map<Object,IncrementableEntryVersion> newVersions) |
boolean |
PartitionHandlingManager.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
Map<Object,IncrementableEntryVersion> newVersions)
Adds a partially committed transaction.
|
boolean |
PartitionHandlingManagerImpl.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
Map<Object,IncrementableEntryVersion> newVersions) |
Modifier and Type | Method and Description |
---|---|
Map<Object,IncrementableEntryVersion> |
PrepareResponse.mergeEntryVersions(Map<Object,IncrementableEntryVersion> entryVersions) |
Modifier and Type | Method and Description |
---|---|
Map<Object,IncrementableEntryVersion> |
PrepareResponse.mergeEntryVersions(Map<Object,IncrementableEntryVersion> entryVersions) |
Modifier and Type | Method and Description |
---|---|
static IncrementableEntryVersion |
WriteSkewHelper.versionFromEntry(CacheEntry<?,?> entry) |
Modifier and Type | Method and Description |
---|---|
Map<Object,IncrementableEntryVersion> |
AbstractCacheTransaction.getUpdatedEntryVersions() |
Map<Object,IncrementableEntryVersion> |
AbstractCacheTransaction.getVersionsRead() |
static Map<Object,IncrementableEntryVersion> |
WriteSkewHelper.mergeEntryVersions(Map<Object,IncrementableEntryVersion> entryVersions,
Map<Object,IncrementableEntryVersion> updatedEntryVersions) |
static CompletionStage<Map<Object,IncrementableEntryVersion>> |
WriteSkewHelper.performWriteSkewCheckAndReturnNewVersions(VersionedPrepareCommand prepareCommand,
EntryLoader<?,?> entryLoader,
VersionGenerator versionGenerator,
TxInvocationContext<?> context,
WriteSkewHelper.KeySpecificLogic ksl,
KeyPartitioner keyPartitioner) |
Modifier and Type | Method and Description |
---|---|
static Map<Object,IncrementableEntryVersion> |
WriteSkewHelper.mergeEntryVersions(Map<Object,IncrementableEntryVersion> entryVersions,
Map<Object,IncrementableEntryVersion> updatedEntryVersions) |
static Map<Object,IncrementableEntryVersion> |
WriteSkewHelper.mergeEntryVersions(Map<Object,IncrementableEntryVersion> entryVersions,
Map<Object,IncrementableEntryVersion> updatedEntryVersions) |
static PrepareResponse |
WriteSkewHelper.mergeInPrepareResponse(Map<Object,IncrementableEntryVersion> versionsMap,
PrepareResponse response) |
void |
AbstractCacheTransaction.setUpdatedEntryVersions(Map<Object,IncrementableEntryVersion> updatedEntryVersions) |
Modifier and Type | Method and Description |
---|---|
Map<Object,IncrementableEntryVersion> |
CacheTransaction.getUpdatedEntryVersions() |
Map<Object,IncrementableEntryVersion> |
CacheTransaction.getVersionsRead()
Note: used in Repeatable Read + Write Skew + Clustering + Versioning.
|
Modifier and Type | Method and Description |
---|---|
void |
CacheTransaction.setUpdatedEntryVersions(Map<Object,IncrementableEntryVersion> updatedEntryVersions) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.