SWC-DB  v0.5.12 C++ documentations
SWC-DB© (Super Wide Column Database) - High Performance Scalable Database (https://github.com/kashirin-alex/swc-db)
Public Types | Public Member Functions | Public Attributes | List of all members
SWC::client::Query::Update::Handlers::BaseSingleColumn Class Reference

#include <swcdb/db/client/Query/Update/Handlers/BaseSingleColumn.h>

+ Inheritance diagram for SWC::client::Query::Update::Handlers::BaseSingleColumn:
+ Collaboration diagram for SWC::client::Query::Update::Handlers::BaseSingleColumn:

Public Types

typedef std::shared_ptr< BaseSingleColumn > Ptr
 
- Public Types inherited from SWC::client::Query::Update::Handlers::Base
typedef std::shared_ptr< Base > Ptr
 
typedef Core::Vector< Column * > Colms
 

Public Member Functions

SWC_CAN_INLINE BaseSingleColumn (const Clients::Ptr &a_clients, const cid_t cid, DB::Types::KeySeq seq, uint32_t versions, uint32_t ttl_secs, DB::Types::Column type, Clients::Flag a_executor=Clients::DEFAULT)
 
SWC_CAN_INLINE BaseSingleColumn (const Clients::Ptr &a_clients, const cid_t cid, DB::Types::KeySeq seq, uint32_t versions, uint32_t ttl_secs, DB::Types::Column type, const StaticBuffer &buffer)
 
virtual ~BaseSingleColumn () noexcept
 
virtual bool requires_commit () noexcept override
 
virtual bool empty () noexcept override
 
virtual size_t size_bytes () noexcept override
 
virtual void next (Base::Colms &cols) noexcept override
 
virtual Base::Column * next (cid_t cid) noexcept override
 
virtual void error (cid_t cid, int err) noexcept override
 
SWC_CAN_INLINE size_t size () noexcept
 
- Public Member Functions inherited from SWC::client::Query::Update::Handlers::Base
SWC_CAN_INLINE Base (const Clients::Ptr &a_clients, Clients::Flag a_executor=Clients::Flag::DEFAULT) noexcept
 
 Base (Base &&)=delete
 
 Base (const Base &)=delete
 
Base & operator= (const Base &)=delete
 
Base & operator= (Base &&)=delete
 
virtual bool valid () noexcept=0
 
virtual void response (int err=Error::OK)=0
 
virtual int error () noexcept
 
virtual void error (int err) noexcept
 
SWC_CAN_INLINE void add_resend_count (size_t count) noexcept
 
SWC_CAN_INLINE size_t get_resend_count (bool reset=true) noexcept
 
void commit ()
 
SWC_CAN_INLINE void commit (const cid_t cid)
 
void commit (Column *colp)
 

Public Attributes

ColumnMutable column
 
- Public Attributes inherited from SWC::client::Query::Update::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 > timeout_ratio
 
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::client::Query::Update::Handlers::Base
virtual void _execute (Column *colp)
 
virtual ~Base () noexcept
 

Detailed Description

Definition at line 18 of file BaseSingleColumn.h.

Member Typedef Documentation

◆ Ptr

typedef std::shared_ptr<BaseSingleColumn> SWC::client::Query::Update::Handlers::BaseSingleColumn::Ptr

Definition at line 20 of file BaseSingleColumn.h.

Constructor & Destructor Documentation

◆ BaseSingleColumn() [1/2]

SWC_CAN_INLINE SWC::client::Query::Update::Handlers::BaseSingleColumn::BaseSingleColumn ( const Clients::Ptr &  a_clients,
const cid_t  cid,
DB::Types::KeySeq  seq,
uint32_t  versions,
uint32_t  ttl_secs,
DB::Types::Column  type,
Clients::Flag  a_executor = Clients::DEFAULT 
)
inline

Definition at line 27 of file BaseSingleColumn.h.

◆ BaseSingleColumn() [2/2]

SWC_CAN_INLINE SWC::client::Query::Update::Handlers::BaseSingleColumn::BaseSingleColumn ( const Clients::Ptr &  a_clients,
const cid_t  cid,
DB::Types::KeySeq  seq,
uint32_t  versions,
uint32_t  ttl_secs,
DB::Types::Column  type,
const StaticBuffer &  buffer 
)
inline

Definition at line 37 of file BaseSingleColumn.h.

◆ ~BaseSingleColumn()

virtual SWC::client::Query::Update::Handlers::BaseSingleColumn::~BaseSingleColumn ( )
inlinevirtualnoexcept

Definition at line 46 of file BaseSingleColumn.h.

Member Function Documentation

◆ empty()

virtual bool SWC::client::Query::Update::Handlers::BaseSingleColumn::empty ( )
inlineoverridevirtualnoexcept

Implements SWC::client::Query::Update::Handlers::Base.

Definition at line 53 of file BaseSingleColumn.h.

References column, and SWC::client::Query::Update::Handlers::ColumnMutable::empty().

Referenced by SWC::Ranger::Query::Update::BaseMeta::is_last_rsp(), SWC::Comm::Protocol::Bkr::Handler::Updater::response(), SWC::client::Query::Update::Handlers::Metric::Reporting::response(), and SWC::DB::RgrData::BaseUpdater::response().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ error()

virtual void SWC::client::Query::Update::Handlers::BaseSingleColumn::error ( cid_t  cid,
int  err 
)
inlineoverridevirtualnoexcept

Implements SWC::client::Query::Update::Handlers::Base.

Definition at line 71 of file BaseSingleColumn.h.

References SWC::client::Query::Update::Handlers::ColumnMutable::cid, SWC::Error::CLIENT_MISMATCHED_CID, column, SWC::client::Query::Update::Handlers::Base::error(), and SWC::client::Query::Update::Handlers::ColumnMutable::error().

+ Here is the call graph for this function:

◆ next() [1/2]

virtual void SWC::client::Query::Update::Handlers::BaseSingleColumn::next ( Base::Colms &  cols)
inlineoverridevirtualnoexcept

Implements SWC::client::Query::Update::Handlers::Base.

Definition at line 61 of file BaseSingleColumn.h.

References column, and requires_commit().

+ Here is the call graph for this function:

◆ next() [2/2]

virtual Base::Column* SWC::client::Query::Update::Handlers::BaseSingleColumn::next ( cid_t  cid)
inlineoverridevirtualnoexcept

Implements SWC::client::Query::Update::Handlers::Base.

Definition at line 67 of file BaseSingleColumn.h.

References SWC::client::Query::Update::Handlers::ColumnMutable::cid, column, and requires_commit().

+ Here is the call graph for this function:

◆ requires_commit()

virtual bool SWC::client::Query::Update::Handlers::BaseSingleColumn::requires_commit ( )
inlineoverridevirtualnoexcept

Implements SWC::client::Query::Update::Handlers::Base.

Definition at line 49 of file BaseSingleColumn.h.

References column, SWC::client::Query::Update::Handlers::ColumnMutable::empty(), SWC::client::Query::Update::Handlers::Base::error(), and SWC::client::Query::Update::Handlers::ColumnMutable::error().

Referenced by SWC::Ranger::Query::Update::BaseMeta::is_last_rsp(), next(), SWC::Comm::Protocol::Bkr::Handler::Updater::response(), SWC::client::Query::Update::Handlers::Metric::Reporting::response(), and SWC::DB::RgrData::BaseUpdater::response().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ size()

SWC_CAN_INLINE size_t SWC::client::Query::Update::Handlers::BaseSingleColumn::size ( )
inlinenoexcept

Definition at line 80 of file BaseSingleColumn.h.

References column, and SWC::client::Query::Update::Handlers::ColumnMutable::size().

+ Here is the call graph for this function:

◆ size_bytes()

virtual size_t SWC::client::Query::Update::Handlers::BaseSingleColumn::size_bytes ( )
inlineoverridevirtualnoexcept

Implements SWC::client::Query::Update::Handlers::Base.

Definition at line 57 of file BaseSingleColumn.h.

References column, and SWC::client::Query::Update::Handlers::ColumnMutable::size_bytes().

+ Here is the call graph for this function:

Member Data Documentation

◆ column

ColumnMutable SWC::client::Query::Update::Handlers::BaseSingleColumn::column

Definition at line 24 of file BaseSingleColumn.h.

Referenced by empty(), error(), SWC::Ranger::Query::Update::BaseMeta::is_last_rsp(), next(), SWC::DB::RgrData::BaseUpdater::remove_rgr(), SWC::client::Query::Update::Handlers::Metric::Reporting::report(), requires_commit(), SWC::Comm::Protocol::Bkr::Handler::Updater::response(), SWC::client::Query::Update::Handlers::Metric::Reporting::response(), SWC::DB::RgrData::BaseUpdater::response(), SWC::DB::RgrData::BaseUpdater::set_rgr(), size(), and size_bytes().

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