Merge pull request #13 from thalesmg/iceberg-restart

feat: add iceberg-rest-fixture image

Author: thalesmg

.gitignore

@@ -0,0 +1,2 @@
+/.clj-kondo/
+/.lsp/

iceberg-rest-fixture/.gitignore

@@ -0,0 +1 @@
+/.cpcache/

iceberg-rest-fixture/Dockerfile

@@ -0,0 +1,19 @@
+FROM apache/iceberg-rest-fixture:1.9.0 AS base
+
+FROM clojure:temurin-17-tools-deps-1.12.0.1530-bookworm-slim
+
+COPY --from=base /usr/lib/iceberg-rest/iceberg-rest-adapter.jar /opt/server/iceberg-rest-adapter.jar
+
+RUN  set -xeu && \
+     apt-get update && \
+     apt-get install -y --no-install-recommends curl && \
+     rm -rf /var/lib/apt/lists/*
+
+WORKDIR /opt/server/
+
+COPY src /opt/server/src
+COPY deps.edn /opt/server/
+
+RUN clojure -P
+
+CMD ["clojure", "-M:run"]

iceberg-rest-fixture/deps.edn

@@ -0,0 +1,9 @@
+{:deps {http-kit/http-kit {:mvn/version "2.8.0"}
+        compojure/compojure {:mvn/version "1.7.1"}
+        ring/ring-devel {:mvn/version "1.14.1"}}
+ :aliases
+ {:run {:main-opts ["-m" "iceberg"]}
+  :fmt/check {:extra-deps {cljfmt/cljfmt {:mvn/version "0.9.2"}}
+              :main-opts ["--main" "cljfmt.main" "check"]}
+  :fmt/fix {:extra-deps {cljfmt/cljfmt {:mvn/version "0.9.2"}}
+            :main-opts ["--main" "cljfmt.main" "fix"]}}}

iceberg-rest-fixture/src/iceberg.clj

@@ -0,0 +1,59 @@
+(ns iceberg
+  (:require
+   [clojure.java.process :as proc]
+   [org.httpkit.client :as client]
+   [org.httpkit.server :as server]
+   [ring.middleware.reload :refer [wrap-reload]]
+   [compojure.core :refer [defroutes POST]]))
+
+(def PORT 8191)
+
+(defn start-server
+  []
+  (proc/start
+   {:out :inherit
+    :err :inherit}
+   "java" "-jar" "iceberg-rest-adapter.jar"))
+
+(defonce server (atom (start-server)))
+
+(defn server-healthy?
+  []
+  (-> (client/get "http://127.0.0.1:8181/v1/config")
+      deref
+      :status
+      (= 200)))
+
+(defn handle-restart
+  [_request]
+  (println "Terminating process...")
+  (.destroy @server)
+  (.waitFor @server)
+  (println "Starting new process...")
+  (reset! server (start-server))
+  (println "Waiting for server to be up...")
+  (while (not (server-healthy?)))
+  (println "New server up.")
+  {:status 204})
+
+(defroutes app-routes
+  (POST "/restart" request (handle-restart request)))
+
+(defn- block-forever
+  []
+  (while true
+    (Thread/sleep 60000)))
+
+(defn -main
+  [& _args]
+  (try
+    (println "starting server on port" PORT)
+    (server/run-server (wrap-reload #'app-routes) {:port PORT})
+    (println "started server on port" PORT)
+    (block-forever)
+    (catch Exception e
+      (println (.getMessage e))
+      (.printStackTrace e)
+      (System/exit 1))
+    (finally
+      (.destroy @server))))

iceberg-rest-fixture/vsn

@@ -0,0 +1 @@
+1.9.0.0

spark-query/Dockerfile-uberjar

@@ -1,3 +1,4 @@
+# -*- mode: dockerfile; -*-
 ARG BUILD_FROM=clojure:temurin-17-tools-deps-1.12.0.1530-bookworm-slim
 ARG RUN_FROM=eclipse-temurin:11-jdk-ubi9-minimal