Collaboration diagram for NES::QueryRedeploymentIntegrationTest:

[legend]

Static Public Member Functions
static void	SetUpTestCase ()

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

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

Public Attributes inherited from NES::Testing::BaseUnitTest
detail::TestSourceNameHelper	srcName

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}

Member Function Documentation

◆ SetUpTestCase()

static void NES::QueryRedeploymentIntegrationTest::SetUpTestCase ( )

inlinestatic

References NES::LOG_DEBUG, NES_INFO, and NES::Logger::setupLogging().

Here is the call graph for this function:

◆ waitForNodes()

static bool NES::QueryRedeploymentIntegrationTest::waitForNodes	(	int	timeoutSeconds,
		size_t	nodes,
		TopologyPtr	topology
	)

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

Parameters

timeoutSeconds	time to wait before aborting
nodes	expected number of nodes
topology	the topology object to query

Returns: true if expected number of nodes was reached. false in case of timeout before number was reached

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

/nebulastream/nes-coordinator/tests/Integration/QueryRedeploymentIntegrationTest.cpp

Static Public Member Functions

Additional Inherited Members

Member Function Documentation

◆ SetUpTestCase()

◆ waitForNodes()