NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::SourceCatalogControllerTest Class Reference
Collaboration diagram for NES::SourceCatalogControllerTest:
[legend]

Public Member Functions

void startCoordinator ()
 
void startCoordinator (CoordinatorConfigurationPtr coordinatorConfiguration)
 
void stopCoordinator ()
 
- 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 void TearDownTestCase ()
 

Public Attributes

CoordinatorConfigurationPtr coordinatorConfig
 
NesCoordinatorPtr coordinator
 
- 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

◆ SetUpTestCase()

static void NES::SourceCatalogControllerTest::SetUpTestCase ( )
inlinestatic

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

Here is the call graph for this function:

◆ startCoordinator() [1/2]

void NES::SourceCatalogControllerTest::startCoordinator ( )
inline

Starts a coordinator with the following configurations rpcPort = rpcCoordinatorPort specified in BaseIntegrationTest restPort = restPort specified in BaseIntegrationTest

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

Here is the call graph for this function:

◆ startCoordinator() [2/2]

void NES::SourceCatalogControllerTest::startCoordinator ( CoordinatorConfigurationPtr  coordinatorConfiguration)
inline

Starts a coordinator with the given configurations Use when configurations mentioned in startCoordinator() dont suit needs

Parameters
coordinatorConfig

References coordinator, and NES_INFO.

◆ stopCoordinator()

void NES::SourceCatalogControllerTest::stopCoordinator ( )
inline

References coordinator.

◆ TearDownTestCase()

static void NES::SourceCatalogControllerTest::TearDownTestCase ( )
inlinestatic

References NES_INFO.

Member Data Documentation

◆ coordinator

NesCoordinatorPtr NES::SourceCatalogControllerTest::coordinator

◆ coordinatorConfig

CoordinatorConfigurationPtr NES::SourceCatalogControllerTest::coordinatorConfig

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