|
OpenCBDC Transaction Processor
|
RPC server for an agent running a Lua exector. More...
#include <server.hpp>


Public Types | |
| using | server_type = cbdc::rpc::async_tcp_server<request, response> |
| Underlying RPC server type alias for this implementation. | |
Public Member Functions | |
| server (std::unique_ptr< server_type > srv, std::shared_ptr< broker::interface > broker, std::shared_ptr< logging::log > log, const cbdc::parsec::config &cfg) | |
| Constructor. | |
| ~server () override | |
| Stops the server. | |
| auto | init () -> bool override |
| Initializes the server. | |
| server (const server &)=delete | |
| auto | operator= (const server &) -> server &=delete |
| server (server &&)=delete | |
| auto | operator= (server &&) -> server &=delete |
Public Member Functions inherited from cbdc::parsec::agent::rpc::server_interface | |
| server_interface (std::shared_ptr< broker::interface > broker, std::shared_ptr< logging::log > log, const cbdc::parsec::config &cfg) | |
| Constructor. | |
| virtual | ~server_interface () |
| Stops retrying additional transactions and cleans up the runners. | |
| server_interface (const server_interface &)=delete | |
| auto | operator= (const server_interface &) -> server_interface &=delete |
| server_interface (server_interface &&)=delete | |
| auto | operator= (server_interface &&) -> server_interface &=delete |
RPC server for an agent running a Lua exector.
Manages retrying function execution if it fails due to a transient error.
Definition at line 15 of file parsec/agent/runners/lua/server.hpp.
| using cbdc::parsec::agent::rpc::server::server_type = cbdc::rpc::async_tcp_server<request, response> |
Underlying RPC server type alias for this implementation.
Definition at line 18 of file parsec/agent/runners/lua/server.hpp.
| cbdc::parsec::agent::rpc::server::server | ( | std::unique_ptr< server_type > | srv, |
| std::shared_ptr< broker::interface > | broker, | ||
| std::shared_ptr< logging::log > | log, | ||
| const cbdc::parsec::config & | cfg ) |
Constructor.
Registers the agent implementation with the RPC server using a request handler callback.
| srv | pointer to an asynchronous RPC server. |
| broker | broker instance. |
| log | log instance. |
| cfg | system configuration options. |
Definition at line 18 of file parsec/agent/runners/lua/server.cpp.
|
override |
Stops the server.
Definition at line 30 of file parsec/agent/runners/lua/server.cpp.
|
delete |
|
delete |
|
overridevirtual |
Initializes the server.
Starts listening for and processing requests.
Implements cbdc::parsec::agent::rpc::server_interface.
Definition at line 36 of file parsec/agent/runners/lua/server.cpp.