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().