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

Nes components that require to be reconfigured at Runtime need to inherit from this class. It provides a reconfigure callback that will be called per thread and a postReconfigurationCallback that will be called on the last thread the executes the reconfiguration. More...

#include <Reconfigurable.hpp>

Collaboration diagram for NES::Runtime::Reconfigurable:
[legend]

Public Member Functions

 ~Reconfigurable () NES_NOEXCEPT(false) override=default
 
virtual void reconfigure (ReconfigurationMessage &, WorkerContext &)
 reconfigure callback that will be called per thread More...
 
virtual void postReconfigurationCallback (ReconfigurationMessage &)
 callback that will be called on the last thread the executes the reconfiguration More...
 
- Public Member Functions inherited from NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >
 ~virtual_enable_shared_from_this () NES_NOEXCEPT(isNoexceptDestructible) 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< isNoexceptDestructible >
virtual ~virtual_enable_shared_from_this_base () NES_NOEXCEPT(isNoexceptDestructible)=default
 

Detailed Description

Nes components that require to be reconfigured at Runtime need to inherit from this class. It provides a reconfigure callback that will be called per thread and a postReconfigurationCallback that will be called on the last thread the executes the reconfiguration.

Constructor & Destructor Documentation

◆ ~Reconfigurable()

NES::Runtime::Reconfigurable::~Reconfigurable ( )
overridedefault

Member Function Documentation

◆ postReconfigurationCallback()

virtual void NES::Runtime::Reconfigurable::postReconfigurationCallback ( ReconfigurationMessage )
inlinevirtual

◆ reconfigure()

virtual void NES::Runtime::Reconfigurable::reconfigure ( ReconfigurationMessage ,
WorkerContext  
)
inlinevirtual

reconfigure callback that will be called per thread

Reimplemented in NES::Network::NetworkSink, NES::SinkMedium, NES::Network::NetworkSource, NES::Runtime::Execution::ExecutablePipeline, and NES::Runtime::AbstractQueryManager.

Referenced by NES::Runtime::AbstractQueryManager::reconfigure(), NES::Runtime::Execution::ExecutablePipeline::reconfigure(), NES::Network::NetworkSource::reconfigure(), and NES::SinkMedium::reconfigure().

Here is the caller graph for this function:

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