log_parser.h

Go to the documentation of this file.

// Splits the log stream into individual messages
// Author: Max Schwarz <max.schwarz@ais.uni-bonn.de>
 
#ifndef ROSMON_MONITOR_LOG_PARSER_H
#define ROSMON_MONITOR_LOG_PARSER_H
 
#include <chrono>
#include <memory>
#include <functional>
 
#include "../log_event.h"
 
namespace rosmon
{
namespace monitor
{
 
class LogParser
{
public:
        LogParser();
        ~LogParser();
 
        struct Event
        {
                std::string message;
                LogEvent::Type severity;
        };
 
        void setCallback(const std::function<void(Event&&)>& cb);
 
        void process(const char* input, std::size_t size, const std::chrono::steady_clock::time_point& time = std::chrono::steady_clock::now());
 
        inline void processString(const std::string& str, const std::chrono::steady_clock::time_point& time = std::chrono::steady_clock::now())
        { process(str.c_str(), str.length(), time); }
 
        void checkPending(const std::chrono::steady_clock::time_point& time = std::chrono::steady_clock::now());
 
        void flush();
 
private:
        class Private;
        std::unique_ptr<Private> m_d;
};
 
}
}
 
 
#endif