NES::QueryReconfigurationTest Class Reference

Collaboration diagram for NES::QueryReconfigurationTest:

Public Member Functions
void	startCoordinator ()
NesWorkerPtr	startWorker (std::vector< uint64_t > sourceIndices)
NesWorkerPtr	startWorkerAsChildOf (std::vector< uint64_t > sourceIndices, NesWorkerPtr parent)
NesWorkerPtr	startWorkerWithLambdaSource (std::string logicalSourceName, std::string physicalSourceName, NesWorkerPtr parent)
uint64_t	addLogicalSourceAndCreatePhysicalSourceType (std::string logicalSourceName, std::string physicalSourceName)
void	addMigrationPipelineToDecomposedQueryPlan (DecomposedQueryPlanPtr &decomposedPlan)
void	stop ()
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 ()

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

Public Attributes
uint64_t	tuplesPerBuffer = 10
uint8_t	bytesPerTuple = sizeof(uint64_t)
TopologyPtr	topology
NesCoordinatorPtr	crd
std::map< WorkerId, NesWorkerPtr >	workers
std::map< std::tuple< WorkerId, std::string >, uint64_t >	systemSourceIdentifierToTestLocalIdentifier
std::map< uint64_t, std::atomic< uint64_t > >	bufferCounts
std::map< uint64_t, std::atomic< uint64_t > >	finalBufferCounts
std::map< uint64_t, LambdaSourceTypePtr >	sourceTypes
std::map< uint64_t, std::atomic< bool > >	stopTriggers
uint64_t	gatheringValue = 10
SchemaPtr	schema = Schema::create()->addField(createField("value", BasicType::UINT64))
Public Attributes inherited from NES::Testing::BaseUnitTest
detail::TestSourceNameHelper	srcName

Additional Inherited Members
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

addLogicalSourceAndCreatePhysicalSourceType()

uint64_t NES::QueryReconfigurationTest::addLogicalSourceAndCreatePhysicalSourceType ( std::string  logicalSourceName, std::string  physicalSourceName  )

inline

References NES::TestUtils::logicalSourceName(), backward::details::move(), NES::TestUtils::physicalSourceName(), and magic_enum::detail::value().

Here is the call graph for this function:

addMigrationPipelineToDecomposedQueryPlan()

void NES::QueryReconfigurationTest::addMigrationPipelineToDecomposedQueryPlan ( DecomposedQueryPlanPtr &  decomposedPlan )

inline

SetUpTestCase()

static void NES::QueryReconfigurationTest::SetUpTestCase ( )

inlinestatic

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

Here is the call graph for this function:

startCoordinator()

void NES::QueryReconfigurationTest::startCoordinator ( )

inline

blocking

References NES_INFO, and NES::TestUtils::restPort().

Here is the call graph for this function:

startWorker()

NesWorkerPtr NES::QueryReconfigurationTest::startWorker ( std::vector< uint64_t >  sourceIndices )

inline

blocking

withConnect

References backward::details::move(), NES_INFO, NES::TestUtils::physicalSourceName(), and NES::TestUtils::sourceType().

Here is the call graph for this function:

startWorkerAsChildOf()

NesWorkerPtr NES::QueryReconfigurationTest::startWorkerAsChildOf ( std::vector< uint64_t >  sourceIndices, NesWorkerPtr  parent  )

inline

References NES::TestUtils::startWorker().

Here is the call graph for this function:

startWorkerWithLambdaSource()

NesWorkerPtr NES::QueryReconfigurationTest::startWorkerWithLambdaSource ( std::string  logicalSourceName, std::string  physicalSourceName, NesWorkerPtr  parent  )

inline

References NES::TestUtils::logicalSourceName(), and NES::TestUtils::physicalSourceName().

Here is the call graph for this function:

stop()

void NES::QueryReconfigurationTest::stop ( )

inline

waitForNodes()

static bool NES::QueryReconfigurationTest::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

Member Data Documentation

bufferCounts

std::map<uint64_t, std::atomic<uint64_t> > NES::QueryReconfigurationTest::bufferCounts

bytesPerTuple

uint8_t NES::QueryReconfigurationTest::bytesPerTuple = sizeof(uint64_t)

crd

NesCoordinatorPtr NES::QueryReconfigurationTest::crd

finalBufferCounts

std::map<uint64_t, std::atomic<uint64_t> > NES::QueryReconfigurationTest::finalBufferCounts

gatheringValue

uint64_t NES::QueryReconfigurationTest::gatheringValue = 10

schema

SchemaPtr NES::QueryReconfigurationTest::schema = Schema::create()->addField(createField("value", BasicType::UINT64))

sourceTypes

std::map<uint64_t, LambdaSourceTypePtr> NES::QueryReconfigurationTest::sourceTypes

stopTriggers

std::map<uint64_t, std::atomic<bool> > NES::QueryReconfigurationTest::stopTriggers

systemSourceIdentifierToTestLocalIdentifier

std::map<std::tuple<WorkerId, std::string>, uint64_t> NES::QueryReconfigurationTest::systemSourceIdentifierToTestLocalIdentifier

topology

TopologyPtr NES::QueryReconfigurationTest::topology

tuplesPerBuffer

uint64_t NES::QueryReconfigurationTest::tuplesPerBuffer = 10

workers

std::map<WorkerId, NesWorkerPtr> NES::QueryReconfigurationTest::workers

---

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

• /nebulastream/nes-coordinator/tests/Integration/QueryReconfigurationTest.cpp