public static class ClusteringDependentLogic.LocalLogic extends ClusteringDependentLogic.AbstractClusteringDependentLogic
ClusteringDependentLogic.AbstractClusteringDependentLogic, ClusteringDependentLogic.Commit, ClusteringDependentLogic.DistributionLogic, ClusteringDependentLogic.InvalidationLogic, ClusteringDependentLogic.LocalLogic, ClusteringDependentLogic.ReplicationLogic, ClusteringDependentLogic.ScatteredLogic
commitManager, componentRegistry, configuration, dataContainer, distributionManager, evictionManager, functionalNotifier, keyPartitioner, notifier, persistenceManager, timeService
Constructor and Description |
---|
LocalLogic() |
Modifier and Type | Method and Description |
---|---|
protected CompletionStage<Void> |
commitSingleEntry(CacheEntry entry,
FlagAffectedCommand command,
InvocationContext ctx,
Flag trackFlag,
boolean l1Invalidation) |
ClusteringDependentLogic.Commit |
commitType(FlagAffectedCommand command,
InvocationContext ctx,
int segment,
boolean removed)
Determines what type of commit this is.
|
Address |
getAddress() |
LocalizedCacheTopology |
getCacheTopology() |
void |
init(Transport transport,
Configuration configuration,
KeyPartitioner keyPartitioner) |
protected WriteSkewHelper.KeySpecificLogic |
initKeySpecificLogic() |
clusterCommitType, commitEntry, createNewVersionsAndCheckForWriteSkews, getEntryLoader, start
public void init(Transport transport, Configuration configuration, KeyPartitioner keyPartitioner)
public LocalizedCacheTopology getCacheTopology()
getCacheTopology
in interface ClusteringDependentLogic
getCacheTopology
in class ClusteringDependentLogic.AbstractClusteringDependentLogic
public Address getAddress()
getAddress
in interface ClusteringDependentLogic
getAddress
in class ClusteringDependentLogic.AbstractClusteringDependentLogic
public ClusteringDependentLogic.Commit commitType(FlagAffectedCommand command, InvocationContext ctx, int segment, boolean removed)
ClusteringDependentLogic
commitType
in interface ClusteringDependentLogic
commitType
in class ClusteringDependentLogic.AbstractClusteringDependentLogic
segment
- if 0 or greater assumes the underlying container is segmented.protected CompletionStage<Void> commitSingleEntry(CacheEntry entry, FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
commitSingleEntry
in class ClusteringDependentLogic.AbstractClusteringDependentLogic
protected WriteSkewHelper.KeySpecificLogic initKeySpecificLogic()
initKeySpecificLogic
in class ClusteringDependentLogic.AbstractClusteringDependentLogic
Copyright © 2021 JBoss by Red Hat. All rights reserved.