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) |
![]() | |
SeqnosByKey_InMemory_Untyped (const std::string &map_name_) | |
![]() | |
VisitEachEntryInMap (const std::string &map_name_, const std::string &strategy_prefix="VisitEachEntryIn") | |
virtual | ~VisitEachEntryInMap ()=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 () |
![]() | |
Strategy (const std::string &name) | |
virtual | ~Strategy ()=default |
std::string | get_name () const |
virtual void | tick () |
Additional Inherited Members | |
![]() | |
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) |
![]() | |
std::unordered_map< ccf::ByteVector, SeqNoCollection > | seqnos_by_key |
ccf::pal::Mutex | lock |
![]() | |
std::string | map_name |
ccf::pal::Mutex | current_txid_lock |
ccf::TxID | current_txid = {} |
|
inline |
|
inline |
|
inline |