|
roo_transport
API Documentation for roo_transport
|
#include <client.h>
Public Types | |
| using | UnaryCompletionCb = std::function< void(const roo::byte *data, size_t data_size, RpcStatus status)> |
Public Member Functions | |
| RpcClient (Messaging &messaging) | |
| RpcStatus | sendUnaryRpc (RpcFunctionId function_id, const roo::byte *payload, size_t payload_size, UnaryCompletionCb cb) |
| RpcStatus | sendUnaryRpcWithTimeout (RpcFunctionId function_id, const roo::byte *payload, size_t payload_size, uint32_t timeout_ms, UnaryCompletionCb cb) |
| ~RpcClient ()=default | |
| void | begin () |
| void | end () |
|
explicit |
Definition at line 7 of file client.cpp.
|
default |
| void roo_transport::RpcClient::begin | ( | ) |
Definition at line 10 of file client.cpp.
References roo_transport::Messaging::setReceiver().
| void roo_transport::RpcClient::end | ( | ) |
Definition at line 12 of file client.cpp.
References roo_transport::Messaging::unsetReceiver().
| RpcStatus roo_transport::RpcClient::sendUnaryRpc | ( | RpcFunctionId | function_id, |
| const roo::byte * | payload, | ||
| size_t | payload_size, | ||
| RpcClient::UnaryCompletionCb | cb | ||
| ) |
Definition at line 14 of file client.cpp.
References roo_transport::RpcHeader::kMaxSerializedSize, roo_transport::kOk, roo_transport::kUnavailable, roo_transport::RpcHeader::NewUnaryRequest(), roo_transport::Messaging::send(), and roo_transport::RpcHeader::serialize().
Referenced by roo_transport::UnaryStub< Request, Response, RequestSerializer, ResponseDeserializer >::call().
| RpcStatus roo_transport::RpcClient::sendUnaryRpcWithTimeout | ( | RpcFunctionId | function_id, |
| const roo::byte * | payload, | ||
| size_t | payload_size, | ||
| uint32_t | timeout_ms, | ||
| RpcClient::UnaryCompletionCb | cb | ||
| ) |
Definition at line 30 of file client.cpp.
References roo_transport::RpcHeader::kMaxSerializedSize, roo_transport::kOk, roo_transport::kUnavailable, roo_transport::RpcHeader::NewUnaryRequest(), roo_transport::Messaging::send(), and roo_transport::RpcHeader::serialize().