NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
Public Member Functions | |
void | SetUp () override |
void | TearDown () override |
![]() | |
BaseIntegrationTest () | |
the base test class ctor that creates the internal test resources More... | |
~BaseIntegrationTest () override | |
void | SetUp () override |
Fetches the port. More... | |
void | TearDown () override |
Release internal ports. More... | |
void | onFatalError (int signalNumber, std::string callstack) override |
onFatalError shall be called when a signal is caught More... | |
void | onFatalException (std::shared_ptr< std::exception > exception, std::string callstack) override |
onFatalException shall be called when an exception is caught More... | |
![]() | |
void | SetUp () override |
void | TearDown () override |
![]() | |
~virtual_enable_shared_from_this () NES_NOEXCEPT(true) override=default | |
std::shared_ptr< T1 > | shared_from_this () |
std::weak_ptr< T1 > | weak_from_this () |
![]() | |
virtual | ~virtual_enable_shared_from_this_base () NES_NOEXCEPT(isNoexceptDestructible)=default |
![]() | |
TestWaitingHelper () | |
void | startWaitingThread (std::string testName) |
void | completeTest () |
void | failTest () |
Static Public Member Functions | |
static void | SetUpTestCase () |
Public Attributes | |
CoordinatorConfigurationPtr | coordinatorConfig |
WorkerConfigurationPtr | wrkConf |
CSVSourceTypePtr | csvSourceType |
std::string | defaultPhysicalStreamName = "defaultPhysicalStreamName" |
Runtime::NodeEnginePtr | nodeEngine {nullptr} |
std::string | path_to_file |
![]() | |
detail::TestSourceNameHelper | srcName |
Additional Inherited Members | |
![]() | |
BorrowedPortPtr | getAvailablePort () |
Retrieve another free port. More... | |
std::filesystem::path | getTestResourceFolder () const |
returns the test resource folder to write files More... | |
![]() | |
BorrowedPortPtr | rpcCoordinatorPort {nullptr} |
BorrowedPortPtr | restPort {nullptr} |
This test set holds the corner cases for moving our sampling frequencies to sub-second intervals. Before, NES was sampling every second and was checking every second if that future timestamp is now stale (older).
First we check for sub-second unit-tests on a soruce and its behavior. Then, we include an E2Etest with a source that samples at sub-second interval.
|
inlineoverride |
References NES_INFO, NES::TestUtils::restPort(), and NES::Testing::BaseIntegrationTest::SetUp().
|
inlinestatic |
References NES::LOG_DEBUG, NES_INFO, and NES::Logger::setupLogging().
|
inlineoverride |
References NES_INFO, and NES::Testing::BaseIntegrationTest::TearDown().
CoordinatorConfigurationPtr NES::MillisecondIntervalTest::coordinatorConfig |
CSVSourceTypePtr NES::MillisecondIntervalTest::csvSourceType |
std::string NES::MillisecondIntervalTest::defaultPhysicalStreamName = "defaultPhysicalStreamName" |
Runtime::NodeEnginePtr NES::MillisecondIntervalTest::nodeEngine {nullptr} |
std::string NES::MillisecondIntervalTest::path_to_file |
WorkerConfigurationPtr NES::MillisecondIntervalTest::wrkConf |