FETPAPI 0.3.0.0
This project provides C++ classes which facilitate the developement of ETP1.2 clients and servers.
Loading...
Searching...
No Matches
Public Member Functions | List of all members
ETP_NS::PlainClientSession Class Reference
Inheritance diagram for ETP_NS::PlainClientSession:
ETP_NS::AbstractClientSessionCRTP< Derived > ETP_NS::ClientSession ETP_NS::AbstractSession

Public Member Functions

FETPAPI_DLL_IMPORT_OR_EXPORT PlainClientSession (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< tcp::socket > & ws ()
 
bool isTls () const final
 
void on_resolve (boost::system::error_code ec, tcp::resolver::results_type results)
 
- Public Member Functions inherited from ETP_NS::AbstractClientSessionCRTP< Derived >
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
 
- Public Member Functions inherited from ETP_NS::ClientSession
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)
 
- Public Member Functions inherited from ETP_NS::AbstractSession
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)
 

Additional Inherited Members

- Public Attributes inherited from ETP_NS::AbstractSession
std::unordered_map< int64_t, Energistics::Etp::v12::Datatypes::Object::SubscriptionInfo > subscriptions
 

Member Function Documentation

◆ isTls()

bool ETP_NS::PlainClientSession::isTls ( ) const
inlinefinalvirtual

Implements ETP_NS::ClientSession.

◆ on_resolve()

void ETP_NS::PlainClientSession::on_resolve ( boost::system::error_code ec,
tcp::resolver::results_type results )
inlinevirtual

Implements ETP_NS::ClientSession.

The documentation for this class was generated from the following file:
Generated by doxygen 1.10.0