OpenCBDC Transaction Processor
|
RPC server for a agent. More...
#include <http_server.hpp>
Public Types | |
using | server_type = cbdc::rpc::json_rpc_http_server |
Type alias for the underlying RPC server. | |
Public Member Functions | |
http_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. | |
~http_server () override | |
Stops listening for incoming connections, waits for existing connections to drain. | |
auto | init () -> bool override |
Starts listening for incoming connections and processing requests. | |
http_server (const http_server &)=delete | |
auto | operator= (const http_server &) -> http_server &=delete |
http_server (http_server &&)=delete | |
auto | operator= (http_server &&) -> http_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 a agent.
Manages retrying function execution if it fails due to a transient error.
Definition at line 26 of file http_server.hpp.
Type alias for the underlying RPC server.
Definition at line 29 of file http_server.hpp.
cbdc::parsec::agent::rpc::http_server::http_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 HTTP JSON-RPC server. |
broker | broker instance. |
log | log instance. |
cfg | system configuration options. |
Definition at line 23 of file http_server.cpp.
|
override |
Stops listening for incoming connections, waits for existing connections to drain.
Definition at line 37 of file http_server.cpp.
|
delete |
|
delete |
|
overridevirtual |
Starts listening for incoming connections and processing requests.
Implements cbdc::parsec::agent::rpc::server_interface.
Definition at line 43 of file http_server.cpp.
|
delete |
|
delete |