|
SWC-DB
v0.5.12 C++ documentations
SWC-DB© (Super Wide Column Database) - High Performance Scalable Database (https://github.com/kashirin-alex/swc-db)
|
Go to the documentation of this file.
6 #ifndef swcdb_db_protocol_rgr_req_RangeQueryUpdate_h
7 #define swcdb_db_protocol_rgr_req_RangeQueryUpdate_h
16 namespace SWC {
namespace Comm {
namespace Protocol {
17 namespace Rgr {
namespace Req {
20 template<
typename DataT>
24 typedef std::shared_ptr<RangeQueryUpdate>
Ptr;
27 template<
typename... DataArgsT>
32 const uint32_t timeout,
33 DataArgsT&&... args) {
40 template<
typename... DataArgsT>
45 const uint32_t timeout,
46 DataArgsT&&... args) {
48 return make(params, snd_buf, timeout, args...);
53 req->data.get_clients()->get_rgr_queue(endpoints)->put(
req);
56 template<
typename... DataArgsT>
61 const uint32_t timeout,
63 DataArgsT&&... args) {
64 request(
make(params, snd_buf, timeout, args...), endpoints);
67 template<
typename... DataArgsT>
72 const uint32_t timeout,
74 DataArgsT&&... args) {
75 request(
make(params, buffer, timeout, args...), endpoints);
105 template<
typename... DataArgsT>
108 : client::ConnQueue::
ReqBase(std::move(a_cbp)),
145 #endif // swcdb_db_protocol_rgr_req_RangeQueryUpdate_h
virtual ~RangeQueryUpdate() noexcept
static SWC_CAN_INLINE Ptr make(const Params::RangeQueryUpdateReq ¶ms, StaticBuffer &snd_buf, const uint32_t timeout, DataArgsT &&... args)
SWC_CAN_INLINE Ptr req() noexcept
std::shared_ptr< Buffers > Ptr
void handle(ConnHandlerPtr, const Event::Ptr &ev) override
Comm::client::ConnQueue::ReqBase ReqBase
Common::Req::function< std::function< void(void *, const client::ConnQueue::ReqBase::Ptr &, const Params::RangeQueryUpdateRsp &)>> Functional_RangeQueryUpdate
static SWC_CAN_INLINE Ptr make(const Params::RangeQueryUpdateReq ¶ms, const DynamicBuffer &buffer, const uint32_t timeout, DataArgsT &&... args)
void handle_no_conn() override
std::shared_ptr< RangeQueryUpdate > Ptr
SWC_CAN_INLINE RangeQueryUpdate(Buffers::Ptr &&a_cbp, DataArgsT &&... args)
The SWC-DB C++ namespace 'SWC'.
RangeQueryUpdate(RangeQueryUpdate &&)=delete
std::shared_ptr< ConnHandler > ConnHandlerPtr
RangeQueryUpdate(const RangeQueryUpdate &)=delete
constexpr SWC_CAN_INLINE size_t fill() const noexcept
RangeQueryUpdate & operator=(RangeQueryUpdate &&)=delete
static SWC_CAN_INLINE Ptr make(uint32_t reserve=0)
static SWC_CAN_INLINE void request(const Ptr &req, const EndPoints &endpoints)
static SWC_CAN_INLINE void request(const Params::RangeQueryUpdateReq ¶ms, const DynamicBuffer &buffer, const uint32_t timeout, const EndPoints &endpoints, DataArgsT &&... args)
std::shared_ptr< Event > Ptr
std::shared_ptr< ConnQueueReqBase > Ptr
static SWC_CAN_INLINE void request(const Params::RangeQueryUpdateReq ¶ms, StaticBuffer &snd_buf, const uint32_t timeout, const EndPoints &endpoints, DataArgsT &&... args)
RangeQueryUpdate & operator=(const RangeQueryUpdate &)=delete