Package | Description |
---|---|
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.commands.control | |
org.infinispan.commands.irac | |
org.infinispan.commands.module | |
org.infinispan.commands.remote |
Meta-commands that wrap other commands for remote execution.
|
org.infinispan.commands.remote.recovery | |
org.infinispan.commands.statetransfer | |
org.infinispan.commands.triangle | |
org.infinispan.commands.tx |
Commands that represent transactional lifecycle transitions.
|
org.infinispan.commands.write |
Commands that alter the state of the cache.
|
org.infinispan.expiration.impl | |
org.infinispan.factories |
Factories are internal components used to create other components based on a cache's
configuration.
|
org.infinispan.marshall.exts |
Externalizers for various JDK types that are marshalled using the marshalling framework.
|
org.infinispan.notifications.cachelistener.cluster | |
org.infinispan.reactive.publisher.impl.commands.batch | |
org.infinispan.reactive.publisher.impl.commands.reduction | |
org.infinispan.remoting.inboundhandler |
Handling of inbound commands on remote nodes.
|
org.infinispan.util |
General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and
collections and containers designed to supplement the JDK-provided containers.
|
org.infinispan.util.logging |
Infinispan's logging abstractions that delegate to either JDK or Log4J logging engines.
|
org.infinispan.xsite | |
org.infinispan.xsite.commands | |
org.infinispan.xsite.statetransfer |
Modifier and Type | Method and Description |
---|---|
CacheRpcCommand |
RemoteCommandsFactory.fromStream(byte id,
byte type,
ByteString cacheName)
Resolve an
CacheRpcCommand from the stream. |
Constructor and Description |
---|
LockControlCommand(ByteString cacheName) |
LockControlCommand(Collection<?> keys,
ByteString cacheName,
long flags,
GlobalTransaction gtx) |
LockControlCommand(Object key,
ByteString cacheName,
long flags,
GlobalTransaction gtx) |
Modifier and Type | Method and Description |
---|---|
ByteString |
IracCleanupKeyCommand.getCacheName() |
ByteString |
IracMetadataRequestCommand.getCacheName() |
ByteString |
IracStateResponseCommand.getCacheName() |
Modifier and Type | Method and Description |
---|---|
IracClearKeysCommand |
IracClearKeysCommand.copyForCacheName(ByteString cacheName) |
IracPutKeyCommand |
IracPutKeyCommand.copyForCacheName(ByteString cacheName) |
IracRemoveKeyCommand |
IracRemoveKeyCommand.copyForCacheName(ByteString cacheName) |
abstract IracUpdateKeyCommand |
IracUpdateKeyCommand.copyForCacheName(ByteString cacheName) |
Constructor and Description |
---|
IracCleanupKeyCommand(ByteString cacheName) |
IracCleanupKeyCommand(ByteString cacheName,
Object key,
Object lockOwner,
IracMetadata tombstone) |
IracClearKeysCommand(ByteString cacheName) |
IracMetadataRequestCommand(ByteString cacheName) |
IracMetadataRequestCommand(ByteString cacheName,
int segment) |
IracPutKeyCommand(ByteString cacheName) |
IracPutKeyCommand(ByteString cacheName,
Object key,
Object value,
Metadata metadata,
IracMetadata iracMetadata) |
IracRemoveKeyCommand(ByteString cacheName) |
IracRemoveKeyCommand(ByteString cacheName,
Object key,
IracMetadata iracMetadata) |
IracRequestStateCommand(ByteString cacheName) |
IracRequestStateCommand(ByteString cacheName,
IntSet segments) |
IracStateResponseCommand(ByteString cacheName) |
IracStateResponseCommand(ByteString cacheName,
Object key,
Object lockOwner,
IracMetadata tombstone) |
IracUpdateKeyCommand(byte commandId,
ByteString cacheName) |
Modifier and Type | Method and Description |
---|---|
CacheRpcCommand |
ModuleCommandFactory.fromStream(byte commandId,
ByteString cacheName)
Construct and initialize a
CacheRpcCommand based on the command id. |
Modifier and Type | Field and Description |
---|---|
protected ByteString |
BaseRpcCommand.cacheName |
Modifier and Type | Method and Description |
---|---|
ByteString |
BaseRpcCommand.getCacheName() |
ByteString |
CacheRpcCommand.getCacheName() |
ByteString |
CheckTransactionRpcCommand.getCacheName() |
Constructor and Description |
---|
BaseClusteredReadCommand(ByteString cacheName,
long flagBitSet) |
BaseRpcCommand(ByteString cacheName) |
CheckTransactionRpcCommand(ByteString cacheName) |
CheckTransactionRpcCommand(ByteString cacheName,
Collection<GlobalTransaction> gtxToCheck) |
ClusteredGetAllCommand(ByteString cacheName) |
ClusteredGetAllCommand(ByteString cacheName,
List<?> keys,
long flags,
GlobalTransaction gtx) |
ClusteredGetCommand(ByteString cacheName) |
ClusteredGetCommand(Object key,
ByteString cacheName,
int segment,
long flags) |
RenewBiasCommand(ByteString cacheName) |
RenewBiasCommand(ByteString cacheName,
Object[] keys) |
RevokeBiasCommand(ByteString cacheName) |
RevokeBiasCommand(ByteString cacheName,
Address ackTarget,
long id,
int topologyId,
Collection<Object> keys) |
SingleRpcCommand(ByteString cacheName) |
SingleRpcCommand(ByteString cacheName,
VisitableCommand command) |
Constructor and Description |
---|
CompleteTransactionCommand(ByteString cacheName) |
CompleteTransactionCommand(ByteString cacheName,
XidImpl xid,
boolean commit) |
GetInDoubtTransactionsCommand(ByteString cacheName) |
GetInDoubtTxInfoCommand(ByteString cacheName) |
RecoveryCommand(ByteString cacheName)
Deprecated.
|
TxCompletionNotificationCommand(ByteString cacheName) |
TxCompletionNotificationCommand(long internalId,
ByteString cacheName) |
TxCompletionNotificationCommand(XidImpl xid,
GlobalTransaction gtx,
ByteString cacheName) |
Constructor and Description |
---|
MultiEntriesFunctionalBackupWriteCommand(ByteString cacheName) |
MultiKeyFunctionalBackupWriteCommand(ByteString cacheName) |
PutMapBackupWriteCommand(ByteString cacheName) |
SingleKeyBackupWriteCommand(ByteString cacheName) |
SingleKeyFunctionalBackupWriteCommand(ByteString cacheName) |
Modifier and Type | Field and Description |
---|---|
protected ByteString |
AbstractTransactionBoundaryCommand.cacheName |
Modifier and Type | Method and Description |
---|---|
ByteString |
AbstractTransactionBoundaryCommand.getCacheName() |
Constructor and Description |
---|
AbstractTransactionBoundaryCommand(ByteString cacheName) |
CommitCommand(ByteString cacheName) |
CommitCommand(ByteString cacheName,
GlobalTransaction gtx) |
PrepareCommand(ByteString cacheName) |
PrepareCommand(ByteString cacheName,
GlobalTransaction gtx,
boolean onePhaseCommit,
WriteCommand... modifications) |
PrepareCommand(ByteString cacheName,
GlobalTransaction gtx,
List<WriteCommand> commands,
boolean onePhaseCommit) |
RollbackCommand(ByteString cacheName) |
RollbackCommand(ByteString cacheName,
GlobalTransaction globalTransaction) |
VersionedCommitCommand(ByteString cacheName) |
VersionedCommitCommand(ByteString cacheName,
GlobalTransaction gtx) |
VersionedPrepareCommand(ByteString cacheName) |
VersionedPrepareCommand(ByteString cacheName,
GlobalTransaction gtx,
List<WriteCommand> modifications,
boolean onePhase) |
Constructor and Description |
---|
BackupAckCommand(ByteString cacheName) |
BackupAckCommand(ByteString cacheName,
long id,
int topologyId) |
BackupMultiKeyAckCommand(ByteString cacheName) |
BackupMultiKeyAckCommand(ByteString cacheName,
long id,
int segment,
int topologyId) |
ExceptionAckCommand(ByteString cacheName) |
ExceptionAckCommand(ByteString cacheName,
long id,
Throwable throwable,
int topologyId) |
InvalidateVersionsCommand(ByteString cacheName) |
InvalidateVersionsCommand(ByteString cacheName,
int topologyId,
Object[] keys,
int[] topologyIds,
long[] versions,
boolean removed) |
Constructor and Description |
---|
TouchCommand(ByteString cacheName) |
TouchCommand(ByteString cacheName,
Object key,
int segment) |
Modifier and Type | Method and Description |
---|---|
ByteString |
ComponentRegistry.getCacheByteString() |
Modifier and Type | Method and Description |
---|---|
ComponentRegistry |
GlobalComponentRegistry.getNamedComponentRegistry(ByteString name) |
Modifier and Type | Method and Description |
---|---|
protected CacheRpcCommand |
ReplicableCommandExternalizer.fromStream(byte id,
byte type,
ByteString cacheName) |
Constructor and Description |
---|
MultiClusterEventCommand(ByteString cacheName) |
MultiClusterEventCommand(ByteString cacheName,
Map<UUID,Collection<ClusterEvent<K,V>>> events) |
Constructor and Description |
---|
CancelPublisherCommand(ByteString cacheName) |
CancelPublisherCommand(ByteString cacheName,
String requestId) |
InitialPublisherCommand(ByteString cacheName) |
InitialPublisherCommand(ByteString cacheName,
String requestId,
DeliveryGuarantee deliveryGuarantee,
int batchSize,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
boolean entryStream,
boolean trackKeys,
Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<R>> transformer) |
NextPublisherCommand(ByteString cacheName) |
NextPublisherCommand(ByteString cacheName,
String requestId) |
Constructor and Description |
---|
ReductionPublisherRequestCommand(ByteString cacheName) |
ReductionPublisherRequestCommand(ByteString cacheName,
boolean parallelStream,
DeliveryGuarantee deliveryGuarantee,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
boolean entryStream,
Function transformer,
Function finalizer) |
Modifier and Type | Method and Description |
---|---|
ByteString |
GlobalInboundInvocationHandler.getLocalCacheForRemoteSite(String remoteSite,
ByteString remoteCache)
test only! See BackupCacheStoppedTest
|
Modifier and Type | Method and Description |
---|---|
ByteString |
GlobalInboundInvocationHandler.getLocalCacheForRemoteSite(String remoteSite,
ByteString remoteCache)
test only! See BackupCacheStoppedTest
|
Modifier and Type | Method and Description |
---|---|
static ByteString |
ByteString.emptyString() |
static ByteString |
ByteString.fromString(String s) |
ByteString |
ByteString$___Marshaller_8e599c0fc1e9a512b7cdb7c05fb5529744ecac265708e69fd30c5e989237252a.readFrom(org.infinispan.protostream.ImmutableSerializationContext $1,
org.infinispan.protostream.RawProtoStreamReader $2) |
static ByteString |
ByteString.readObject(ObjectInput input) |
Modifier and Type | Method and Description |
---|---|
Class<ByteString> |
ByteString$___Marshaller_8e599c0fc1e9a512b7cdb7c05fb5529744ecac265708e69fd30c5e989237252a.getJavaClass() |
Modifier and Type | Method and Description |
---|---|
static void |
ByteString.writeObject(ObjectOutput output,
ByteString object) |
void |
ByteString$___Marshaller_8e599c0fc1e9a512b7cdb7c05fb5529744ecac265708e69fd30c5e989237252a.writeTo(org.infinispan.protostream.ImmutableSerializationContext $1,
org.infinispan.protostream.RawProtoStreamWriter $2,
ByteString $3) |
Modifier and Type | Method and Description |
---|---|
static void |
LogFactory.pushNDC(ByteString cacheName,
boolean isTrace) |
CacheConfigurationException |
Log.xsiteCacheNotFound(String remoteSite,
ByteString cacheName) |
CacheConfigurationException |
Log_$logger.xsiteCacheNotFound(String remoteSite,
ByteString cacheName) |
CacheConfigurationException |
Log.xsiteCacheNotStarted(String origin,
ByteString cacheName) |
CacheConfigurationException |
Log_$logger.xsiteCacheNotStarted(String origin,
ByteString cacheName) |
CacheConfigurationException |
Log.xsiteInLocalCache(String origin,
ByteString cacheName) |
CacheConfigurationException |
Log_$logger.xsiteInLocalCache(String origin,
ByteString cacheName) |
Constructor and Description |
---|
SingleXSiteRpcCommand(ByteString cacheName) |
SingleXSiteRpcCommand(ByteString cacheName,
VisitableCommand command) |
XSiteReplicateCommand(byte commandId,
ByteString cacheName) |
Modifier and Type | Method and Description |
---|---|
static XSiteStateTransferFinishReceiveCommand |
XSiteStateTransferFinishReceiveCommand.copyForCache(XSiteStateTransferFinishReceiveCommand command,
ByteString cacheName) |
static XSiteStateTransferStartReceiveCommand |
XSiteStateTransferStartReceiveCommand.copyForCache(XSiteStateTransferStartReceiveCommand command,
ByteString cacheName) |
Constructor and Description |
---|
XSiteStatePushCommand(ByteString cacheName) |
XSiteStatePushCommand(ByteString cacheName,
XSiteState[] chunk,
long timeoutMillis) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.