libpinkas-clj

[updcon/libpinkas-clj "0.0.5"]

(ns my-app.jasper
  (:require [libpinkas-clj.core :refer :all]
            [clojure.core.async :refer [timeout <!!] :include-macros true]))

(defn- schema [id port]
  {:node    "My-Node-Name"
   :address "127.0.0.1"
   :service {
             :id                  id
             :name                id
             :service             "my-service"
             :address             "127.0.0.1"
             :tags                ["primary"]
             :enable_tag_override true
             :port                port}
   })

(def ^:private path "http://localhost:8500/v1/catalog/")

(def ^:private serv1 (service path (schema "my-service-1" 8888)))
(def ^:private one-sec 1000)

(defn run-my-service
  (let [status (register serv1)]

    (when status
      (<!! (timeout one-sec)))

    (assert (= (count (filter
                        #(= "my-service-1" (get % :ServiceID))
                        (discover serv1))) 1)))
  (deregister serv1)
  (<!! (timeout one-sec)))