|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
Public Member Functions | |
| void | SetUp () override |
| Catalogs::Source::SourceCatalogPtr | setUpSourceCatalog (const int numberOfSources) |
| Creates #numberOfSources physical sources. More... | |
Public Member Functions inherited from NES::Testing::BaseUnitTest | |
| void | SetUp () override |
| void | TearDown () override |
| virtual void | onFatalError (int signalNumber, std::string callstack) override |
| onFatalError shall be called when a signal is caught More... | |
| virtual void | onFatalException (std::shared_ptr< std::exception > exception, std::string callstack) override |
| onFatalException shall be called when an exception is caught More... | |
Public Member Functions inherited from NES::detail::virtual_enable_shared_from_this< ErrorListener > | |
| ~virtual_enable_shared_from_this () NES_NOEXCEPT(true) override=default | |
| std::shared_ptr< T1 > | shared_from_this () |
| std::weak_ptr< T1 > | weak_from_this () |
Public Member Functions inherited from NES::detail::virtual_enable_shared_from_this_base< true > | |
| virtual | ~virtual_enable_shared_from_this_base () NES_NOEXCEPT(isNoexceptDestructible)=default |
Public Member Functions inherited from NES::Testing::detail::TestWaitingHelper | |
| TestWaitingHelper () | |
| void | startWaitingThread (std::string testName) |
| void | completeTest () |
| void | failTest () |
Static Public Member Functions | |
| static void | SetUpTestCase () |
Public Attributes | |
| Windowing::WindowTypePtr | window |
| Statistic::WindowStatisticDescriptorPtr | statisticDescriptor |
| Statistic::StatisticMetricHash | metricHash |
| Catalogs::Source::SourceCatalogPtr | sourceCatalog |
| Statistic::SendingPolicyPtr | sendingPolicy |
| Statistic::TriggerConditionPtr | triggerCondition |
Public Attributes inherited from NES::Testing::BaseUnitTest | |
| detail::TestSourceNameHelper | srcName |
|
inlineoverride |
References NES::Statistic::DEFAULT, NES::API::IngestionTime(), metricHash, NES::API::Minutes(), sendingPolicy, setUpSourceCatalog(), sourceCatalog, statisticDescriptor, triggerCondition, and window.
|
inline |
Creates #numberOfSources physical sources.
| numberOfSources |
References NES::Schema::create(), NES_DEBUG, NES::Spatial::Experimental::NO_LOCATION, and sourceCatalog.
Referenced by SetUp().
|
inlinestatic |
References NES::LOG_DEBUG, NES_INFO, and NES::Logger::setupLogging().
| Statistic::StatisticMetricHash NES::StatisticIdsExtractorTest::metricHash |
Referenced by SetUp().
| Statistic::SendingPolicyPtr NES::StatisticIdsExtractorTest::sendingPolicy |
Referenced by SetUp().
| Catalogs::Source::SourceCatalogPtr NES::StatisticIdsExtractorTest::sourceCatalog |
Referenced by SetUp(), and setUpSourceCatalog().
| Statistic::WindowStatisticDescriptorPtr NES::StatisticIdsExtractorTest::statisticDescriptor |
Referenced by SetUp().
| Statistic::TriggerConditionPtr NES::StatisticIdsExtractorTest::triggerCondition |
Referenced by SetUp().
| Windowing::WindowTypePtr NES::StatisticIdsExtractorTest::window |
Referenced by SetUp().