remove prometheus output wip code

appclacks · Apr 18, 2024 · 6c7c209 · 6c7c209
1 parent 409bb22
commit 6c7c209
Show file tree

Hide file tree

Showing 2 changed files with 30 additions and 60 deletions.
diff --git a/src/clojure/mirabelle/output/prometheus.clj b/src/clojure/mirabelle/output/prometheus.clj
diff --git a/src/clojure/mirabelle/prometheus.clj b/src/clojure/mirabelle/prometheus.clj
@@ -34,33 +34,33 @@
       events)))
 
 
-(defn events->write-request
-  "Converts list of events to a Prometheus remote write request"
-  [events labels]
-  (let [write-request (Remote$WriteRequest/newBuilder)
-        timeseries (atom {})]
-    (doseq [event events]
-      (let [labels (-> (select-keys event labels)
-                       (assoc "__name__" (:service event)))
-            ^prometheus.Types$TimeSeries$Builder timeserie
-            (get
-             @timeseries
-             labels
-             (let [timeserie (Types$TimeSeries/newBuilder)]
-               (doseq [[k v] labels]
-                 (.addLabels timeserie
-                             (doto (Types$Label/newBuilder)
-                               (.setName (name k))
-                               (.setValue (name v))
-                               (.build))))
-               (swap! timeseries assoc labels timeserie)
-               timeserie))]
-        (println @timeseries)
-        (.addSamples timeserie
-                     (doto (Types$Sample/newBuilder)
-                       (.setValue (:metric event 0))
-                       (.setTimestamp (int (* 1000 (:time event))))
-                       (.build)))))
-    (doseq [[_ ^prometheus.Types$TimeSeries$Builder timeserie] @timeseries]
-      (.addTimeseries write-request (.build timeserie)))
-    (.build write-request)))
+;; (defn events->write-request
+;;   "Converts list of events to a Prometheus remote write request"
+;;   [events labels]
+;;   (let [write-request (Remote$WriteRequest/newBuilder)
+;;         timeseries (atom {})]
+;;     (doseq [event events]
+;;       (let [labels (-> (select-keys event labels)
+;;                        (assoc "__name__" (:service event)))
+;;             ^prometheus.Types$TimeSeries$Builder timeserie
+;;             (get
+;;              @timeseries
+;;              labels
+;;              (let [timeserie (Types$TimeSeries/newBuilder)]
+;;                (doseq [[k v] labels]
+;;                  (.addLabels timeserie
+;;                              (doto (Types$Label/newBuilder)
+;;                                (.setName (name k))
+;;                                (.setValue (name v))
+;;                                (.build))))
+;;                (swap! timeseries assoc labels timeserie)
+;;                timeserie))]
+;;         (println @timeseries)
+;;         (.addSamples timeserie
+;;                      (doto (Types$Sample/newBuilder)
+;;                        (.setValue (:metric event 0))
+;;                        (.setTimestamp (int (* 1000 (:time event))))
+;;                        (.build)))))
+;;     (doseq [[_ ^prometheus.Types$TimeSeries$Builder timeserie] @timeseries]
+;;       (.addTimeseries write-request (.build timeserie)))
+;;     (.build write-request)))