message-queue/cpp/src: wip postgres metrics

refs #6

message-queue/cpp/src/instance.cpp

@@ -1,6 +1,8 @@
 #include "./instance.hpp"
 
-Instance::Instance() : prometheus(Prometheus(config)) {}
+Instance::Instance()
+: prometheus(Prometheus(config)), pg(Postgres(config))
+{}
 
 prometheus::Labels mk_labels(const Instance& app, const WorkerResult& wr, const SampleDesc& sdesc) {
   Labels labels = app.runtime.Map();

message-queue/cpp/src/instance.hpp

@@ -4,6 +4,7 @@
 #include <prometheus/labels.h>
 
 #include "./config.hpp"
+#include "./postgres.hpp"
 #include "./primitives.hpp"
 #include "./prometheus.hpp"
 #include "./runtime.hpp"
@@ -15,6 +16,7 @@ class Instance {
   Config config;
   Runtime runtime;
   Prometheus prometheus;
+  Postgres pg;
   Instance();
 };
 

message-queue/cpp/src/postgres.cpp

@@ -0,0 +1,5 @@
+#include "postgres.hpp"
+
+Postgres::Postgres(Config &c)
+: conn(connection("postgres://mq@localhost/mq")) {
+}

message-queue/cpp/src/postgres.hpp

@@ -0,0 +1,24 @@
+#ifndef POSTGRES_CPP
+#define POSTGRES_CPP
+
+#include <optional>
+
+#include <pqxx/pqxx>
+
+#include "config.hpp"
+#include "runtime.hpp"
+#include "primitives.hpp"
+
+using namespace std;
+using namespace pqxx;
+
+class Postgres {
+  connection conn;
+  optional<int> runtime_id = nullopt;
+
+public:
+  Postgres(Config&);
+  void Push(Runtime&, SampleDesc&, Results&);
+};
+
+#endif

message-queue/cpp/src/runtime.hpp

@@ -45,4 +45,5 @@ class Runtime {
     return ss.str();
   }
 };
+
 #endif