ILogReader.hpp

Go to the documentation of this file.

#pragma once
#ifndef LOGIT_CPP_HEADER_LOGIT_CPP_LOGIT_LOGGERS_ILOGREADER_HPP_INCLUDED
#define LOGIT_CPP_HEADER_LOGIT_CPP_LOGIT_LOGGERS_ILOGREADER_HPP_INCLUDED
 
 
#include "../enums.hpp"
#include <cstddef>
#include <cstdint>
#include <string>
#include <vector>
#if __cplusplus >= 201703L
#include <optional>
#endif
 
namespace logit {
 
    struct LogRecordSnapshot {
        uint64_t session_id = 0;                     
        int64_t timestamp_ms = 0;                    
        uint32_t sequence = 0;                       
        LogLevel level = LogLevel::LOG_LVL_TRACE;    
        std::string message;                         
        uint64_t payload_id = 0;                     
        std::string file;                            
        std::string function;                        
        int line = 0;                                
    };
 
    enum class LogReadOrder {
        Ascending,   
        Descending   
    };
 
#if __cplusplus >= 201703L
    enum class LogReadError {
        None,
        NotFound,
        StorageError,
        DecodeError,
        UnsupportedVersion,
        DecompressionError
    };
 
    template <typename T>
    struct LogReadResult {
        std::optional<T> value; 
        LogReadError error = LogReadError::None; 
        std::string message; 
    };
#endif
 
    class ILogReader {
    public:
        virtual ~ILogReader() = default;
 
        virtual std::vector<LogRecordSnapshot> read_range(
            int64_t from_ms,
            int64_t to_ms,
            std::size_t limit = 0) const = 0;
 
#if __cplusplus >= 201703L
        virtual LogReadResult<std::vector<LogRecordSnapshot>> read_range_result(
            int64_t from_ms,
            int64_t to_ms,
            std::size_t limit = 0) const {
            LogReadResult<std::vector<LogRecordSnapshot>> result;
            result.value = read_range(from_ms, to_ms, limit);
            return result;
        }
#endif
 
        virtual std::vector<LogRecordSnapshot> read_recent(
            std::size_t limit,
            int64_t period_ms = 0,
            LogReadOrder order = LogReadOrder::Ascending) const = 0;
 
#if __cplusplus >= 201703L
        virtual LogReadResult<std::vector<LogRecordSnapshot>> read_recent_result(
            std::size_t limit,
            int64_t period_ms = 0,
            LogReadOrder order = LogReadOrder::Ascending) const {
            LogReadResult<std::vector<LogRecordSnapshot>> result;
            result.value = read_recent(limit, period_ms, order);
            return result;
        }
#endif
    };
 
} // namespace logit
 
#endif // LOGIT_CPP_HEADER_LOGIT_CPP_LOGIT_LOGGERS_ILOGREADER_HPP_INCLUDED