1 #ifndef GET_BLOB_CALLBACK__HPP
2 #define GET_BLOB_CALLBACK__HPP
43 const unsigned char * chunk_data,
44 unsigned int data_size,
53 const string & message)>;
74 const unsigned char * chunk_data,
75 unsigned int data_size,
int chunk_no)
104 shared_ptr<CPSGS_Request> request,
105 shared_ptr<CPSGS_Reply> reply,
125 m_Reply->SendTrace(
"Cassandra blob props: " +
129 m_Reply->SendTrace(
"Cassandra blob props not found",
187 const string & message)
TBlobChunkCB m_BlobChunkCB
psg_time_point_t m_BlobRetrieveTiming
CCassBlobFetch * m_FetchDetails
EPSGOperation m_RetrieveStatistic
CBlobChunkCallback(IPSGS_Processor *processor, TBlobChunkCB blob_chunk_cb, CCassBlobFetch *fetch_details, EPSGOperation retrieve_statistic=eBlobRetrieve)
IPSGS_Processor * m_Processor
void operator()(CBlobRecord const &blob, const unsigned char *chunk_data, unsigned int data_size, int chunk_no)
void operator()(CBlobRecord const &blob, bool is_found)
TBlobPropsCB m_BlobPropCB
shared_ptr< CPSGS_Reply > m_Reply
CCassBlobFetch * m_FetchDetails
psg_time_point_t m_BlobPropTiming
CBlobPropCallback(IPSGS_Processor *processor, TBlobPropsCB blob_prop_cb, shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply, CCassBlobFetch *fetch_details, bool need_timing)
shared_ptr< CPSGS_Request > m_Request
IPSGS_Processor * m_Processor
EPSGOperation m_RetrieveStatistic
CCassBlobFetch * m_FetchDetails
CGetBlobErrorCallback(IPSGS_Processor *processor, TBlobErrorCB blob_error_cb, CCassBlobFetch *fetch_details, EPSGOperation retrieve_statistic=eBlobRetrieve)
void operator()(CRequestStatus::ECode status, int code, EDiagSev severity, const string &message)
TBlobErrorCB m_BlobErrorCB
psg_time_point_t m_BlobRetrieveTiming
IPSGS_Processor * m_Processor
uint64_t Register(IPSGS_Processor *processor, EPSGOperation operation, EPSGOperationStatus status, const psg_time_point_t &op_begin_ts, size_t blob_size=0)
COperationTiming & GetTiming(void)
static CPubseqGatewayApp * GetInstance(void)
Interface class (and self-factory) for request processor objects that can retrieve data from a given ...
function< void(CCassBlobFetch *fetch_details, CRequestStatus::ECode status, int code, EDiagSev severity, const string &message)> TBlobErrorCB
function< void(CCassBlobFetch *fetch_details, CBlobRecord const &blob, bool is_found)> TBlobPropsCB
function< void(CCassBlobFetch *fetch_details, CBlobRecord const &blob, const unsigned char *chunk_data, unsigned int data_size, int chunk_no)> TBlobChunkCB
EDiagSev
Severity level for the posted diagnostics.
string ToJsonString(const CBioseqInfoRecord &bioseq_info, SPSGS_ResolveRequest::TPSGS_BioseqIncludeData include_data_flags, const string &custom_blob_id)
chrono::steady_clock psg_clock_t
psg_clock_t::time_point psg_time_point_t