|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
Classes | |
| struct | getGeolocationParameters |
Static Public Member Functions | |
| static void | SetUpTestCase () |
| static std::optional< NES::Spatial::DataTypes::Experimental::GeoLocation > | getLocationFromTopologyNode (const std::shared_ptr< void > &structParams) |
| static bool | waitForNodes (int timeoutSeconds, size_t nodes, TopologyPtr topology) |
| wait until the topology contains the expected number of nodes so we can rely on these nodes being present for the rest of the test More... | |
| static void | TearDownTestCase () |
Public Attributes | |
| std::string | location2 = "52.53736960143897, 13.299134894776092" |
| std::string | location3 = "52.52025049345923, 13.327886280405611" |
| std::string | location4 = "52.49846981391786, 13.514464421192917" |
| std::chrono::duration< int64_t, std::milli > | defaultTimeoutInSec = std::chrono::seconds(TestUtils::defaultTimeout) |
Public Attributes inherited from NES::Testing::BaseUnitTest | |
| detail::TestSourceNameHelper | srcName |
Additional Inherited Members | |
Public Member Functions inherited from NES::Testing::BaseIntegrationTest | |
| 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... | |
Public Member Functions inherited from NES::Testing::BaseUnitTest | |
| void | SetUp () override |
| void | TearDown () override |
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 () |
Protected Member Functions inherited from NES::Testing::BaseIntegrationTest | |
| BorrowedPortPtr | getAvailablePort () |
| Retrieve another free port. More... | |
| std::filesystem::path | getTestResourceFolder () const |
| returns the test resource folder to write files More... | |
Protected Attributes inherited from NES::Testing::BaseIntegrationTest | |
| BorrowedPortPtr | rpcCoordinatorPort {nullptr} |
| BorrowedPortPtr | restPort {nullptr} |
|
inlinestatic |
|
inlinestatic |
References NES::LOG_DEBUG, NES_INFO, NES::Logger::setupLogging(), and NES::writeWaypointsToCsv().
|
inlinestatic |
References NES_INFO.
|
inlinestatic |
wait until the topology contains the expected number of nodes so we can rely on these nodes being present for the rest of the test
| timeoutSeconds | time to wait before aborting |
| nodes | expected number of nodes |
| topology | the topology object to query |
| std::chrono::duration<int64_t, std::milli> NES::Spatial::LocationIntegrationTests::defaultTimeoutInSec = std::chrono::seconds(TestUtils::defaultTimeout) |
| std::string NES::Spatial::LocationIntegrationTests::location2 = "52.53736960143897, 13.299134894776092" |
| std::string NES::Spatial::LocationIntegrationTests::location3 = "52.52025049345923, 13.327886280405611" |
| std::string NES::Spatial::LocationIntegrationTests::location4 = "52.49846981391786, 13.514464421192917" |