NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
: This class is responsible for starting the REST server. More...
#include <RestServer.hpp>
Public Member Functions | |
RestServer (std::string host, uint16_t port, NesCoordinatorWeakPtr coordinator, Catalogs::Query::QueryCatalogPtr queryCatalog, TopologyPtr topology, Optimizer::GlobalExecutionPlanPtr globalExecutionPlan, RequestHandlerServicePtr requestHandlerService, MonitoringServicePtr monitoringService, QueryParsingServicePtr queryParsingService, GlobalQueryPlanPtr globalQueryPlan, Catalogs::UDF::UDFCatalogPtr udfCatalog, Runtime::BufferManagerPtr bufferManager, std::optional< std::string > corsAllowedOrigin) | |
constructor for rest server More... | |
bool | start () |
method to start the rest server, calls run() internally More... | |
void | run () |
method called within start() starts the server after initializing controllers, endpoints and necessary components like connection handler, router. More... | |
bool | stop () |
method to stop rest server More... | |
: This class is responsible for starting the REST server.
NES::RestServer::RestServer | ( | std::string | host, |
uint16_t | port, | ||
NesCoordinatorWeakPtr | coordinator, | ||
Catalogs::Query::QueryCatalogPtr | queryCatalog, | ||
TopologyPtr | topology, | ||
Optimizer::GlobalExecutionPlanPtr | globalExecutionPlan, | ||
RequestHandlerServicePtr | requestHandlerService, | ||
MonitoringServicePtr | monitoringService, | ||
QueryParsingServicePtr | queryParsingService, | ||
GlobalQueryPlanPtr | globalQueryPlan, | ||
Catalogs::UDF::UDFCatalogPtr | udfCatalog, | ||
Runtime::BufferManagerPtr | bufferManager, | ||
std::optional< std::string > | corsAllowedOrigin | ||
) |
constructor for rest server
host | |
port | |
coordinator | |
queryCatalog | |
sourceCatalogService | |
topology | |
globalExecutionPlan | |
requestHandlerService | |
monitoringService | |
queryParsingService | |
globalQueryPlan | |
udfCatalog | |
bufferManager | |
corsAllowedOrigin |
void NES::RestServer::run | ( | ) |
method called within start() starts the server after initializing controllers, endpoints and necessary components like connection handler, router.
References NES::REST::Controller::QueryCatalogController::create(), NES::REST::Controller::MonitoringController::create(), NES::REST::Controller::QueryController::create(), NES::REST::Controller::SourceCatalogController::create(), NES::REST::Controller::ConnectivityController::create(), NES::REST::Controller::LocationController::create(), NES::REST::Controller::TopologyController::create(), NES::REST::Controller::UDFCatalogController::create(), NES_DEBUG, and NES_INFO.
Referenced by start().
bool NES::RestServer::start | ( | ) |
method to start the rest server, calls run() internally
References NES::RestServerInterruptHandler::hookUserInterruptHandler(), NES_FATAL_ERROR, NES_INFO, and run().
bool NES::RestServer::stop | ( | ) |
method to stop rest server