|
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