libadiak_json.ipp

Go to the documentation of this file.

#include <adc/builder/builder.hpp>
#include <adc/publisher/publisher.hpp>
#include <cstdlib>
#include "adiak.hpp"
 
namespace adc {
 
std::map< const std::string, const std::string> libadiak_json_defaults;
 
/*! \brief Terminal output publisher_api implementation.
  This plugin sends messages to libadiak synchronously.
  Multiple independent instances of this plugin may be used simultaneously,
  but message integrity depends on the behavior of libadiak.
 */
class libadiak_json_plugin : public publisher_api {
    enum state {
        ok,
        err
    };
 
private:
    const std::string vers;
    const std::vector<std::string> tags;
    enum state state;
    bool paused;
 
public:
    libadiak_json_plugin() : vers("1.0.0") , tags({"none"}), state(ok), paused(false) {
        std::cout << "Constructing libadiak_json_plugin" << std::endl;
    }
 
        int publish(std::shared_ptr<builder_api> b) {
        if (paused)
            return 0;
        if (state != ok)
            return 1;
        auto jstr = b->serialize();
        adiak::value("adc_event", adiak::jsonstring(jstr));
        return 0;
    }
 
        int config(const std::map< std::string, std::string >& m) {
        return 0;
    }
 
        int config(const std::map< std::string, std::string >& m, std::string_view env_prefix) {
        return 0;
    }
 
    const std::map< const std::string, const std::string> & get_option_defaults() {
        return libadiak_json_defaults;
    }
 
        int initialize() {
        return 0;
    }
 
        void finalize() {
    }
 
    void pause() {
        paused = true;
    }
 
        void resume() {
        paused = false;
    }
 
    std::string_view name() const {
        return "libadiak_json";
    }
 
    std::string_view version() const {
        return vers;
    }
 
    ~libadiak_json_plugin() {
        std::cout << "Destructing libadiak_json_plugin" << std::endl;
    }
};
 
 
} // adc