CCF
Loading...
Searching...
No Matches
Public Member Functions | List of all members
ccf::indexing::strategies::SeqnosByKey_Bucketed< M > Class Template Reference

#include <seqnos_by_key_bucketed.h>

Inherits ccf::indexing::strategies::SeqnosByKey_Bucketed_Untyped.

Public Member Functions

 SeqnosByKey_Bucketed (const M &map, ccf::AbstractNodeContext &node_context, size_t seqnos_per_bucket_=1000, size_t max_buckets_=10)
 
std::optional< SeqNoCollectionget_write_txs_in_range (const typename M::Key &key, 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)
 
- Public Member Functions inherited from 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)
 
size_t max_requestable_range () const
 
- Public Member Functions inherited from ccf::indexing::strategies::VisitEachEntryInMap
 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::SeqNonext_requested () override
 
nlohmann::json describe () override
 
ccf::TxID get_indexed_watermark ()
 
- Public Member Functions inherited from ccf::indexing::Strategy
 Strategy (const 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_Bucketed_Untyped
void visit_entry (const ccf::TxID &tx_id, const ccf::ByteVector &k, const ccf::ByteVector &v) override
 
nlohmann::json describe () override
 
std::optional< SeqNoCollectionget_write_txs_impl (const ccf::ByteVector &serialised_key, ccf::SeqNo from, ccf::SeqNo to)
 
- Protected Attributes inherited from ccf::indexing::strategies::SeqnosByKey_Bucketed_Untyped
std::shared_ptr< Implimpl = nullptr
 
- Protected Attributes inherited from ccf::indexing::strategies::VisitEachEntryInMap
std::string map_name
 
ccf::pal::Mutex current_txid_lock
 
ccf::TxID current_txid = {}
 

Constructor & Destructor Documentation

◆ SeqnosByKey_Bucketed()

template<typename M >
ccf::indexing::strategies::SeqnosByKey_Bucketed< M >::SeqnosByKey_Bucketed ( const M &  map,
ccf::AbstractNodeContext node_context,
size_t  seqnos_per_bucket_ = 1000,
size_t  max_buckets_ = 10 
)
inline

Member Function Documentation

◆ get_write_txs_in_range()

template<typename M >
std::optional< SeqNoCollection > ccf::indexing::strategies::SeqnosByKey_Bucketed< M >::get_write_txs_in_range ( const typename M::Key &  key,
ccf::SeqNo  from,
ccf::SeqNo  to 
)
inline

◆ SeqnosByKey_Bucketed_Untyped()

template<typename M >
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 
)

The documentation for this class was generated from the following file: