|
rad
2.0.0
|
Classes | |
| class | Publisher |
| class | Replier |
| class | Request |
| class | Request< REP_TYPE, void > |
| class | RequestAmi |
| class | RequestAmi< REP_TYPE, void > |
| class | Requestor |
| class | Subscriber |
| class | SMSubscriber |
| class | CancellationToken |
Functions | |
| template<class EVENT , class T > | |
| void | RoutePartialReply (std::shared_ptr<::elt::mal::rr::Ami< T >> ami, rad::SMAdapter &sm) |
| template<class EVENT , class FUT > | |
| CancellationToken | RouteReply (FUT &&rep_future, rad::SMAdapter &sm) |
| template<class EVENT , class EVENT_ERR , class FUT > | |
| CancellationToken | RouteReply (FUT &&rep_future, rad::SMAdapter &sm) |
| template<class EVENT , class EVENT_TIMEOUT , class EVENT_ERR , class FUT > | |
| CancellationToken | RouteReplyWithTimeout (FUT &&rep_future, rad::SMAdapter &sm) |
| void | LoadMiddlewares (const std::vector< std::string > &mal_types) |
|
inline |
This helper function loads given MAL middlewares and configure them with default QoS properties.
| mal_types | A list of supported middlewares (e.g. zpd, opcua, ...) |
Usage: LoadMiddlewares({"zpb", "opcua"});
This helper function loads given MAL middlewares and configure them with default QoS properties.
| mal_types | A list of supported middlewares (e.g. zpd, opcua, ...) |
Usage: LoadMiddlewares({"zpb", "opcua"});
This helper function loads given MAL middlewares and configure them with default QoS properties.
| mal_types | A list of supported middlewares (e.g. zpd, opcua, ...) |
Usage: LoadMiddlewares({"zpb", "opcua"});
| void rad::cii::RoutePartialReply | ( | std::shared_ptr<::elt::mal::rr::Ami< T >> | ami, |
| rad::SMAdapter & | sm | ||
| ) |
This function can be use to configure the injection of an event, associated to a partial reply, into a given State Machine engine. There is no special handling for error replies (exceptions).
| EVENT | Type of event to trigger when a partial reply is received. |
| T | Type associated to the partial replies. |
| ami | Object associated to the partial replies and returned by MAL Client interface invocation. |
| sm | Reference to a State Machine adapter. |
| CancellationToken rad::cii::RouteReply | ( | FUT && | rep_future, |
| rad::SMAdapter & | sm | ||
| ) |
This function can be use to configure the injection of an event, associated to a reply, into a given State Machine engine. There is no special handling for error replies (exceptions).
| EVENT | Type of event to trigger when the reply is received. |
| FUT | Type of future for the reply. |
| rep_future | Future associated to the reply and returned by MAL Client interface invocation. |
| sm | Reference to a State Machine adapter. |
| CancellationToken rad::cii::RouteReply | ( | FUT && | rep_future, |
| rad::SMAdapter & | sm | ||
| ) |
This function can be use to configure the injection of an OK event (associated to a normal reply), or an ERROR event (associated to an error reply/exception), into a given State Machine engine.
| EVENT | Type of OK event to trigger in case of OK reply. |
| EVENT_ERR | Type of ERROR event to trigger in case of ERROR reply. |
| FUT | Type of future for the reply. |
| rep_future | Future associated to the reply and returned by MAL Client interface invocation. |
| sm | Reference to a State Machine adapter. |
| CancellationToken rad::cii::RouteReplyWithTimeout | ( | FUT && | rep_future, |
| rad::SMAdapter & | sm | ||
| ) |
This function can be use to configure the injection of an OK event (associated to a normal reply), or an ERROR event (associated to an error reply/exception), or a TIMEOUT event (associated to the expiration of a timer associated with a request) into a given State Machine engine.
| EVENT | Type of OK event to trigger in case of OK reply. |
| EVENT_TIMEOUT | Type of TIMEOUT event to trigger in case of request time-out. |
| EVENT_ERR | Type of ERROR event to trigger in case of ERROR reply. |
| FUT | Type of future for the reply. |
| rep_future | Future associated to the reply and returned by MAL Client interface invocation. |
| sm | Reference to a State Machine adapter. |
1.8.5