IExportDestination.h

Go to the documentation of this file.

//
// Created by Nico on 20/03/2019.
//
 
#ifndef JODA_IEXPORTDESTINATION_H
#define JODA_IEXPORTDESTINATION_H
 
#include <joda/container/ContainerFlags.h>
#include <joda/misc/RecurringTimer.h>
 
class IExportDestination {
 public:
  virtual ~IExportDestination() = default;
 
  virtual void consume(JsonContainerQueue::queue_t &queue) {
    timer.start();
    this->consumeContainer(queue);
    timer.stop();
  };
 
  std::pair<std::string, double> getTimer() {
    return {getTimerName(), timer.durationSeconds()};
  };
 
  virtual const std::string toString() = 0;
 
  virtual const std::string toQueryString() = 0;
 
 protected:
  virtual void consumeContainer(JsonContainerQueue::queue_t &queue) {
    std::unique_ptr<JSONContainer> cont;
    while (!queue.isFinished()) {
      queue.retrieve(cont);
      if (cont == nullptr) {
        LOG(WARNING) << "Received nullptr as container.";
        continue;
      }
      this->exportContainer(std::move(cont));
    }
  };
  virtual void exportContainer(std::unique_ptr<JSONContainer> &&cont) = 0;
  virtual const std::string getTimerName() = 0;
  RecurringTimer timer;
};
 
#endif  // JODA_IEXPORTDESTINATION_H