![]() |
Fledge
An open source edge computing platform for industrial users
|
The debugger class for elements in a pipeline. More...
#include <pipeline_debugger.h>
Public Types | |
enum | debuggerActions { NoAction, Block } |
typedef enum PipelineDebugger::debuggerActions | DebuggerActions |
Public Member Functions | |
PipelineDebugger () | |
Constructor for the pipeline element debugger. | |
~PipelineDebugger () | |
Destructor for the pipeline element debugger. | |
DebuggerActions | process (ReadingSet *readingSet) |
Process a reading set as it flows through the pipeline. More... | |
void | setBuffer (unsigned int size) |
Set the size of the circular buffer used to buffer the data flowing in the pipeline. More... | |
void | clearBuffer () |
Remove the circular buffer of readings and stop the process of storing future readings. | |
std::vector< std::shared_ptr< Reading > > | fetchBuffer () |
Fetch the current contents of the circular buffer. More... | |
The debugger class for elements in a pipeline.
std::vector< std::shared_ptr< Reading > > PipelineDebugger::fetchBuffer | ( | ) |
Fetch the current contents of the circular buffer.
A vector of shared pointers is returned to alleviate the need to copy the readings.
PipelineDebugger::DebuggerActions PipelineDebugger::process | ( | ReadingSet * | readings | ) |
Process a reading set as it flows through the pipeline.
The main purpose here is to buffer the readings in the circular buffer in order to allow later examination of the data.
readings | The reading set flowing into the pipeline element |
void PipelineDebugger::setBuffer | ( | unsigned int | size | ) |
Set the size of the circular buffer used to buffer the data flowing in the pipeline.
size | The number of readings to buffer |