FETPAPI 0.3.0.0
This project provides C++ classes which facilitate the developement of ETP1.2 clients and servers.
|
Public Member Functions | |
StoreHandlers (AbstractSession *mySession) | |
void | decodeMessageBody (const Energistics::Etp::v12::Datatypes::MessageHeader &mh, avro::DecoderPtr d) |
virtual void | on_GetDataObjects (const Energistics::Etp::v12::Protocol::Store::GetDataObjects &msg, int64_t correlationId) |
virtual void | on_GetDataObjectsResponse (const Energistics::Etp::v12::Protocol::Store::GetDataObjectsResponse &msg, int64_t correlationId) |
virtual void | on_PutDataObjects (const Energistics::Etp::v12::Protocol::Store::PutDataObjects &msg, int64_t correlationId) |
virtual void | on_PutDataObjectsResponse (const Energistics::Etp::v12::Protocol::Store::PutDataObjectsResponse &msg, int64_t correlationId) |
virtual void | on_DeleteDataObjects (const Energistics::Etp::v12::Protocol::Store::DeleteDataObjects &msg, int64_t correlationId) |
virtual void | on_DeleteDataObjectsResponse (const Energistics::Etp::v12::Protocol::Store::DeleteDataObjectsResponse &msg, int64_t correlationId) |
virtual void | on_Chunk (const Energistics::Etp::v12::Protocol::Store::Chunk &msg, int64_t correlationId) |
std::map< std::string, Energistics::Etp::v12::Datatypes::Object::DataObject > | getDataObjects () const |
void | clearDataObjects () |
std::vector< std::string > | getSuccessKeys () const |
void | clearSuccessKeys () |
![]() | |
AbstractSession * | getSession () |
|
virtual |
Implements ETP_NS::ProtocolHandlers.