public interface CustomFailurePolicy<K,V>
BackupFailureException
to signal that they want the intra-site operation to
fail as well. If handle methods don't throw any exception then the operation will succeed in the local cluster. For
convenience, there is a support implementation of this class: AbstractCustomFailurePolicy
Lifecycle: the same instance is invoked during the lifecycle of a cache so it is allowed to hold state between
invocations.
Threadsafety: instances of this class might be invoked from different threads and they should be synchronized.BackupFailureException
Modifier and Type | Method and Description |
---|---|
void |
handleClearFailure(String site) |
void |
handleCommitFailure(String site,
Transaction transaction) |
default void |
handleComputeFailure(String site,
K key,
BiFunction<? super K,? super V,? extends V> remappingFunction,
boolean computeIfPresent) |
default void |
handleComputeIfAbsentFailure(String site,
K key,
Function<? super K,? extends V> mappingFunction) |
void |
handlePrepareFailure(String site,
Transaction transaction) |
void |
handlePutAllFailure(String site,
Map<K,V> map) |
void |
handlePutFailure(String site,
K key,
V value,
boolean putIfAbsent) |
default void |
handleReadWriteKeyFailure(String site,
K key) |
default void |
handleReadWriteKeyValueFailure(String site,
K key) |
default void |
handleReadWriteManyEntriesFailure(String site,
Map<? extends K,? extends V> keys) |
default void |
handleReadWriteManyFailure(String site,
Collection<? extends K> keys) |
void |
handleRemoveFailure(String site,
K key,
V oldValue) |
void |
handleReplaceFailure(String site,
K key,
V oldValue,
V newValue) |
void |
handleRollbackFailure(String site,
Transaction transaction) |
default void |
handleWriteOnlyKeyFailure(String site,
K key) |
default void |
handleWriteOnlyKeyValueFailure(String site,
K key) |
default void |
handleWriteOnlyManyEntriesFailure(String site,
Map<? extends K,? extends V> key) |
default void |
handleWriteOnlyManyFailure(String site,
Collection<? extends K> key) |
void |
init(Cache<K,V> cache)
Invoked during the initialization phase.
|
default void handleComputeFailure(String site, K key, BiFunction<? super K,? super V,? extends V> remappingFunction, boolean computeIfPresent)
default void handleComputeIfAbsentFailure(String site, K key, Function<? super K,? extends V> mappingFunction)
default void handleReadWriteManyFailure(String site, Collection<? extends K> keys)
default void handleReadWriteManyEntriesFailure(String site, Map<? extends K,? extends V> keys)
default void handleWriteOnlyManyFailure(String site, Collection<? extends K> key)
default void handleWriteOnlyManyEntriesFailure(String site, Map<? extends K,? extends V> key)
void handleClearFailure(String site)
void handlePrepareFailure(String site, Transaction transaction)
void handleRollbackFailure(String site, Transaction transaction)
void handleCommitFailure(String site, Transaction transaction)
Copyright © 2021 JBoss by Red Hat. All rights reserved.