NES::Testing::BaseIntegrationTest Class Reference

#include <BaseIntegrationTest.hpp>

Collaboration diagram for NES::Testing::BaseIntegrationTest:

Public Member Functions
	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
BorrowedPortPtr	getAvailablePort ()
	Retrieve another free port. More...
std::filesystem::path	getTestResourceFolder () const
	returns the test resource folder to write files More...

Protected Attributes
BorrowedPortPtr	rpcCoordinatorPort {nullptr}
BorrowedPortPtr	restPort {nullptr}

Friends
class	BorrowedPort

Additional Inherited Members
Public Attributes inherited from NES::Testing::BaseUnitTest
detail::TestSourceNameHelper	srcName

Constructor & Destructor Documentation

BaseIntegrationTest()

NES::Testing::BaseIntegrationTest::BaseIntegrationTest ( )

explicit

the base test class ctor that creates the internal test resources

~BaseIntegrationTest()

NES::Testing::BaseIntegrationTest::~BaseIntegrationTest ( )

override

References NES_ASSERT2_FMT.

Member Function Documentation

getAvailablePort()

BorrowedPortPtr NES::Testing::BaseIntegrationTest::getAvailablePort ( )

protected

Retrieve another free port.

Returns

a free port

References NES::Testing::detail::PortDispatcher::getNextPort(), and NES::Testing::detail::getPortDispatcher().

Referenced by NES::TCPSourceIntegrationTest::SetUp(), and NES::ConvertLogicalToPhysicalSinkTest::SetUp().

Here is the call graph for this function:

Here is the caller graph for this function:

getTestResourceFolder()

std::filesystem::path NES::Testing::BaseIntegrationTest::getTestResourceFolder ( ) const

protected

returns the test resource folder to write files

Returns

the test folder

Referenced by NES::Runtime::Execution::JoinDeploymentTest::runAndValidateJoinQueryTwoLogicalStreams().

Here is the caller graph for this function:

onFatalError()

void NES::Testing::BaseIntegrationTest::onFatalError ( int  signalNumber, std::string    )

overridevirtual

onFatalError shall be called when a signal is caught

Parameters

signalNumber	the caught signal
stacktrace	the stacktrace of the error

Reimplemented from NES::Testing::BaseUnitTest.

References NES::Testing::detail::TestWaitingHelper::failTest(), and NES_ERROR.

Here is the call graph for this function:

onFatalException()

void NES::Testing::BaseIntegrationTest::onFatalException ( std::shared_ptr< std::exception >  , std::string    )

overridevirtual

onFatalException shall be called when an exception is caught

Parameters

exception	the caught exception
stacktrace	the stacktrace of the error

Reimplemented from NES::Testing::BaseUnitTest.

References NES::Testing::detail::TestWaitingHelper::failTest(), and NES_ERROR.

Here is the call graph for this function:

SetUp()

void NES::Testing::BaseIntegrationTest::SetUp ( )

override

Fetches the port.

References NES::Testing::detail::PortDispatcher::getNextPort(), NES::Testing::detail::getPortDispatcher(), NES_ERROR, restPort, rpcCoordinatorPort, and NES::Testing::BaseUnitTest::SetUp().

Referenced by NES::E2EMonitoringTest::SetUp(), NES::DistributedMatrixJoinIntegrationTest::SetUp(), NES::DistributedNemoJoinIntegrationTest::SetUp(), NES::FilterPushDownTest::SetUp(), NES::MonitoringControllerTest::SetUp(), NES::QueryControllerTest::SetUp(), NES::TCPSourceIntegrationTest::SetUp(), NES::UnionDeploymentTest::SetUp(), NES::MonitoringQueriesTest::SetUp(), NES::ConvertLogicalToPhysicalSinkTest::SetUp(), NES::StatisticSinkTest::SetUp(), NES::MillisecondIntervalTest::SetUp(), NES::SourceTest::SetUp(), NES::TCPSourceTest::SetUp(), and ZMQTest::SetUp().

Here is the call graph for this function:

Here is the caller graph for this function:

TearDown()

void NES::Testing::BaseIntegrationTest::TearDown ( )

override

Release internal ports.

References NES::Testing::detail::TestWaitingHelper::completeTest(), NES_ERROR, restPort, rpcCoordinatorPort, and NES::Testing::BaseUnitTest::TearDown().

Referenced by NES::JoinMultiThreadedTest::TearDown(), NES::MultiThreadedTest::TearDown(), NES::TCPSourceIntegrationTest::TearDown(), NES::ConvertLogicalToPhysicalSinkTest::TearDown(), NES::StatisticSinkTest::TearDown(), NES::MillisecondIntervalTest::TearDown(), NES::SourceTest::TearDown(), NES::TCPSourceTest::TearDown(), and ZMQTest::TearDown().

Here is the call graph for this function:

Here is the caller graph for this function:

Friends And Related Function Documentation

BorrowedPort

friend class BorrowedPort

friend

Member Data Documentation

restPort

BorrowedPortPtr NES::Testing::BaseIntegrationTest::restPort {nullptr}

protected

Referenced by NES::MonitoringQueriesTest::createCoordinator(), NES::Runtime::Execution::JoinDeploymentTest::runAndValidateJoinQueryTwoLogicalStreams(), SetUp(), NES::MonitoringQueriesTest::SetUp(), NES::LocationControllerIntegrationTest::startCoordinator(), NES::QueryCatalogControllerTest::startCoordinator(), NES::QueryControllerTest::startCoordinator(), NES::TopologyControllerTest::startCoordinator(), TearDown(), and NES::MonitoringControllerTest::waitForMonitoringQuery().

rpcCoordinatorPort

BorrowedPortPtr NES::Testing::BaseIntegrationTest::rpcCoordinatorPort {nullptr}

protected

Referenced by NES::MonitoringQueriesTest::createCoordinator(), NES::MonitoringQueriesTest::createWorker(), NES::Runtime::Execution::JoinDeploymentTest::runAndValidateJoinQueryTwoLogicalStreams(), SetUp(), NES::MonitoringQueriesTest::SetUp(), NES::LocationControllerIntegrationTest::startCoordinator(), NES::QueryCatalogControllerTest::startCoordinator(), NES::QueryControllerTest::startCoordinator(), NES::TopologyControllerTest::startCoordinator(), and TearDown().

---

The documentation for this class was generated from the following files:

• /nebulastream/nes-common/tests/Util/include/BaseIntegrationTest.hpp
• /nebulastream/nes-common/tests/Util/src/BaseIntegrationTest.cpp