kcenon::monitoring::alert_pipeline Class Reference

Configurable alert processing pipeline. More...

#include <alert_pipeline.h>

Collaboration diagram for kcenon::monitoring::alert_pipeline:

Public Member Functions
void	add_stage (std::shared_ptr< pipeline_stage > stage)
	Add a processing stage.
bool	process (alert &a)
	Process an alert through all stages.
std::vector< std::string >	stage_names () const
	Get stage names.

Private Attributes
std::vector< std::shared_ptr< pipeline_stage > >	stages_

Detailed Description

Configurable alert processing pipeline.

Allows building custom alert processing workflows by chaining multiple processing stages together.

Definition at line 615 of file alert_pipeline.h.

Member Function Documentation

add_stage()

void kcenon::monitoring::alert_pipeline::add_stage ( std::shared_ptr< pipeline_stage > stage )

inline

Add a processing stage.

Examples

/home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_pipeline.h.

Definition at line 620 of file alert_pipeline.h.

                                                        {
        stages_.push_back(std::move(stage));
    }

References stages_.

process()

bool kcenon::monitoring::alert_pipeline::process ( alert & a )

inline

Process an alert through all stages.

Parameters

a	Alert to process

Returns

True if alert passed all stages

Definition at line 629 of file alert_pipeline.h.

                           {
        for (const auto& stage : stages_) {
            if (!stage->process(a)) {
                return false;
            }
        }
        return true;
    }

References stages_.

stage_names()

std::vector< std::string > kcenon::monitoring::alert_pipeline::stage_names ( ) const

inline

Get stage names.

Examples

/home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_pipeline.h.

Definition at line 641 of file alert_pipeline.h.

                                             {
        std::vector<std::string> names;
        names.reserve(stages_.size());
        for (const auto& stage : stages_) {
            names.push_back(stage->name());
        }
        return names;
    }

References stages_.

Member Data Documentation

stages_

std::vector<std::shared_ptr<pipeline_stage> > kcenon::monitoring::alert_pipeline::stages_

private

Examples

/home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_pipeline.h.

Definition at line 651 of file alert_pipeline.h.

Referenced by add_stage(), process(), and stage_names().

---

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

• include/kcenon/monitoring/alert/alert_pipeline.h