public interface AtomicKVStore extends KVStore
KVStoreinterface for implementations that support atomic, batched reads and writes.
Atomic batch reads are available via
snapshot(), which returns a consistent point-in-time views of the
Atomic batch writes are available via
mutate(), which applies a set of mutations in an "all or none" fashion.
|Modifier and Type||Method and Description|
Apply a set of mutations to this instance atomically.
Acquire a read-only, snapshot view of this instance based on the current state.
Start this instance.
Stop this instance.
This method is idempotent: if this instance is already started, nothing happens.
Whether an instance that has been started and stopped can be restarted is implementation-dependent.
IllegalStateException- if this instance is not properly configured
KVStore view should remain constant even if this instance is subsequently mutated.
Note: callers are required to
close the returned instance when no longer in use.
void mutate(Mutations mutations, boolean sync)
If this method returns normally, all of the given mutations will have been applied. If this method returns abnormally, then none of the given mutations will have been applied.
In any case, other threads observing this instance will never see a partial application of the given mutations.
This method is required to apply the mutations in this order: removes, puts, adjusts.
sync is true, the implementation must durably persist the changes before returning.
mutations- the mutations to apply
sync- if true, caller requires that the changes be durably persisted
StaleTransactionException- if an underlying transaction is no longer usable
RetryTransactionException- if an underlying transaction must be retried and is no longer usable
syncis true and this implementation cannot guarantee durability
IllegalStateException- if this instance is not
Copyright © 2021. All rights reserved.