|
FETPAPI_DLL_IMPORT_OR_EXPORT | SslClientSession (boost::asio::ssl::context &ctx, InitializationParameters const *initializationParams, const std::string &target, const std::string &authorization, const std::string &proxyAuthorization="", const std::map< std::string, std::string > &additionalHandshakeHeaderFields={}, std::size_t frameSize=4096) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT websocket::stream< boost::beast::ssl_stream< tcp::socket > > & | ws () |
|
bool | isTls () const final |
|
void | on_resolve (boost::system::error_code ec, tcp::resolver::results_type results) |
|
void | on_ssl_connect (boost::system::error_code ec) |
|
void | on_proxy_handshake_write (boost::system::error_code ec, std::size_t bytes_transferred) |
|
void | on_proxy_handshake_read (boost::system::error_code ec, std::size_t bytes_transferred) |
|
void | on_connect (boost::system::error_code ec) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT void | do_close () |
|
FETPAPI_DLL_IMPORT_OR_EXPORT void | do_read () |
|
void | on_handshake (boost::system::error_code ec) |
|
void | setMaxWebSocketMessagePayloadSize (int64_t value) final |
|
boost::asio::io_context & | getIoContext () |
|
const std::string & | getEtpServerHost () const |
|
const std::string & | getEtpServerPort () const |
|
const std::string & | getEtpServerTarget () const |
|
const std::string & | getEtpServerAuthorization () const |
|
const std::string & | getProxyHost () const |
|
const std::string & | getProxyPort () const |
|
const std::string & | getProxyAuthorization () const |
|
bool | run () |
|
void | on_handshake (boost::system::error_code ec) |
|
const boost::uuids::uuid & | getIdentifier () |
|
void | setTimeOut (double timeOut) |
|
double | getTimeOut () const |
|
FETPAPI_DLL_IMPORT_OR_EXPORT void | setCoreProtocolHandlers (std::shared_ptr< CoreHandlers > coreHandlers) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT void | setDiscoveryProtocolHandlers (std::shared_ptr< DiscoveryHandlers > discoveryHandlers) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT void | setStoreProtocolHandlers (std::shared_ptr< StoreHandlers > storeHandlers) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT void | setStoreNotificationProtocolHandlers (std::shared_ptr< ETP_NS::StoreNotificationHandlers > storeNotificationHandlers) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT void | setDataArrayProtocolHandlers (std::shared_ptr< DataArrayHandlers > dataArrayHandlers) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT void | setTransactionProtocolHandlers (std::shared_ptr< TransactionHandlers > transactionHandlers) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT void | setDataspaceProtocolHandlers (std::shared_ptr< DataspaceHandlers > dataspaceHandlers) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT void | setDataspaceOSDUProtocolHandlers (std::shared_ptr< DataspaceOSDUHandlers > dataspaceOsduHandlers) |
|
template<typename T > |
int64_t | send (const T &mb, int64_t correlationId=0, int32_t messageFlags=0) |
|
template<typename T > |
void | sendAndBlock (const T &mb, int64_t correlationId=0, int32_t messageFlags=0) |
|
template<typename T > |
int64_t | sendWithSpecificHandler (const T &mb, std::shared_ptr< ETP_NS::ProtocolHandlers > specificHandler, int64_t correlationId=0, int32_t messageFlags=0) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT void | on_read (boost::system::error_code ec, std::size_t bytes_transferred) |
|
void | on_write (boost::system::error_code ec, std::size_t) |
|
void | on_close (boost::system::error_code ec) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT bool | isWebSocketSessionClosed () const |
|
FETPAPI_DLL_IMPORT_OR_EXPORT bool | isMessageStillProcessing (int64_t msgId) |
|
int64_t | getMaxWebSocketMessagePayloadSize () const |
|
FETPAPI_DLL_IMPORT_OR_EXPORT void | close () |
|
FETPAPI_DLL_IMPORT_OR_EXPORT void | closeAndBlock () |
|
FETPAPI_DLL_IMPORT_OR_EXPORT bool | isEtpSessionClosed () const |
|
void | setEtpSessionClosed (bool etpSessionClosed_) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT std::vector< Energistics::Etp::v12::Datatypes::Object::Dataspace > | getDataspaces (int64_t storeLastWriteFilter=-1) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT std::vector< std::string > | putDataspaces (const std::map< std::string, Energistics::Etp::v12::Datatypes::Object::Dataspace > &dataspaces) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT std::vector< std::string > | deleteDataspaces (const std::map< std::string, std::string > &dataspaceUris) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT std::vector< Energistics::Etp::v12::Datatypes::Object::Dataspace > | getDataspaceInfo (const std::map< std::string, std::string > &dataspaceUris) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT std::vector< std::string > | copyDataspacesContent (const std::map< std::string, std::string > &sourceDataspaceUris, const std::string &targetDataspaceUri) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT std::vector< std::string > | lockDataspaces (const std::map< std::string, std::string > &dataspaceUris, bool lock) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT std::vector< std::string > | copyToDataspace (const std::map< std::string, std::string > &sourceUris, const std::string &targetDataspaceUri) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT std::vector< Energistics::Etp::v12::Datatypes::Object::Resource > | getResources (const Energistics::Etp::v12::Datatypes::Object::ContextInfo &context, const Energistics::Etp::v12::Datatypes::Object::ContextScopeKind &scope, int64_t storeLastWriteFilter=-1, bool countObjects=false) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT std::vector< Energistics::Etp::v12::Datatypes::Object::DeletedResource > | getDeletedResources (const std::string &dataspaceUri, int64_t deleteTimeFilter=-1, const std::vector< std::string > &dataObjectTypes={}) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT std::map< std::string, Energistics::Etp::v12::Datatypes::Object::DataObject > | getDataObjects (const std::map< std::string, std::string > &uris) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT std::vector< std::string > | putDataObjects (const std::map< std::string, Energistics::Etp::v12::Datatypes::Object::DataObject > &dataObjects) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT std::vector< std::string > | deleteDataObjects (const std::map< std::string, std::string > &uris) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT std::string | startTransaction (std::vector< std::string > dataspaceUris={}, bool readOnly=false) |
|
FETPAPI_DLL_IMPORT_OR_EXPORT std::string | rollbackTransaction () |
|
FETPAPI_DLL_IMPORT_OR_EXPORT std::string | commitTransaction () |
|
void | setVerbose (bool verbose) |
|
void | fesapi_log () |
|
template<typename First , typename ... Rest> |
void | fesapi_log (First &&first, Rest &&...rest) |
|