CCF
|
#include <seqnos_by_key_bucketed.h>
Inherits ccf::indexing::strategies::SeqnosByKey_Bucketed_Untyped.
Public Member Functions | |
SeqnosForValue_Bucketed (const V &value, ccf::AbstractNodeContext &node_context, size_t seqnos_per_bucket_=1000, size_t max_buckets_=10) | |
std::optional< SeqNoCollection > | get_write_txs_in_range (ccf::SeqNo from, ccf::SeqNo to) |
SeqnosByKey_Bucketed_Untyped (const std::string &map_name_, ccf::AbstractNodeContext &node_context, size_t seqnos_per_bucket_=1000, size_t max_buckets_=10) | |
![]() | |
SeqnosByKey_Bucketed_Untyped (const std::string &map_name_, ccf::AbstractNodeContext &node_context, size_t seqnos_per_bucket_=1000, size_t max_buckets_=10) | |
size_t | max_requestable_range () const |
![]() | |
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 |
nlohmann::json | describe () override |
std::optional< SeqNoCollection > | get_write_txs_impl (const ccf::ByteVector &serialised_key, ccf::SeqNo from, ccf::SeqNo to) |
![]() | |
std::shared_ptr< Impl > | impl = nullptr |
![]() | |
std::string | map_name |
ccf::pal::Mutex | current_txid_lock |
ccf::TxID | current_txid = {} |
|
inline |
|
inline |
ccf::indexing::strategies::SeqnosByKey_Bucketed_Untyped::SeqnosByKey_Bucketed_Untyped | ( | const std::string & | map_name_, |
ccf::AbstractNodeContext & | node_context, | ||
size_t | seqnos_per_bucket_ = 1000 , |
||
size_t | max_buckets_ = 10 |
||
) |