NES::StatisticsIntegrationTest Class Reference

Collaboration diagram for NES::StatisticsIntegrationTest:

Public Member Functions
void	SetUp () override
void	TearDown () override
NesWorkerPtr	createWorker (const string &defaultLogicalSourceName, const std::string &physicalSourceName, const uint64_t coordinatorRPCPort, WorkerId workerId)
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
RequestHandlerServicePtr	requestHandlerService
Statistic::StatisticProbeHandlerPtr	probeHandler
std::vector< NesWorkerPtr >	allWorkers
NesCoordinatorPtr	nesCoordinator
SchemaPtr	testInputSchema
const std::string	logicalSourceName = "defaultLogicalSourceName"
const std::string	basePhysicalSourceName = "basePhysicalSourceName"
std::vector< std::string >	physicalSourceNames
uint64_t	numberOfWorkers
uint64_t	numberOfBuffersToProduce
uint64_t	windowSize
Statistic::MetricPtr	metric
Public Attributes inherited from NES::Testing::BaseUnitTest
detail::TestSourceNameHelper	srcName

Static Public Attributes
static constexpr auto	timeout = std::chrono::seconds(10)
static constexpr auto	fieldNameToTrack = "id"
static constexpr auto	timestampFieldName = "timestamp"
static constexpr auto	gatheringValue = 0

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

createWorker()

NesWorkerPtr NES::StatisticsIntegrationTest::createWorker ( const string &  defaultLogicalSourceName, const std::string &  physicalSourceName, const uint64_t  coordinatorRPCPort, WorkerId  workerId  )

inline

blocking

withConnect

References backward::details::move(), NES_DEBUG, NES::TestUtils::numberOfBuffersToProduce(), NES::TestUtils::physicalSourceName(), NES::Runtime::TupleBuffer::setNumberOfTuples(), and worker.

Here is the call graph for this function:

SetUp()

void NES::StatisticsIntegrationTest::SetUp ( )

inlineoverride

blocking

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

Here is the call graph for this function:

SetUpTestCase()

static void NES::StatisticsIntegrationTest::SetUpTestCase ( )

inlinestatic

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

Here is the call graph for this function:

TearDown()

void NES::StatisticsIntegrationTest::TearDown ( )

inlineoverride

References NES_INFO, and worker.

Member Data Documentation

allWorkers

std::vector<NesWorkerPtr> NES::StatisticsIntegrationTest::allWorkers

basePhysicalSourceName

const std::string NES::StatisticsIntegrationTest::basePhysicalSourceName = "basePhysicalSourceName"

fieldNameToTrack

constexpr auto NES::StatisticsIntegrationTest::fieldNameToTrack = "id"

staticconstexpr

gatheringValue

constexpr auto NES::StatisticsIntegrationTest::gatheringValue = 0

staticconstexpr

logicalSourceName

const std::string NES::StatisticsIntegrationTest::logicalSourceName = "defaultLogicalSourceName"

metric

Statistic::MetricPtr NES::StatisticsIntegrationTest::metric

nesCoordinator

NesCoordinatorPtr NES::StatisticsIntegrationTest::nesCoordinator

numberOfBuffersToProduce

uint64_t NES::StatisticsIntegrationTest::numberOfBuffersToProduce

numberOfWorkers

uint64_t NES::StatisticsIntegrationTest::numberOfWorkers

physicalSourceNames

std::vector<std::string> NES::StatisticsIntegrationTest::physicalSourceNames

probeHandler

Statistic::StatisticProbeHandlerPtr NES::StatisticsIntegrationTest::probeHandler

requestHandlerService

RequestHandlerServicePtr NES::StatisticsIntegrationTest::requestHandlerService

testInputSchema

SchemaPtr NES::StatisticsIntegrationTest::testInputSchema

timeout

constexpr auto NES::StatisticsIntegrationTest::timeout = std::chrono::seconds(10)

staticconstexpr

timestampFieldName

constexpr auto NES::StatisticsIntegrationTest::timestampFieldName = "timestamp"

staticconstexpr

windowSize

uint64_t NES::StatisticsIntegrationTest::windowSize

---

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

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