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 |
![]() | |
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.