|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <Catalogs/Source/PhysicalSource.hpp>#include <Components/NesWorker.hpp>#include <Configurations/Worker/WorkerConfiguration.hpp>#include <Exceptions/ErrorListener.hpp>#include <Exceptions/SignalHandling.hpp>#include <Util/Logger/Logger.hpp>#include <Version/version.hpp>#include <iostream>Functions | |
| int | main (int argc, char **argv) |
Variables | |
| const std::string | logo |
| const std::string | worker |
| int main | ( | int | argc, |
| char ** | argv | ||
| ) |
blocking
withConnect
force
References magic_enum::detail::find(), NES::Logger::getInstance(), NES::Exceptions::installGlobalErrorListener(), NES::LOG_DEBUG, logo, backward::details::move(), NES_ERROR, NES_INFO, NES_VERSION, NES::Logger::setupLogging(), worker, and NES::TestUtils::workerConfigPath().
| const std::string logo |
Referenced by main().
| const std::string worker |
Referenced by NES::TestUtils::checkRemovedDecomposedQueryOrTimeoutAtWorker(), NES::TestUtils::checkStoppedOrTimeoutAtWorker(), NES::StatisticsIntegrationTest::createWorker(), main(), NES::MockedPipelineExecutionContext::MockedPipelineExecutionContext(), NES::TestHarness::runQuery(), NES::TestHarness::stopCoordinatorAndWorkers(), and NES::StatisticsIntegrationTest::TearDown().