|
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 () |
Public Member Functions inherited from ETP_NS::ProtocolHandlers | |
| AbstractSession * | getSession () |
|
virtual |
Implements ETP_NS::ProtocolHandlers.