logger_di_integration_example.cpp File Reference

Monitoring system integration example with Result pattern. More...

#include <kcenon/monitoring/core/performance_monitor.h>
#include <kcenon/monitoring/core/result_types.h>
#include <kcenon/common/interfaces/logger_interface.h>
#include <kcenon/common/interfaces/monitoring_interface.h>
#include <iostream>
#include <memory>
#include <thread>
#include <chrono>
#include <iomanip>

Include dependency graph for logger_di_integration_example.cpp:

Go to the source code of this file.

Classes
class	simple_console_logger
	Simple logger implementation for demonstration. More...

Functions
void	example_1_basic_monitoring ()
	Example 1: Basic monitoring with Result pattern.
void	example_2_error_handling ()
	Example 2: Error handling with Result pattern.
void	example_3_threshold_monitoring ()
	Example 3: Threshold monitoring.
void	example_4_multiple_monitors ()
	Example 4: Multiple monitors.
void	example_5_metrics_with_tags ()
	Example 5: Metrics with tags.
void	example_6_monitoring_workflow ()
	Example 6: Simulating monitoring workflow.
int	main ()

Detailed Description

Monitoring system integration example with Result pattern.

Definition in file logger_di_integration_example.cpp.

Function Documentation

example_1_basic_monitoring()

void example_1_basic_monitoring

(

)

Example 1: Basic monitoring with Result pattern.

Examples

logger_di_integration_example.cpp.

Definition at line 95 of file logger_di_integration_example.cpp.

                                  {
    std::cout << "\n=== Example 1: Basic Monitoring ===" << std::endl;
 
    // Create monitor
    auto monitor = std::make_shared<performance_monitor>();
 
    std::cout << "\nRecording metrics..." << std::endl;
 
    // Record metrics using Result pattern (updated API: record_counter, record_gauge)
    auto result1 = monitor->record_counter("requests_total", 100.0);
    if (result1.is_ok()) {
        std::cout << "  Metric 'requests_total' recorded" << std::endl;
    }
 
    auto result2 = monitor->record_counter("errors_total", 5.0);
    if (result2.is_ok()) {
        std::cout << "  Metric 'errors_total' recorded" << std::endl;
    }
 
    // Get metrics snapshot using collect()
    auto metrics = monitor->collect();
    if (metrics.is_ok()) {
        const auto& snapshot = metrics.value();
        std::cout << "  Retrieved " << snapshot.metrics.size() << " metrics" << std::endl;
    }
}

Referenced by main().

Here is the caller graph for this function:

example_2_error_handling()

void example_2_error_handling

(

)

Example 2: Error handling with Result pattern.

Examples

logger_di_integration_example.cpp.

Definition at line 125 of file logger_di_integration_example.cpp.

                                {
    std::cout << "\n=== Example 2: Error Handling ===" << std::endl;
 
    auto monitor = std::make_shared<performance_monitor>();
 
    // Record metric and check result (updated API: record_gauge)
    auto result = monitor->record_gauge("cpu_usage", 45.5);
    if (result.is_ok()) {
        std::cout << "  Metric recorded successfully" << std::endl;
    } else {
        const auto& err = result.error();
        std::cout << "  Error: " << err.message << std::endl;
    }
}

Referenced by main().

Here is the caller graph for this function:

example_3_threshold_monitoring()

void example_3_threshold_monitoring

(

)

Example 3: Threshold monitoring.

Examples

logger_di_integration_example.cpp.

Definition at line 143 of file logger_di_integration_example.cpp.

                                      {
    std::cout << "\n=== Example 3: Threshold Monitoring ===" << std::endl;
 
    auto monitor = std::make_shared<performance_monitor>();
 
    std::cout << "\nConfiguring thresholds..." << std::endl;
 
    // Set thresholds
    monitor->set_cpu_threshold(80.0);
    monitor->set_memory_threshold(90.0);
    monitor->set_latency_threshold(std::chrono::milliseconds(1000));
 
    // Check thresholds
    auto threshold_result = monitor->check_thresholds();
    if (threshold_result.is_ok()) {
        bool exceeded = threshold_result.value();
        std::cout << "  Thresholds exceeded: " << (exceeded ? "Yes" : "No") << std::endl;
 
        auto thresholds = monitor->get_thresholds();
        std::cout << "  CPU threshold: " << thresholds.cpu_threshold << "%" << std::endl;
        std::cout << "  Memory threshold: " << thresholds.memory_threshold << "%" << std::endl;
        std::cout << "  Latency threshold: " << thresholds.latency_threshold.count() << "ms" << std::endl;
    }
}

Referenced by main().

Here is the caller graph for this function:

example_4_multiple_monitors()

void example_4_multiple_monitors

(

)

Example 4: Multiple monitors.

Examples

logger_di_integration_example.cpp.

