SWC-DB  v0.5.12 C++ documentations
SWC-DB© (Super Wide Column Database) - High Performance Scalable Database (https://github.com/kashirin-alex/swc-db)
SWC::DB::RgrData::SyncSelector Class Reference

#include <swcdb/db/Columns/RgrData.h>

+ Inheritance diagram for SWC::DB::RgrData::SyncSelector:
+ Collaboration diagram for SWC::DB::RgrData::SyncSelector:

Public Types

typedef std::shared_ptr< SyncSelectorPtr
 
- Public Types inherited from SWC::DB::RgrData::BaseSelector
typedef std::shared_ptr< BaseSelectorPtr
 
- Public Types inherited from SWC::client::Query::Select::Handlers::BaseSingleColumn
typedef std::shared_ptr< BaseSingleColumnPtr
 
- Public Types inherited from SWC::client::Query::Select::Handlers::Base
typedef std::shared_ptr< BasePtr
 

Public Member Functions

SWC_CAN_INLINE SyncSelector () noexcept
 
 SyncSelector (const SyncSelector &)=delete
 
 SyncSelector (SyncSelector &&)=delete
 
SyncSelectoroperator= (const SyncSelector &)=delete
 
SyncSelectoroperator= (SyncSelector &&)=delete
 
void callback () override
 
virtual ~SyncSelector () noexcept
 
- Public Member Functions inherited from SWC::DB::RgrData::BaseSelector
SWC_CAN_INLINE BaseSelector ()
 
bool valid () noexcept override
 
void response (int err) override
 
void scan (cid_t a_cid, rid_t a_rid)
 
void get_rgr (int &err, DB::RgrData &data) noexcept
 
- Public Member Functions inherited from SWC::client::Query::Select::Handlers::BaseSingleColumn
SWC_CAN_INLINE BaseSingleColumn (const Clients::Ptr &a_clients, const cid_t a_cid, Clients::Flag a_executor=Clients::DEFAULT) noexcept
 
virtual ~BaseSingleColumn () noexcept
 
virtual void error (const cid_t _cid, int err) override
 
virtual bool add_cells (const cid_t _cid, StaticBuffer &buffer, bool reached_limit, DB::Specs::Interval &interval) override
 
virtual size_t get_size_bytes () noexcept override
 
virtual size_t get_size () noexcept
 
virtual bool empty () noexcept
 
virtual void get_cells (DB::Cells::Result &cells)
 
virtual void error (const cid_t cid, int err)=0
 
virtual int error () noexcept
 
virtual void error (int err) noexcept
 
- Public Member Functions inherited from SWC::client::Query::Select::Handlers::Base
SWC_CAN_INLINE Base (const Clients::Ptr &a_clients, Clients::Flag a_executor=Clients::DEFAULT) noexcept
 
 Base (Base &&)=delete
 
 Base (const Base &)=delete
 
Baseoperator= (const Base &)=delete
 
Baseoperator= (Base &&)=delete
 
virtual void error (int err) noexcept
 
SWC_CAN_INLINE void scan (const DB::Schema::Ptr &schema, const DB::Specs::Interval &intval)
 
SWC_CAN_INLINE void scan (const DB::Schema::Ptr &schema, DB::Specs::Interval &&intval)
 
SWC_CAN_INLINE void scan (DB::Types::KeySeq key_seq, cid_t cid, const DB::Specs::Interval &intval)
 
SWC_CAN_INLINE void scan (DB::Types::KeySeq key_seq, cid_t cid, DB::Specs::Interval &&intval)
 
SWC_CAN_INLINE void scan (int &err, const DB::Specs::Scan &specs)
 
SWC_CAN_INLINE void scan (int &err, DB::Specs::Scan &&specs)
 

Public Attributes

Core::StateSynchronization await
 
- Public Attributes inherited from SWC::client::Query::Select::Handlers::BaseSingleColumn
const cid_t cid
 
- Public Attributes inherited from SWC::client::Query::Select::Handlers::Base
Clients::Ptr clients
 
Profiling profile
 
Core::Atomic< int > state_error
 
Core::CompletionCounter< uint64_t > completion
 
Core::Atomic< uint32_t > timeout
 
Core::Atomic< uint32_t > buff_sz
 
Core::Atomic< uint8_t > buff_ahead
 
const Clients::Flag executor
 

Additional Inherited Members

- Protected Member Functions inherited from SWC::DB::RgrData::BaseSelector
virtual ~BaseSelector () noexcept
 
- Protected Member Functions inherited from SWC::client::Query::Select::Handlers::Base
virtual void _execute (DB::Types::KeySeq key_seq, cid_t cid, const DB::Specs::Interval &intval)
 
virtual void _execute (DB::Types::KeySeq key_seq, cid_t cid, DB::Specs::Interval &&intval)
 
virtual void _execute (int &err, const DB::Specs::Scan &specs)
 
virtual void _execute (int &err, DB::Specs::Scan &&specs)
 
virtual ~Base () noexcept
 

Detailed Description

Definition at line 300 of file RgrData.h.

Member Typedef Documentation

◆ Ptr

Definition at line 302 of file RgrData.h.

Constructor & Destructor Documentation

◆ SyncSelector() [1/3]

SWC_CAN_INLINE SWC::DB::RgrData::SyncSelector::SyncSelector ( )
inlinenoexcept

Definition at line 305 of file RgrData.h.

◆ SyncSelector() [2/3]

SWC::DB::RgrData::SyncSelector::SyncSelector ( const SyncSelector )
delete

◆ SyncSelector() [3/3]

SWC::DB::RgrData::SyncSelector::SyncSelector ( SyncSelector &&  )
delete

◆ ~SyncSelector()

virtual SWC::DB::RgrData::SyncSelector::~SyncSelector ( )
inlinevirtualnoexcept

Definition at line 314 of file RgrData.h.

Member Function Documentation

◆ callback()

void SWC::DB::RgrData::SyncSelector::callback ( )
inlineoverridevirtual

Implements SWC::DB::RgrData::BaseSelector.

Definition at line 310 of file RgrData.h.

References SWC::Core::StateSynchronization::acknowledge(), and await.

+ Here is the call graph for this function:

◆ operator=() [1/2]

SyncSelector& SWC::DB::RgrData::SyncSelector::operator= ( const SyncSelector )
delete

◆ operator=() [2/2]

SyncSelector& SWC::DB::RgrData::SyncSelector::operator= ( SyncSelector &&  )
delete

Member Data Documentation

◆ await

Core::StateSynchronization SWC::DB::RgrData::SyncSelector::await

Definition at line 303 of file RgrData.h.

Referenced by callback().


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