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::SslClientSession Class Reference
Inheritance diagram for ETP_NS::SslClientSession:
ETP_NS::AbstractClientSessionCRTP< Derived > ETP_NS::ClientSession ETP_NS::AbstractSession

Public Member Functions

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)
 
- 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::DataspacegetDataspaces (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::DataspacegetDataspaceInfo (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::ResourcegetResources (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::DeletedResourcegetDeletedResources (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::DataObjectgetDataObjects (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::SubscriptionInfosubscriptions
 

Member Function Documentation

◆ isTls()

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

Implements ETP_NS::ClientSession.

◆ on_proxy_handshake_write()

void ETP_NS::SslClientSession::on_proxy_handshake_write ( boost::system::error_code ec,
std::size_t bytes_transferred )
inline

Set the skip parse option. This option controls whether or not the parser expects to see an HTTP body, regardless of the presence or absence of certain fields such as Content-Length or a chunked Transfer-Encoding. Depending on the request, some responses do not carry a body. For example, a 200 response to a CONNECT request from a tunneling proxy, or a response to a HEAD request. In these cases, callers may use this function inform the parser that no body is expected. The parser will consider the message complete after the header has been received.

Parameters
vtrue to set the skip body option or false to disable it.
Note
This function must called before any bytes are processed.

◆ on_resolve()

void ETP_NS::SslClientSession::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: