|
CCF
|
#include <seqnos_by_key_in_memory.h>
Inherits ccf::indexing::strategies::SeqnosByKey_InMemory_Untyped.
Public Member Functions | |
| SeqnosByKey_InMemory (const M &map) | |
| std::optional< SeqNoCollection > | get_write_txs_in_range (const typename M::Key &key, ccf::SeqNo from, ccf::SeqNo to, std::optional< size_t > max_seqnos=std::nullopt) |
| std::optional< SeqNoCollection > | get_all_write_txs (const typename M::Key &key) |
Public Member Functions inherited from ccf::indexing::strategies::SeqnosByKey_InMemory_Untyped | |
| SeqnosByKey_InMemory_Untyped (const std::string &map_name_) | |
Public Member Functions inherited from ccf::indexing::strategies::VisitEachEntryInMap | |
| VisitEachEntryInMap (const std::string &map_name_, const std::string &strategy_prefix="VisitEachEntryIn") | |
| ~VisitEachEntryInMap () override=default | |
| void | handle_committed_transaction (const ccf::TxID &tx_id, const ccf::kv::ReadOnlyStorePtr &store) override |
| std::optional< ccf::SeqNo > | next_requested () override |
| nlohmann::json | describe () override |
| ccf::TxID | get_indexed_watermark () |
Public Member Functions inherited from ccf::indexing::Strategy | |
| Strategy (std::string name) | |
| virtual | ~Strategy ()=default |
| std::string | get_name () const |
| virtual void | tick () |
Additional Inherited Members | |
Protected Member Functions inherited from ccf::indexing::strategies::SeqnosByKey_InMemory_Untyped | |
| void | visit_entry (const ccf::TxID &tx_id, const ccf::ByteVector &k, const ccf::ByteVector &v) override |
| std::optional< SeqNoCollection > | get_write_txs_impl (const ccf::ByteVector &serialised_key, ccf::SeqNo from, ccf::SeqNo to, std::optional< size_t > max_seqnos=std::nullopt) |
Protected Attributes inherited from ccf::indexing::strategies::SeqnosByKey_InMemory_Untyped | |
| std::unordered_map< ccf::ByteVector, SeqNoCollection > | seqnos_by_key |
| ccf::pal::Mutex | lock |
Protected Attributes inherited from ccf::indexing::strategies::VisitEachEntryInMap | |
| std::string | map_name |
| ccf::pal::Mutex | current_txid_lock |
| ccf::TxID | current_txid = {} |
|
inline |
|
inline |
|
inline |