NES::MonitoringQueriesTest Class Reference

Collaboration diagram for NES::MonitoringQueriesTest:

Public Member Functions
void	SetUp () override
NesCoordinatorPtr	createCoordinator ()
NesWorkerPtr	createWorker (PhysicalSourceTypePtr phSource)
std::string	createQueryString (std::string logicalStream, std::string metricCollectorString)
void	runMetricsQueryTest (uint64_t workerCnt, Monitoring::MetricCollectorType collectorType, SchemaPtr schema, Monitoring::MetricType expectedType)
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 ()

Public Attributes
Runtime::BufferManagerPtr	bufferManager
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

createCoordinator()

NesCoordinatorPtr NES::MonitoringQueriesTest::createCoordinator ( )

inline

References NES::Testing::BaseIntegrationTest::restPort, and NES::Testing::BaseIntegrationTest::rpcCoordinatorPort.

Referenced by runMetricsQueryTest().

Here is the caller graph for this function:

createQueryString()

std::string NES::MonitoringQueriesTest::createQueryString ( std::string  logicalStream, std::string  metricCollectorString  )

inline

Referenced by runMetricsQueryTest().

Here is the caller graph for this function:

createWorker()

NesWorkerPtr NES::MonitoringQueriesTest::createWorker ( PhysicalSourceTypePtr  phSource )

inline

References backward::details::move(), and NES::Testing::BaseIntegrationTest::rpcCoordinatorPort.

Referenced by runMetricsQueryTest().

Here is the call graph for this function:

Here is the caller graph for this function:

runMetricsQueryTest()

void NES::MonitoringQueriesTest::runMetricsQueryTest ( uint64_t  workerCnt, Monitoring::MetricCollectorType  collectorType, SchemaPtr  schema, Monitoring::MetricType  expectedType  )

inline

blocking

blocking

withConnect

References NES::Optimizer::BottomUp, NES::TestUtils::checkCompleteOrTimeout(), NES::TestUtils::checkStoppedOrTimeout(), createCoordinator(), NES::Monitoring::MetricUtils::createMetricFromCollectorType(), createQueryString(), createWorker(), magic_enum::enum_name(), NES::Monitoring::SystemResourcesReaderFactory::getSystemResourcesReader(), NES::MetricValidator::isValid(), NES_DEBUG, NES_INFO, nodeId, NES::TestUtils::sourceType(), and NES::TestUtils::waitForQueryToStart().

Here is the call graph for this function:

SetUp()

void NES::MonitoringQueriesTest::SetUp ( )

inlineoverride

References bufferManager, NES_INFO, NES::Testing::BaseIntegrationTest::restPort, NES::Testing::BaseIntegrationTest::rpcCoordinatorPort, and NES::Testing::BaseIntegrationTest::SetUp().

Here is the call graph for this function:

SetUpTestCase()

static void NES::MonitoringQueriesTest::SetUpTestCase ( )

inlinestatic

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

Here is the call graph for this function:

Member Data Documentation

bufferManager

Runtime::BufferManagerPtr NES::MonitoringQueriesTest::bufferManager

Referenced by SetUp().

---

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

• /nebulastream/nes-coordinator/tests/UnitTests/Monitoring/MonitoringQueriesTest.cpp