ThrottledConsumer.h

#pragma once
 
#include "Consumer.h"
#include "Logger.h"
 
#include <map>
#include <string>
 
namespace Cogs {
  namespace Logging {
    class COGSFOUNDATION_API ThrottledConsumer : public Consumer {
    public:
      static void setEnabled(bool enable);
      virtual void consumeMessage(const char* source, Category category, uint32_t errorNumber, const char * message, const char* filename, int lineNumber) override;
      void flush(bool flushAll = true);
 
    protected:
      struct Message {
        std::string message;                  
        std::string source;                   
        int count = 0;                        
        int64_t outputTime = 0;               
        const char* file = nullptr;           
        int line = 0;                         
        Category category = Category::Trace;  
      };
 
    private:
      using MessageMap = std::map<size_t, Message>;
 
      MessageMap messages;
      Mutex messagesMutex;
 
      virtual void outputMessage(const std::string& prefix, const Message& message) = 0;
    };
  }
}