core_log_sink.hpp

//
// Created by greg on 8/5/25.
// Copyright (c) 2025 Presage Technologies
//
// SPDX-License-Identifier: LGPL-3.0-or-later
 
#pragma once
// === standard library includes (if any) ===
#include <atomic>
// === third-party includes (if any) ===
#include <reproc++/reproc.hpp>
// === local includes (if any) ===
#include "log_buffer.hpp"
 
namespace presage::smartspectra::grpc_bindings {
 
class CoreLogSink {
public:
    explicit CoreLogSink(LogBuffer& buffer, std::atomic<bool>& shutdown) noexcept;
 
    std::error_code operator()(reproc::stream stream, const uint8_t *buffer_line, size_t size);
private:
    LogBuffer& buffer;
    std::atomic<bool>& shutdown;
};
 
} // namespace presage::smartspectra::grpc_bindings