Definition at line 171 of file logger_di_integration_example.cpp.

                                   {
    std::cout << "\n=== Example 4: Multiple Monitors ===" << std::endl;
 
    // Create multiple monitors
    auto monitor1 = std::make_shared<performance_monitor>("monitor1");
    auto monitor2 = std::make_shared<performance_monitor>("monitor2");
 
    std::cout << "\nMonitor 1 recording metrics..." << std::endl;
    monitor1->record_counter("monitor1_metric", 100.0);
 
    std::cout << "Monitor 2 recording metrics..." << std::endl;
    monitor2->record_counter("monitor2_metric", 200.0);
 
    // Get metrics from both using collect()
    auto metrics1 = monitor1->collect();
    auto metrics2 = monitor2->collect();
 
    if (metrics1.is_ok() && metrics2.is_ok()) {
        const auto& snapshot1 = metrics1.value();
        const auto& snapshot2 = metrics2.value();
        std::cout << "  Monitor 1: " << snapshot1.metrics.size() << " metrics" << std::endl;
        std::cout << "  Monitor 2: " << snapshot2.metrics.size() << " metrics" << std::endl;
    }
}

Referenced by main().

Here is the caller graph for this function:

example_5_metrics_with_tags()

void example_5_metrics_with_tags

(

)

Example 5: Metrics with tags.

Examples

logger_di_integration_example.cpp.

Definition at line 199 of file logger_di_integration_example.cpp.

                                   {
    std::cout << "\n=== Example 5: Metrics with Tags ===" << std::endl;
 
    auto monitor = std::make_shared<performance_monitor>();
 
    // Record metrics with tags (updated API: record_histogram with tags)
    tag_map tags{
        {"service", "api"},
        {"region", "us-east-1"},
        {"instance", "i-12345"}
    };
 
    auto result = monitor->record_histogram("request_latency", 150.0, tags);
    if (result.is_ok()) {
        std::cout << "  Metric with tags recorded successfully" << std::endl;
    }
 
    // Get all tagged metrics
    auto all_metrics = monitor->get_all_tagged_metrics();
    std::cout << "  Total tagged metrics: " << all_metrics.size() << std::endl;
}

Referenced by main().

Here is the caller graph for this function:

example_6_monitoring_workflow()

void example_6_monitoring_workflow

(

)

Example 6: Simulating monitoring workflow.

Examples

logger_di_integration_example.cpp.

Definition at line 224 of file logger_di_integration_example.cpp.

                                     {
    std::cout << "\n=== Example 6: Monitoring Workflow ===" << std::endl;
 
    auto monitor = std::make_shared<performance_monitor>();
    auto logger = std::make_shared<simple_console_logger>();
 
    std::cout << "\nSimulating application workload..." << std::endl;
 
    // Simulate application metrics (updated API: record_gauge)
    for (int i = 0; i < 5; ++i) {
        auto result = monitor->record_gauge("requests", static_cast<double>(i * 10));
        if (result.is_ok()) {
            logger->log(log_level::info, "Recorded metric: requests = " + std::to_string(i * 10));
        }
        std::this_thread::sleep_for(std::chrono::milliseconds(100));
    }
 
    // Check thresholds and log results
    auto threshold_result = monitor->check_thresholds();
    if (threshold_result.is_ok()) {
        bool exceeded = threshold_result.value();
        logger->log(log_level::info, "Thresholds exceeded: " + std::string(exceeded ? "Yes" : "No"));
    }
 
    // Get metrics and log summary
    auto metrics = monitor->collect();
    if (metrics.is_ok()) {
        const auto& snapshot = metrics.value();
        logger->log(log_level::info, "Collected " + std::to_string(snapshot.metrics.size()) + " metrics");
    }
 
    std::cout << "\n  Workflow completed successfully" << std::endl;
    std::cout << "  Logger events: " << logger->get_log_count() << std::endl;
}

Referenced by main().

Here is the caller graph for this function:

main()

int main

(

)

Definition at line 259 of file logger_di_integration_example.cpp.

           {
    std::cout << "========================================================" << std::endl;
    std::cout << "Monitoring System - Integration Examples" << std::endl;
    std::cout << "Using common_system interfaces and Result<T> pattern" << std::endl;
    std::cout << "========================================================" << std::endl;
 
    try {
        example_1_basic_monitoring();
        example_2_error_handling();
        example_3_threshold_monitoring();
        example_4_multiple_monitors();
        example_5_metrics_with_tags();
        example_6_monitoring_workflow();
 
        std::cout << "\n========================================================" << std::endl;
        std::cout << "All integration examples completed!" << std::endl;
        std::cout << "Key Points:" << std::endl;
        std::cout << "    common_system interfaces used" << std::endl;
        std::cout << "    Result<T> pattern for error handling" << std::endl;
        std::cout << "    Interface-based loose coupling" << std::endl;
        std::cout << "    Comprehensive monitoring" << std::endl;
        std::cout << "========================================================" << std::endl;
 
    } catch (const std::exception& e) {
        std::cerr << "Error: " << e.what() << std::endl;
        return 1;
    }
 
    return 0;
}

References example_1_basic_monitoring(), example_2_error_handling(), example_3_threshold_monitoring(), example_4_multiple_monitors(), example_5_metrics_with_tags(), and example_6_monitoring_workflow().

Here is the call graph for this function: