NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::CoordinatorHealthCheckService Class Reference

: This class is responsible for handling requests related to monitor the alive status of nodes from the coordinator More...

#include <CoordinatorHealthCheckService.hpp>

Collaboration diagram for NES::CoordinatorHealthCheckService:
[legend]

Public Member Functions

 CoordinatorHealthCheckService (TopologyPtr topology, std::string healthServiceName, Configurations::CoordinatorConfigurationPtr coordinatorConfiguration)
 
void startHealthCheck () override
 

Detailed Description

: This class is responsible for handling requests related to monitor the alive status of nodes from the coordinator

Constructor & Destructor Documentation

◆ CoordinatorHealthCheckService()

NES::CoordinatorHealthCheckService::CoordinatorHealthCheckService ( TopologyPtr  topology,
std::string  healthServiceName,
Configurations::CoordinatorConfigurationPtr  coordinatorConfiguration 
)

Member Function Documentation

◆ startHealthCheck()

void NES::CoordinatorHealthCheckService::startHealthCheck ( )
override

Method to start the health checking

References magic_enum::detail::find(), NES_DEBUG, NES_INFO, NES_TRACE, NES_WARNING, and NES::setThreadName().

Here is the call graph for this function:

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