log_collector.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include <kcenon/common/interfaces/logger_interface.h>
#include <kcenon/logger/interfaces/log_writer_interface.h>
#include <kcenon/logger/logger_export.h>
 
#include <atomic>
#include <chrono>
#include <memory>
#include <vector>
 
namespace kcenon::logger {
 
class LOGGER_SYSTEM_API log_collector {
public:
    explicit log_collector(std::size_t buffer_size = 8192, std::size_t batch_size = 100);
    
    ~log_collector();
    
    bool enqueue(common::interfaces::log_level level,
                 const std::string& message,
                 const std::string& file,
                 int line,
                 const std::string& function,
                 const std::chrono::system_clock::time_point& timestamp);
    
    void add_writer(std::shared_ptr<log_writer_interface> writer);
    
    void clear_writers();
    
    void start();
    
    void stop();
    
    void flush();
    
    std::pair<size_t, size_t> get_queue_metrics() const;
    
private:
    class impl;
    std::unique_ptr<impl> pimpl_;
};
 
} // namespace kcenon::logger