NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
nesWorkerStarter.cpp File Reference
#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>
Include dependency graph for nesWorkerStarter.cpp:

Functions

int main (int argc, char **argv)
 

Variables

const std::string logo
 
const std::string worker
 

Function Documentation

◆ main()

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

Here is the call graph for this function:

Variable Documentation

◆ logo

const std::string logo
Initial value:
=
"\n"
"███╗░░██╗███████╗██████╗░██╗░░░██╗██╗░░░░░░█████╗░░██████╗████████╗██████╗░███████╗░█████╗░███╗░░░███╗\n"
"████╗░██║██╔════╝██╔══██╗██║░░░██║██║░░░░░██╔══██╗██╔════╝╚══██╔══╝██╔══██╗██╔════╝██╔══██╗████╗░████║\n"
"██╔██╗██║█████╗░░██████╦╝██║░░░██║██║░░░░░███████║╚█████╗░░░░██║░░░██████╔╝█████╗░░███████║██╔████╔██║\n"
"██║╚████║██╔══╝░░██╔══██╗██║░░░██║██║░░░░░██╔══██║░╚═══██╗░░░██║░░░██╔══██╗██╔══╝░░██╔══██║██║╚██╔╝██║\n"
"██║░╚███║███████╗██████╦╝╚██████╔╝███████╗██║░░██║██████╔╝░░░██║░░░██║░░██║███████╗██║░░██║██║░╚═╝░██║\n"
"╚═╝░░╚══╝╚══════╝╚═════╝░░╚═════╝░╚══════╝╚═╝░░╚═╝╚═════╝░░░░╚═╝░░░╚═╝░░╚═╝╚══════╝╚═╝░░╚═╝╚═╝░░░░░╚═╝"

Referenced by main().

◆ worker

const std::string worker
Initial value:
= "\n"
"▒█░░▒█ █▀▀█ █▀▀█ █░█ █▀▀ █▀▀█ \n"
"▒█▒█▒█ █░░█ █▄▄▀ █▀▄ █▀▀ █▄▄▀ \n"
"▒█▄▀▄█ ▀▀▀▀ ▀░▀▀ ▀░▀ ▀▀▀ ▀░▀▀"

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