Interface | Description |
---|---|
StateConsumer |
Handles inbound state transfers.
|
StateConsumerImpl.KeyInvalidationListener | |
StateProvider |
Handles outbound state transfers.
|
StateTransferLock |
We use the state transfer lock for three different things:
We don't want to execute a command until we have the transaction table for that topology id.
|
StateTransferManager |
A component that manages the state transfer when the topology of the cluster changes.
|
Class | Description |
---|---|
CommitManager |
Keeps track of the keys updated by normal operation and state transfer.
|
InboundTransferTask |
Inbound state transfer task.
|
OutboundTransferTask |
Outbound state transfer task.
|
StateChunk |
Encapsulates a chunk of cache entries that belong to the same segment.
|
StateChunk.Externalizer | |
StateConsumerImpl |
StateConsumer implementation. |
StateProviderImpl |
StateProvider implementation. |
StateRequestCommand |
This command is used by a StateConsumer to request transactions and cache entries from a StateProvider.
|
StateResponseCommand |
This command is used by a StateProvider to push cache entries to a StateConsumer.
|
StateTransferInterceptor | Deprecated
Since 8.2, no longer public API.
|
StateTransferLockImpl |
StateTransferLock implementation. |
StateTransferManagerImpl |
StateTransferManager implementation. |
TransactionInfo |
A representation of a transaction that is suitable for transferring between a StateProvider and a StateConsumer
running on different members of the same cache.
|
TransactionInfo.Externalizer | |
TransactionSynchronizerInterceptor |
With the Non-Blocking State Transfer (NBST) in place it is possible for a transactional command to be forwarded
multiple times, concurrently to the same node.
|
Enum | Description |
---|---|
StateRequestCommand.Type |
Exception | Description |
---|---|
OutdatedTopologyException |
An exception signalling that a command should be retried because it was executed with an outdated
topology.
|
Copyright © 2022 JBoss, a division of Red Hat. All rights reserved.