| 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.
|
| CorePackageImpl | |
| 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. |
| StateTransferInterceptor |
This interceptor has two tasks:
If the command's topology id is higher than the current topology id,
wait for the node to receive transaction data for the new topology id.
If the topology id changed during a command's execution, retry the command, but only on the
originator (which replicates it to the new owners).
If the cache is configured with asynchronous replication, owners cannot signal to the originator that they
saw a new topology, so instead each owner forwards the command to all the other owners in the new topology.
|
| 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 |
|---|---|
| RebalanceType |
| Exception | Description |
|---|---|
| AllOwnersLostException |
Signals that all owners of a key have been lost.
|
| OutdatedTopologyException |
An exception signalling that a command should be retried because a newer topology was seen during execution.
|
Copyright © 2021 JBoss by Red Hat. All rights reserved.