mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-12-11 00:42:29 +00:00
40 lines
1.4 KiB
Clojure
40 lines
1.4 KiB
Clojure
(ns jepsen.keeper-test
|
|
(:require [clojure.test :refer :all]
|
|
[jepsen.clickhouse-keeper.utils :refer :all]
|
|
[zookeeper :as zk]
|
|
[zookeeper.data :as data])
|
|
(:import (ch.qos.logback.classic Level)
|
|
(org.slf4j Logger LoggerFactory)))
|
|
|
|
(defn multicreate
|
|
[conn]
|
|
(dorun (map (fn [v] (zk/create conn v :persistent? true)) (take 10 (zk-range)))))
|
|
|
|
(defn multidelete
|
|
[conn]
|
|
(dorun (map (fn [v] (zk/delete conn v)) (take 10 (zk-range)))))
|
|
|
|
(deftest a-test
|
|
(testing "keeper connection"
|
|
(.setLevel
|
|
(LoggerFactory/getLogger "org.apache.zookeeper") Level/OFF)
|
|
(let [conn (zk/connect "localhost:9181" :timeout-msec 5000)]
|
|
;(println (take 10 (zk-range)))
|
|
;(multidelete conn)
|
|
;(multicreate conn)
|
|
;(zk/create-all conn "/0")
|
|
;(zk/create conn "/0")
|
|
;(println (zk/children conn "/"))
|
|
;(zk/set-data conn "/0" (data/to-bytes "777") -1)
|
|
(println (zk-parent-path "/sasds/dasda/das"))
|
|
(println (zk-parent-path "/sasds"))
|
|
(zk-multi-create-many-seq-nodes conn "/a-" 5)
|
|
(println (zk/children conn "/"))
|
|
(println (zk-list-with-stat conn "/"))
|
|
(println (zk-multi-delete-first-child conn "/"))
|
|
(println (zk-list-with-stat conn "/"))
|
|
;(Thread/sleep 5000)
|
|
;(println "VALUE" (data/to-string (:data (zk/data conn "/0"))))
|
|
;(is (= (data/to-string (:data (zk/data conn "/0"))) "777"))
|
|
(zk/close conn))))
|