A class to keep Configurations of different nodes in the topology. More...

#include <TestHarnessWorkerConfiguration.hpp>

Public Types
enum class	TestHarnessWorkerSourceType : int8_t { CSVSource , MemorySource , LambdaSource , NonSource }

Public Member Functions
void	setQueryStatusListener (const NesWorkerPtr &nesWorker)

const WorkerConfigurationPtr &	getWorkerConfiguration () const

TestHarnessWorkerSourceType	getSourceType () const

PhysicalSourceTypePtr	getPhysicalSourceType () const

void	setPhysicalSourceType (PhysicalSourceTypePtr physicalSource)

const std::vector< uint8_t * > &	getRecords () const

void	addRecord (uint8_t *record)

WorkerId	getWorkerId () const

const std::string &	getLogicalSourceName () const

const std::string &	getPhysicalSourceName () const

const NesWorkerPtr &	getNesWorker () const

Static Public Member Functions
static TestHarnessWorkerConfigurationPtr	create (WorkerConfigurationPtr workerConfiguration, WorkerId workerId)

static TestHarnessWorkerConfigurationPtr	create (WorkerConfigurationPtr workerConfiguration, std::string logicalSourceName, std::string physicalSourceName, TestHarnessWorkerSourceType sourceType, WorkerId workerId)

Detailed Description

A class to keep Configurations of different nodes in the topology.

Member Enumeration Documentation

◆ TestHarnessWorkerSourceType

enum NES::TestHarnessWorkerConfiguration::TestHarnessWorkerSourceType : int8_t

strong

Enumerator
CSVSource
MemorySource
LambdaSource
NonSource

Member Function Documentation

◆ addRecord()

void NES::TestHarnessWorkerConfiguration::addRecord ( uint8_t * record )

◆ create() [1/2]

TestHarnessWorkerConfigurationPtr NES::TestHarnessWorkerConfiguration::create	(	WorkerConfigurationPtr	workerConfiguration,
		std::string	logicalSourceName,
		std::string	physicalSourceName,
		TestHarnessWorkerSourceType	sourceType,
		WorkerId	workerId
	)

static

References backward::details::move().

Here is the call graph for this function:

◆ create() [2/2]

TestHarnessWorkerConfigurationPtr NES::TestHarnessWorkerConfiguration::create	(	WorkerConfigurationPtr	workerConfiguration,
		WorkerId	workerId
	)

static

References backward::details::move(), and NonSource.

Referenced by NES::TestHarness::attachWorkerToWorkerWithId(), NES::TestHarness::attachWorkerWithCSVSourceToWorkerWithId(), NES::TestHarness::attachWorkerWithLambdaSourceToCoordinator(), and NES::TestHarness::attachWorkerWithMemorySourceToWorkerWithId().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getLogicalSourceName()

const std::string & NES::TestHarnessWorkerConfiguration::getLogicalSourceName ( ) const

◆ getNesWorker()

const NesWorkerPtr & NES::TestHarnessWorkerConfiguration::getNesWorker ( ) const

◆ getPhysicalSourceName()

const std::string & NES::TestHarnessWorkerConfiguration::getPhysicalSourceName ( ) const

◆ getPhysicalSourceType()

PhysicalSourceTypePtr NES::TestHarnessWorkerConfiguration::getPhysicalSourceType ( ) const

◆ getRecords()

const std::vector< uint8_t * > & NES::TestHarnessWorkerConfiguration::getRecords ( ) const

◆ getSourceType()

TestHarnessWorkerConfiguration::TestHarnessWorkerSourceType NES::TestHarnessWorkerConfiguration::getSourceType ( ) const

◆ getWorkerConfiguration()

const WorkerConfigurationPtr & NES::TestHarnessWorkerConfiguration::getWorkerConfiguration ( ) const

◆ getWorkerId()

WorkerId NES::TestHarnessWorkerConfiguration::getWorkerId ( ) const

◆ setPhysicalSourceType()

void NES::TestHarnessWorkerConfiguration::setPhysicalSourceType ( PhysicalSourceTypePtr physicalSource )

◆ setQueryStatusListener()

void NES::TestHarnessWorkerConfiguration::setQueryStatusListener ( const NesWorkerPtr & nesWorker )

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

/nebulastream/nes-coordinator/tests/include/Util/TestHarness/TestHarnessWorkerConfiguration.hpp
/nebulastream/nes-coordinator/tests/src/Util/TestHarness/TestHarnessWorkerConfiguration.cpp

Public Types

Public Member Functions

Static Public Member Functions