Browse code
(init)
Ed Langley authored on 02/05/2020 07:39:28Showing 12 changed files
- .gitignore
- generate-ji-definitions.lisp
- init.lisp
- jinterface/al.lisp
- jinterface/bebr.lisp
- jinterface/cf.lisp
- jinterface/cff.lisp
- jinterface/gcb.lisp
- jinterface/gdb.lisp
- lw-curator.asd
- main.lisp
- packages.lisp
| 0 | 3 |
new file mode 100644 |
| ... | ... |
@@ -0,0 +1,41 @@ |
| 1 |
+(defpackage :fwoar.lw-curator.generate-ji-definitions |
|
| 2 |
+ (:use :cl ) |
|
| 3 |
+ (:export )) |
|
| 4 |
+(in-package :fwoar.lw-curator.generate-ji-definitions) |
|
| 5 |
+ |
|
| 6 |
+(defun jinterface-dest (dest) |
|
| 7 |
+ (merge-pathnames (parse-namestring dest) |
|
| 8 |
+ (asdf:component-pathname |
|
| 9 |
+ (asdf:find-component :lw-curator "jinterface")))) |
|
| 10 |
+ |
|
| 11 |
+(defun write-class-def (java-class-name dest package) |
|
| 12 |
+ (lw-ji:write-java-class-definitions-to-file java-class-name |
|
| 13 |
+ (jinterface-dest dest) |
|
| 14 |
+ :prefix "" |
|
| 15 |
+ :lisp-name nil |
|
| 16 |
+ :create-defpackage t |
|
| 17 |
+ :package-name package |
|
| 18 |
+ :if-exists :overwrite)) |
|
| 19 |
+(defmacro write-class-defs (&body defs) |
|
| 20 |
+ `(progn |
|
| 21 |
+ ,@(mapcar (fw.lu:destructuring-lambda ((&key java-class dest package)) |
|
| 22 |
+ `(write-class-def ,java-class ,dest ,package)) |
|
| 23 |
+ defs))) |
|
| 24 |
+ |
|
| 25 |
+(defun run () |
|
| 26 |
+ (write-class-defs |
|
| 27 |
+ (:java-class "org.apache.curator.framework.CuratorFramework" |
|
| 28 |
+ :package :fwoar.lw-curator.ji.framework |
|
| 29 |
+ :dest "cf.lisp") |
|
| 30 |
+ |
|
| 31 |
+ (:java-class "org.apache.curator.framework.api.GetChildrenBuilder" |
|
| 32 |
+ :package :fwoar.lw-curator.ji.gcb |
|
| 33 |
+ :dest "gcb.lisp") |
|
| 34 |
+ |
|
| 35 |
+ (:java-class "org.apache.curator.framework.api.GetDataBuilder" |
|
| 36 |
+ :package :fwoar.lw-curator.ji.gdb |
|
| 37 |
+ :dest "gdb.lisp") |
|
| 38 |
+ |
|
| 39 |
+ (:java-class "java.util.ArrayList" |
|
| 40 |
+ :package :fwoar.lw-curator.ji.al |
|
| 41 |
+ :dest "al.lisp"))) |
| 0 | 42 |
new file mode 100644 |
| ... | ... |
@@ -0,0 +1,6 @@ |
| 1 |
+(in-package :fwoar.lw-curator) |
|
| 2 |
+(serapeum:eval-always |
|
| 3 |
+ (unless (lw-ji:get-java-virtual-machine) |
|
| 4 |
+ (lw-ji:init-java-interface |
|
| 5 |
+ :jvm-library-path "/Library/Java/JavaVirtualMachines/jdk-11.jdk/Contents/Home/lib/server/libjvm.dylib" |
|
| 6 |
+ :java-class-path (namestring (truename "~/curator-test/bundle.jar"))))) |
| 0 | 7 |
new file mode 100644 |
| ... | ... |
@@ -0,0 +1,276 @@ |
| 1 |
+;;; -*- Mode : lisp -*- |
|
| 2 |
+;;; This file was automatically generated by WRITE-JAVA-CLASS-DEFINITIONS-TO-FILE |
|
| 3 |
+ |
|
| 4 |
+ |
|
| 5 |
+;;; Definitions for Java class java.util.ArrayList |
|
| 6 |
+ |
|
| 7 |
+ |
|
| 8 |
+(defpackage "FWOAR.LW-CURATOR.JI.AL" |
|
| 9 |
+ (:export |
|
| 10 |
+ ".CONTAINS" |
|
| 11 |
+ ".RETAINALL" |
|
| 12 |
+ ".FOREACH" |
|
| 13 |
+ ".CLONE" |
|
| 14 |
+ ".ADD" |
|
| 15 |
+ ".GET" |
|
| 16 |
+ ".ITERATOR" |
|
| 17 |
+ ".REPLACEALL" |
|
| 18 |
+ ".TOSTRING" |
|
| 19 |
+ ".GETCLASS" |
|
| 20 |
+ ".EQUALS" |
|
| 21 |
+ ".CLEAR" |
|
| 22 |
+ ".ISEMPTY" |
|
| 23 |
+ ".SIZE" |
|
| 24 |
+ ".SUBLIST" |
|
| 25 |
+ ".NOTIFY" |
|
| 26 |
+ ".REMOVE" |
|
| 27 |
+ ".CONTAINSALL" |
|
| 28 |
+ ".LASTINDEXOF" |
|
| 29 |
+ ".PARALLELSTREAM" |
|
| 30 |
+ ".ADDALL" |
|
| 31 |
+ ".INDEXOF" |
|
| 32 |
+ ".STREAM" |
|
| 33 |
+ ".SPLITERATOR" |
|
| 34 |
+ ".TRIMTOSIZE" |
|
| 35 |
+ ".NOTIFYALL" |
|
| 36 |
+ ".HASHCODE" |
|
| 37 |
+ ".ENSURECAPACITY" |
|
| 38 |
+ ".REMOVEALL" |
|
| 39 |
+ ".TOARRAY" |
|
| 40 |
+ ".SET" |
|
| 41 |
+ ".REMOVEIF" |
|
| 42 |
+ ".WAIT" |
|
| 43 |
+ ".LISTITERATOR" |
|
| 44 |
+ ".SORT" |
|
| 45 |
+ ".NEW")) |
|
| 46 |
+ |
|
| 47 |
+(in-package "FWOAR.LW-CURATOR.JI.AL") |
|
| 48 |
+(lw-ji:define-java-constructor .new |
|
| 49 |
+ "java.util.ArrayList" |
|
| 50 |
+ :signatures |
|
| 51 |
+ ("java.util.ArrayList()"
|
|
| 52 |
+ "java.util.ArrayList(java.util.Collection)" |
|
| 53 |
+ "java.util.ArrayList(int)") |
|
| 54 |
+ :class-symbol |
|
| 55 |
+ nil) |
|
| 56 |
+(lw-ji:define-java-caller .contains |
|
| 57 |
+ "java/util/ArrayList" |
|
| 58 |
+ "contains" |
|
| 59 |
+ :signatures |
|
| 60 |
+ ("public boolean contains(java.lang.Object)"))
|
|
| 61 |
+(lw-ji:define-java-caller .retainall |
|
| 62 |
+ "java/util/ArrayList" |
|
| 63 |
+ "retainAll" |
|
| 64 |
+ :signatures |
|
| 65 |
+ ("public boolean retainAll(java.util.Collection)"))
|
|
| 66 |
+(lw-ji:define-java-caller .foreach |
|
| 67 |
+ "java/util/ArrayList" |
|
| 68 |
+ "forEach" |
|
| 69 |
+ :signatures |
|
| 70 |
+ ("public void forEach(java.util.function.Consumer)"))
|
|
| 71 |
+(lw-ji:define-java-caller .clone |
|
| 72 |
+ "java/util/ArrayList" |
|
| 73 |
+ "clone" |
|
| 74 |
+ :signatures |
|
| 75 |
+ ("public java.lang.Object clone()"))
|
|
| 76 |
+(lw-ji:define-java-caller .add |
|
| 77 |
+ "java/util/ArrayList" |
|
| 78 |
+ "add" |
|
| 79 |
+ :signatures |
|
| 80 |
+ ("public void add(int, java.lang.Object)"
|
|
| 81 |
+ "public boolean add(java.lang.Object)")) |
|
| 82 |
+(lw-ji:define-java-caller .get |
|
| 83 |
+ "java/util/ArrayList" |
|
| 84 |
+ "get" |
|
| 85 |
+ :signatures |
|
| 86 |
+ ("public java.lang.Object get(int)"))
|
|
| 87 |
+(lw-ji:define-java-caller .iterator |
|
| 88 |
+ "java/util/ArrayList" |
|
| 89 |
+ "iterator" |
|
| 90 |
+ :signatures |
|
| 91 |
+ ("public java.util.Iterator iterator()"))
|
|
| 92 |
+(lw-ji:define-java-caller .replaceall |
|
| 93 |
+ "java/util/ArrayList" |
|
| 94 |
+ "replaceAll" |
|
| 95 |
+ :signatures |
|
| 96 |
+ ("public void replaceAll(java.util.function.UnaryOperator)"))
|
|
| 97 |
+(lw-ji:define-java-caller .tostring |
|
| 98 |
+ "java/util/ArrayList" |
|
| 99 |
+ "toString" |
|
| 100 |
+ :signatures |
|
| 101 |
+ ("public java.lang.String toString()"))
|
|
| 102 |
+(lw-ji:define-java-caller .getclass |
|
| 103 |
+ "java/util/ArrayList" |
|
| 104 |
+ "getClass" |
|
| 105 |
+ :signatures |
|
| 106 |
+ ("public final java.lang.Class getClass()"))
|
|
| 107 |
+(lw-ji:define-java-caller .equals |
|
| 108 |
+ "java/util/ArrayList" |
|
| 109 |
+ "equals" |
|
| 110 |
+ :signatures |
|
| 111 |
+ ("public boolean equals(java.lang.Object)"))
|
|
| 112 |
+(lw-ji:define-java-caller .clear |
|
| 113 |
+ "java/util/ArrayList" |
|
| 114 |
+ "clear" |
|
| 115 |
+ :signatures |
|
| 116 |
+ ("public void clear()"))
|
|
| 117 |
+(lw-ji:define-java-caller .isempty |
|
| 118 |
+ "java/util/ArrayList" |
|
| 119 |
+ "isEmpty" |
|
| 120 |
+ :signatures |
|
| 121 |
+ ("public boolean isEmpty()"))
|
|
| 122 |
+(lw-ji:define-java-caller .size |
|
| 123 |
+ "java/util/ArrayList" |
|
| 124 |
+ "size" |
|
| 125 |
+ :signatures |
|
| 126 |
+ ("public int size()"))
|
|
| 127 |
+(lw-ji:define-java-caller .sublist |
|
| 128 |
+ "java/util/ArrayList" |
|
| 129 |
+ "subList" |
|
| 130 |
+ :signatures |
|
| 131 |
+ ("public java.util.List subList(int, int)"))
|
|
| 132 |
+(lw-ji:define-java-caller .notify |
|
| 133 |
+ "java/util/ArrayList" |
|
| 134 |
+ "notify" |
|
| 135 |
+ :signatures |
|
| 136 |
+ ("public final void notify()"))
|
|
| 137 |
+(lw-ji:define-java-caller .remove |
|
| 138 |
+ "java/util/ArrayList" |
|
| 139 |
+ "remove" |
|
| 140 |
+ :signatures |
|
| 141 |
+ ("public java.lang.Object remove(int)"
|
|
| 142 |
+ "public boolean remove(java.lang.Object)")) |
|
| 143 |
+(lw-ji:define-java-caller .containsall |
|
| 144 |
+ "java/util/ArrayList" |
|
| 145 |
+ "containsAll" |
|
| 146 |
+ :signatures |
|
| 147 |
+ ("public boolean containsAll(java.util.Collection)"))
|
|
| 148 |
+(lw-ji:define-java-caller .lastindexof |
|
| 149 |
+ "java/util/ArrayList" |
|
| 150 |
+ "lastIndexOf" |
|
| 151 |
+ :signatures |
|
| 152 |
+ ("public int lastIndexOf(java.lang.Object)"))
|
|
| 153 |
+(lw-ji:define-java-caller .parallelstream |
|
| 154 |
+ "java/util/ArrayList" |
|
| 155 |
+ "parallelStream" |
|
| 156 |
+ :signatures |
|
| 157 |
+ ("public java.util.stream.Stream parallelStream()"))
|
|
| 158 |
+(lw-ji:define-java-caller .addall |
|
| 159 |
+ "java/util/ArrayList" |
|
| 160 |
+ "addAll" |
|
| 161 |
+ :signatures |
|
| 162 |
+ ("public boolean addAll(int, java.util.Collection)"
|
|
| 163 |
+ "public boolean addAll(java.util.Collection)")) |
|
| 164 |
+(lw-ji:define-java-caller .indexof |
|
| 165 |
+ "java/util/ArrayList" |
|
| 166 |
+ "indexOf" |
|
| 167 |
+ :signatures |
|
| 168 |
+ ("public int indexOf(java.lang.Object)"))
|
|
| 169 |
+(lw-ji:define-java-caller .stream |
|
| 170 |
+ "java/util/ArrayList" |
|
| 171 |
+ "stream" |
|
| 172 |
+ :signatures |
|
| 173 |
+ ("public java.util.stream.Stream stream()"))
|
|
| 174 |
+(lw-ji:define-java-caller .spliterator |
|
| 175 |
+ "java/util/ArrayList" |
|
| 176 |
+ "spliterator" |
|
| 177 |
+ :signatures |
|
| 178 |
+ ("public java.util.Spliterator spliterator()"))
|
|
| 179 |
+(lw-ji:define-java-caller .trimtosize |
|
| 180 |
+ "java/util/ArrayList" |
|
| 181 |
+ "trimToSize" |
|
| 182 |
+ :signatures |
|
| 183 |
+ ("public void trimToSize()"))
|
|
| 184 |
+(lw-ji:define-java-caller .notifyall |
|
| 185 |
+ "java/util/ArrayList" |
|
| 186 |
+ "notifyAll" |
|
| 187 |
+ :signatures |
|
| 188 |
+ ("public final void notifyAll()"))
|
|
| 189 |
+(lw-ji:define-java-caller .hashcode |
|
| 190 |
+ "java/util/ArrayList" |
|
| 191 |
+ "hashCode" |
|
| 192 |
+ :signatures |
|
| 193 |
+ ("public int hashCode()"))
|
|
| 194 |
+(lw-ji:define-java-caller .ensurecapacity |
|
| 195 |
+ "java/util/ArrayList" |
|
| 196 |
+ "ensureCapacity" |
|
| 197 |
+ :signatures |
|
| 198 |
+ ("public void ensureCapacity(int)"))
|
|
| 199 |
+(lw-ji:define-java-caller .removeall |
|
| 200 |
+ "java/util/ArrayList" |
|
| 201 |
+ "removeAll" |
|
| 202 |
+ :signatures |
|
| 203 |
+ ("public boolean removeAll(java.util.Collection)"))
|
|
| 204 |
+(lw-ji:define-java-caller .toarray |
|
| 205 |
+ "java/util/ArrayList" |
|
| 206 |
+ "toArray" |
|
| 207 |
+ :signatures |
|
| 208 |
+ ("public java.lang.Object[] toArray(java.util.function.IntFunction)"
|
|
| 209 |
+ "public java.lang.Object[] toArray()" |
|
| 210 |
+ "public java.lang.Object[] toArray(java.lang.Object[])")) |
|
| 211 |
+(lw-ji:define-java-caller .set |
|
| 212 |
+ "java/util/ArrayList" |
|
| 213 |
+ "set" |
|
| 214 |
+ :signatures |
|
| 215 |
+ ("public java.lang.Object set(int, java.lang.Object)"))
|
|
| 216 |
+(lw-ji:define-java-caller .removeif |
|
| 217 |
+ "java/util/ArrayList" |
|
| 218 |
+ "removeIf" |
|
| 219 |
+ :signatures |
|
| 220 |
+ ("public boolean removeIf(java.util.function.Predicate)"))
|
|
| 221 |
+(lw-ji:define-java-caller .wait |
|
| 222 |
+ "java/util/ArrayList" |
|
| 223 |
+ "wait" |
|
| 224 |
+ :signatures |
|
| 225 |
+ ("public final void wait()"
|
|
| 226 |
+ "public final void wait(long, int)" |
|
| 227 |
+ "public final void wait(long)")) |
|
| 228 |
+(lw-ji:define-java-caller .listiterator |
|
| 229 |
+ "java/util/ArrayList" |
|
| 230 |
+ "listIterator" |
|
| 231 |
+ :signatures |
|
| 232 |
+ ("public java.util.ListIterator listIterator(int)"
|
|
| 233 |
+ "public java.util.ListIterator listIterator()")) |
|
| 234 |
+(lw-ji:define-java-caller .sort |
|
| 235 |
+ "java/util/ArrayList" |
|
| 236 |
+ "sort" |
|
| 237 |
+ :signatures |
|
| 238 |
+ ("public void sort(java.util.Comparator)"))
|
|
| 239 |
+ |
|
| 240 |
+;;; End of class java.util.ArrayList |
|
| 241 |
+ |
|
| 242 |
+ures |
|
| 243 |
+ ("public java.lang.Object[] toArray(java.util.function.IntFunction)"
|
|
| 244 |
+ "public java.lang.Object[] toArray()" |
|
| 245 |
+ "public java.lang.Object[] toArray(java.lang.Object[])")) |
|
| 246 |
+(lw-ji:define-java-caller arraylist.set |
|
| 247 |
+ "java/util/ArrayList" |
|
| 248 |
+ "set" |
|
| 249 |
+ :signatures |
|
| 250 |
+ ("public java.lang.Object set(int, java.lang.Object)"))
|
|
| 251 |
+(lw-ji:define-java-caller arraylist.removeif |
|
| 252 |
+ "java/util/ArrayList" |
|
| 253 |
+ "removeIf" |
|
| 254 |
+ :signatures |
|
| 255 |
+ ("public boolean removeIf(java.util.function.Predicate)"))
|
|
| 256 |
+(lw-ji:define-java-caller arraylist.wait |
|
| 257 |
+ "java/util/ArrayList" |
|
| 258 |
+ "wait" |
|
| 259 |
+ :signatures |
|
| 260 |
+ ("public final void wait()"
|
|
| 261 |
+ "public final void wait(long, int)" |
|
| 262 |
+ "public final void wait(long)")) |
|
| 263 |
+(lw-ji:define-java-caller arraylist.listiterator |
|
| 264 |
+ "java/util/ArrayList" |
|
| 265 |
+ "listIterator" |
|
| 266 |
+ :signatures |
|
| 267 |
+ ("public java.util.ListIterator listIterator(int)"
|
|
| 268 |
+ "public java.util.ListIterator listIterator()")) |
|
| 269 |
+(lw-ji:define-java-caller arraylist.sort |
|
| 270 |
+ "java/util/ArrayList" |
|
| 271 |
+ "sort" |
|
| 272 |
+ :signatures |
|
| 273 |
+ ("public void sort(java.util.Comparator)"))
|
|
| 274 |
+ |
|
| 275 |
+;;; End of class java.util.ArrayList |
|
| 276 |
+ |
| 0 | 277 |
new file mode 100644 |
| ... | ... |
@@ -0,0 +1,95 @@ |
| 1 |
+;;; -*- Mode : lisp -*- |
|
| 2 |
+;;; This file was automatically generated by WRITE-JAVA-CLASS-DEFINITIONS-TO-FILE |
|
| 3 |
+ |
|
| 4 |
+ |
|
| 5 |
+;;; Definitions for Java class org.apache.curator.retry.BoundedExponentialBackoffRetry |
|
| 6 |
+ |
|
| 7 |
+ |
|
| 8 |
+(eval-when (compile load eval) |
|
| 9 |
+ (let ((package-name "org.apache.curator.retry")) |
|
| 10 |
+ (unless (find-package package-name) (make-package package-name))) |
|
| 11 |
+ (lw-ji:intern-and-export-list '("BOUNDEDEXPONENTIALBACKOFFRETRY.GETN"
|
|
| 12 |
+ "BOUNDEDEXPONENTIALBACKOFFRETRY.TOSTRING" |
|
| 13 |
+ "BOUNDEDEXPONENTIALBACKOFFRETRY.GETCLASS" |
|
| 14 |
+ "BOUNDEDEXPONENTIALBACKOFFRETRY.EQUALS" |
|
| 15 |
+ "BOUNDEDEXPONENTIALBACKOFFRETRY.NOTIFY" |
|
| 16 |
+ "BOUNDEDEXPONENTIALBACKOFFRETRY.GETBASESLEEPTIMEMS" |
|
| 17 |
+ "BOUNDEDEXPONENTIALBACKOFFRETRY.ALLOWRETRY" |
|
| 18 |
+ "BOUNDEDEXPONENTIALBACKOFFRETRY.GETMAXSLEEPTIMEMS" |
|
| 19 |
+ "BOUNDEDEXPONENTIALBACKOFFRETRY.NOTIFYALL" |
|
| 20 |
+ "BOUNDEDEXPONENTIALBACKOFFRETRY.HASHCODE" |
|
| 21 |
+ "BOUNDEDEXPONENTIALBACKOFFRETRY.WAIT" |
|
| 22 |
+ "BOUNDEDEXPONENTIALBACKOFFRETRY.NEW" |
|
| 23 |
+ "BOUNDEDEXPONENTIALBACKOFFRETRY.") |
|
| 24 |
+ "org.apache.curator.retry")) |
|
| 25 |
+ |
|
| 26 |
+(in-package "org.apache.curator.retry") |
|
| 27 |
+(defconstant boundedexponentialbackoffretry. "org.apache.curator.retry.BoundedExponentialBackoffRetry") |
|
| 28 |
+(lw-ji:record-java-class-lisp-symbol "org.apache.curator.retry.BoundedExponentialBackoffRetry" |
|
| 29 |
+ 'boundedexponentialbackoffretry.) |
|
| 30 |
+(lw-ji:define-java-constructor boundedexponentialbackoffretry.new |
|
| 31 |
+ "org.apache.curator.retry.BoundedExponentialBackoffRetry" |
|
| 32 |
+ :signatures |
|
| 33 |
+ ("org.apache.curator.retry.BoundedExponentialBackoffRetry(int,int,int)")
|
|
| 34 |
+ :class-symbol |
|
| 35 |
+ nil) |
|
| 36 |
+(lw-ji:define-java-caller boundedexponentialbackoffretry.getn |
|
| 37 |
+ "org/apache/curator/retry/BoundedExponentialBackoffRetry" |
|
| 38 |
+ "getN" |
|
| 39 |
+ :signatures |
|
| 40 |
+ ("public int getN()"))
|
|
| 41 |
+(lw-ji:define-java-caller boundedexponentialbackoffretry.tostring |
|
| 42 |
+ "org/apache/curator/retry/BoundedExponentialBackoffRetry" |
|
| 43 |
+ "toString" |
|
| 44 |
+ :signatures |
|
| 45 |
+ ("public java.lang.String toString()"))
|
|
| 46 |
+(lw-ji:define-java-caller boundedexponentialbackoffretry.getclass |
|
| 47 |
+ "org/apache/curator/retry/BoundedExponentialBackoffRetry" |
|
| 48 |
+ "getClass" |
|
| 49 |
+ :signatures |
|
| 50 |
+ ("public final java.lang.Class getClass()"))
|
|
| 51 |
+(lw-ji:define-java-caller boundedexponentialbackoffretry.equals |
|
| 52 |
+ "org/apache/curator/retry/BoundedExponentialBackoffRetry" |
|
| 53 |
+ "equals" |
|
| 54 |
+ :signatures |
|
| 55 |
+ ("public boolean equals(java.lang.Object)"))
|
|
| 56 |
+(lw-ji:define-java-caller boundedexponentialbackoffretry.notify |
|
| 57 |
+ "org/apache/curator/retry/BoundedExponentialBackoffRetry" |
|
| 58 |
+ "notify" |
|
| 59 |
+ :signatures |
|
| 60 |
+ ("public final void notify()"))
|
|
| 61 |
+(lw-ji:define-java-caller boundedexponentialbackoffretry.getbasesleeptimems |
|
| 62 |
+ "org/apache/curator/retry/BoundedExponentialBackoffRetry" |
|
| 63 |
+ "getBaseSleepTimeMs" |
|
| 64 |
+ :signatures |
|
| 65 |
+ ("public int getBaseSleepTimeMs()"))
|
|
| 66 |
+(lw-ji:define-java-caller boundedexponentialbackoffretry.allowretry |
|
| 67 |
+ "org/apache/curator/retry/BoundedExponentialBackoffRetry" |
|
| 68 |
+ "allowRetry" |
|
| 69 |
+ :signatures |
|
| 70 |
+ ("public boolean allowRetry(int, long, org.apache.curator.RetrySleeper)"))
|
|
| 71 |
+(lw-ji:define-java-caller boundedexponentialbackoffretry.getmaxsleeptimems |
|
| 72 |
+ "org/apache/curator/retry/BoundedExponentialBackoffRetry" |
|
| 73 |
+ "getMaxSleepTimeMs" |
|
| 74 |
+ :signatures |
|
| 75 |
+ ("public int getMaxSleepTimeMs()"))
|
|
| 76 |
+(lw-ji:define-java-caller boundedexponentialbackoffretry.notifyall |
|
| 77 |
+ "org/apache/curator/retry/BoundedExponentialBackoffRetry" |
|
| 78 |
+ "notifyAll" |
|
| 79 |
+ :signatures |
|
| 80 |
+ ("public final void notifyAll()"))
|
|
| 81 |
+(lw-ji:define-java-caller boundedexponentialbackoffretry.hashcode |
|
| 82 |
+ "org/apache/curator/retry/BoundedExponentialBackoffRetry" |
|
| 83 |
+ "hashCode" |
|
| 84 |
+ :signatures |
|
| 85 |
+ ("public int hashCode()"))
|
|
| 86 |
+(lw-ji:define-java-caller boundedexponentialbackoffretry.wait |
|
| 87 |
+ "org/apache/curator/retry/BoundedExponentialBackoffRetry" |
|
| 88 |
+ "wait" |
|
| 89 |
+ :signatures |
|
| 90 |
+ ("public final void wait()"
|
|
| 91 |
+ "public final void wait(long, int)" |
|
| 92 |
+ "public final void wait(long)")) |
|
| 93 |
+ |
|
| 94 |
+;;; End of class org.apache.curator.retry.BoundedExponentialBackoffRetry |
|
| 95 |
+ |
| 0 | 96 |
new file mode 100644 |
| ... | ... |
@@ -0,0 +1,281 @@ |
| 1 |
+;;; -*- Mode : lisp -*- |
|
| 2 |
+;;; This file was automatically generated by WRITE-JAVA-CLASS-DEFINITIONS-TO-FILE |
|
| 3 |
+ |
|
| 4 |
+ |
|
| 5 |
+;;; Definitions for Java class org.apache.curator.framework.CuratorFramework |
|
| 6 |
+ |
|
| 7 |
+ |
|
| 8 |
+(defpackage "FWOAR.LW-CURATOR.JI.FRAMEWORK" |
|
| 9 |
+ (:export |
|
| 10 |
+ ".CREATECONTAINERS" |
|
| 11 |
+ ".GETCURRENTCONFIG" |
|
| 12 |
+ ".GETACL" |
|
| 13 |
+ ".BLOCKUNTILCONNECTED" |
|
| 14 |
+ ".RECONFIG" |
|
| 15 |
+ ".SETACL" |
|
| 16 |
+ ".POSTSAFENOTIFY" |
|
| 17 |
+ ".DELETE" |
|
| 18 |
+ ".RUNSAFE" |
|
| 19 |
+ ".GETCHILDREN" |
|
| 20 |
+ ".INTRANSACTION" |
|
| 21 |
+ ".CLEARWATCHERREFERENCES" |
|
| 22 |
+ ".CLOSE" |
|
| 23 |
+ ".CREATE" |
|
| 24 |
+ ".WATCHES" |
|
| 25 |
+ ".USINGNAMESPACE" |
|
| 26 |
+ ".TRANSACTIONOP" |
|
| 27 |
+ ".GETCONNECTIONSTATELISTENABLE" |
|
| 28 |
+ ".GETCURATORLISTENABLE" |
|
| 29 |
+ ".GETSTATE" |
|
| 30 |
+ ".GETSCHEMASET" |
|
| 31 |
+ ".NEWNAMESPACEAWAREENSUREPATH" |
|
| 32 |
+ ".SYNC" |
|
| 33 |
+ ".GETCONFIG" |
|
| 34 |
+ ".GETZOOKEEPERCLIENT" |
|
| 35 |
+ ".GETUNHANDLEDERRORLISTENABLE" |
|
| 36 |
+ ".NONNAMESPACEVIEW" |
|
| 37 |
+ ".GETDATA" |
|
| 38 |
+ ".GETNAMESPACE" |
|
| 39 |
+ ".SETDATA" |
|
| 40 |
+ ".GETCONNECTIONSTATEERRORPOLICY" |
|
| 41 |
+ ".CHECKEXISTS" |
|
| 42 |
+ ".ISZK34COMPATIBILITYMODE" |
|
| 43 |
+ ".START" |
|
| 44 |
+ ".ISSTARTED" |
|
| 45 |
+ ".TRANSACTION" |
|
| 46 |
+ ".NEWWATCHERREMOVECURATORFRAMEWORK")) |
|
| 47 |
+ |
|
| 48 |
+(in-package "FWOAR.LW-CURATOR.JI.FRAMEWORK") |
|
| 49 |
+(lw-ji:define-java-caller .createcontainers |
|
| 50 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 51 |
+ "createContainers" |
|
| 52 |
+ :signatures |
|
| 53 |
+ ("public abstract void createContainers(java.lang.String)"))
|
|
| 54 |
+(lw-ji:define-java-caller .getcurrentconfig |
|
| 55 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 56 |
+ "getCurrentConfig" |
|
| 57 |
+ :signatures |
|
| 58 |
+ ("public abstract org.apache.zookeeper.server.quorum.flexible.QuorumVerifier getCurrentConfig()"))
|
|
| 59 |
+(lw-ji:define-java-caller .getacl |
|
| 60 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 61 |
+ "getACL" |
|
| 62 |
+ :signatures |
|
| 63 |
+ ("public abstract org.apache.curator.framework.api.GetACLBuilder getACL()"))
|
|
| 64 |
+(lw-ji:define-java-caller .blockuntilconnected |
|
| 65 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 66 |
+ "blockUntilConnected" |
|
| 67 |
+ :signatures |
|
| 68 |
+ ("public abstract void blockUntilConnected()"
|
|
| 69 |
+ "public abstract boolean blockUntilConnected(int, java.util.concurrent.TimeUnit)")) |
|
| 70 |
+(lw-ji:define-java-caller .reconfig |
|
| 71 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 72 |
+ "reconfig" |
|
| 73 |
+ :signatures |
|
| 74 |
+ ("public abstract org.apache.curator.framework.api.ReconfigBuilder reconfig()"))
|
|
| 75 |
+(lw-ji:define-java-caller .setacl |
|
| 76 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 77 |
+ "setACL" |
|
| 78 |
+ :signatures |
|
| 79 |
+ ("public abstract org.apache.curator.framework.api.SetACLBuilder setACL()"))
|
|
| 80 |
+(lw-ji:define-java-caller .postsafenotify |
|
| 81 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 82 |
+ "postSafeNotify" |
|
| 83 |
+ :signatures |
|
| 84 |
+ ("public java.util.concurrent.CompletableFuture postSafeNotify(java.lang.Object)"))
|
|
| 85 |
+(lw-ji:define-java-caller .delete |
|
| 86 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 87 |
+ "delete" |
|
| 88 |
+ :signatures |
|
| 89 |
+ ("public abstract org.apache.curator.framework.api.DeleteBuilder delete()"))
|
|
| 90 |
+(lw-ji:define-java-caller .runsafe |
|
| 91 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 92 |
+ "runSafe" |
|
| 93 |
+ :signatures |
|
| 94 |
+ ("public abstract java.util.concurrent.CompletableFuture runSafe(java.lang.Runnable)"))
|
|
| 95 |
+(lw-ji:define-java-caller .getchildren |
|
| 96 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 97 |
+ "getChildren" |
|
| 98 |
+ :signatures |
|
| 99 |
+ ("public abstract org.apache.curator.framework.api.GetChildrenBuilder getChildren()"))
|
|
| 100 |
+(lw-ji:define-java-caller .intransaction |
|
| 101 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 102 |
+ "inTransaction" |
|
| 103 |
+ :signatures |
|
| 104 |
+ ("public abstract org.apache.curator.framework.api.transaction.CuratorTransaction inTransaction()"))
|
|
| 105 |
+(lw-ji:define-java-caller .clearwatcherreferences |
|
| 106 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 107 |
+ "clearWatcherReferences" |
|
| 108 |
+ :signatures |
|
| 109 |
+ ("public abstract void clearWatcherReferences(org.apache.zookeeper.Watcher)"))
|
|
| 110 |
+(lw-ji:define-java-caller .close |
|
| 111 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 112 |
+ "close" |
|
| 113 |
+ :signatures |
|
| 114 |
+ ("public abstract void close()"))
|
|
| 115 |
+(lw-ji:define-java-caller .create |
|
| 116 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 117 |
+ "create" |
|
| 118 |
+ :signatures |
|
| 119 |
+ ("public abstract org.apache.curator.framework.api.CreateBuilder create()"))
|
|
| 120 |
+(lw-ji:define-java-caller .watches |
|
| 121 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 122 |
+ "watches" |
|
| 123 |
+ :signatures |
|
| 124 |
+ ("public abstract org.apache.curator.framework.api.RemoveWatchesBuilder watches()"))
|
|
| 125 |
+(lw-ji:define-java-caller .usingnamespace |
|
| 126 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 127 |
+ "usingNamespace" |
|
| 128 |
+ :signatures |
|
| 129 |
+ ("public abstract org.apache.curator.framework.CuratorFramework usingNamespace(java.lang.String)"))
|
|
| 130 |
+(lw-ji:define-java-caller .transactionop |
|
| 131 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 132 |
+ "transactionOp" |
|
| 133 |
+ :signatures |
|
| 134 |
+ ("public abstract org.apache.curator.framework.api.transaction.TransactionOp transactionOp()"))
|
|
| 135 |
+(lw-ji:define-java-caller .getconnectionstatelistenable |
|
| 136 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 137 |
+ "getConnectionStateListenable" |
|
| 138 |
+ :signatures |
|
| 139 |
+ ("public abstract org.apache.curator.framework.listen.Listenable getConnectionStateListenable()"))
|
|
| 140 |
+(lw-ji:define-java-caller .getcuratorlistenable |
|
| 141 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 142 |
+ "getCuratorListenable" |
|
| 143 |
+ :signatures |
|
| 144 |
+ ("public abstract org.apache.curator.framework.listen.Listenable getCuratorListenable()"))
|
|
| 145 |
+(lw-ji:define-java-caller .getstate |
|
| 146 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 147 |
+ "getState" |
|
| 148 |
+ :signatures |
|
| 149 |
+ ("public abstract org.apache.curator.framework.imps.CuratorFrameworkState getState()"))
|
|
| 150 |
+(lw-ji:define-java-caller .getschemaset |
|
| 151 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 152 |
+ "getSchemaSet" |
|
| 153 |
+ :signatures |
|
| 154 |
+ ("public abstract org.apache.curator.framework.schema.SchemaSet getSchemaSet()"))
|
|
| 155 |
+(lw-ji:define-java-caller .newnamespaceawareensurepath |
|
| 156 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 157 |
+ "newNamespaceAwareEnsurePath" |
|
| 158 |
+ :signatures |
|
| 159 |
+ ("public abstract org.apache.curator.utils.EnsurePath newNamespaceAwareEnsurePath(java.lang.String)"))
|
|
| 160 |
+(lw-ji:define-java-caller .sync |
|
| 161 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 162 |
+ "sync" |
|
| 163 |
+ :signatures |
|
| 164 |
+ ("public abstract void sync(java.lang.String, java.lang.Object)"
|
|
| 165 |
+ "public abstract org.apache.curator.framework.api.SyncBuilder sync()")) |
|
| 166 |
+(lw-ji:define-java-caller .getconfig |
|
| 167 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 168 |
+ "getConfig" |
|
| 169 |
+ :signatures |
|
| 170 |
+ ("public abstract org.apache.curator.framework.api.GetConfigBuilder getConfig()"))
|
|
| 171 |
+(lw-ji:define-java-caller .getzookeeperclient |
|
| 172 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 173 |
+ "getZookeeperClient" |
|
| 174 |
+ :signatures |
|
| 175 |
+ ("public abstract org.apache.curator.CuratorZookeeperClient getZookeeperClient()"))
|
|
| 176 |
+(lw-ji:define-java-caller .getunhandlederrorlistenable |
|
| 177 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 178 |
+ "getUnhandledErrorListenable" |
|
| 179 |
+ :signatures |
|
| 180 |
+ ("public abstract org.apache.curator.framework.listen.Listenable getUnhandledErrorListenable()"))
|
|
| 181 |
+(lw-ji:define-java-caller .nonnamespaceview |
|
| 182 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 183 |
+ "nonNamespaceView" |
|
| 184 |
+ :signatures |
|
| 185 |
+ ("public abstract org.apache.curator.framework.CuratorFramework nonNamespaceView()"))
|
|
| 186 |
+(lw-ji:define-java-caller .getdata |
|
| 187 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 188 |
+ "getData" |
|
| 189 |
+ :signatures |
|
| 190 |
+ ("public abstract org.apache.curator.framework.api.GetDataBuilder getData()"))
|
|
| 191 |
+(lw-ji:define-java-caller .getnamespace |
|
| 192 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 193 |
+ "getNamespace" |
|
| 194 |
+ :signatures |
|
| 195 |
+ ("public abstract java.lang.String getNamespace()"))
|
|
| 196 |
+(lw-ji:define-java-caller .setdata |
|
| 197 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 198 |
+ "setData" |
|
| 199 |
+ :signatures |
|
| 200 |
+ ("public abstract org.apache.curator.framework.api.SetDataBuilder setData()"))
|
|
| 201 |
+(lw-ji:define-java-caller .getconnectionstateerrorpolicy |
|
| 202 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 203 |
+ "getConnectionStateErrorPolicy" |
|
| 204 |
+ :signatures |
|
| 205 |
+ ("public abstract org.apache.curator.framework.state.ConnectionStateErrorPolicy getConnectionStateErrorPolicy()"))
|
|
| 206 |
+(lw-ji:define-java-caller .checkexists |
|
| 207 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 208 |
+ "checkExists" |
|
| 209 |
+ :signatures |
|
| 210 |
+ ("public abstract org.apache.curator.framework.api.ExistsBuilder checkExists()"))
|
|
| 211 |
+(lw-ji:define-java-caller .iszk34compatibilitymode |
|
| 212 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 213 |
+ "isZk34CompatibilityMode" |
|
| 214 |
+ :signatures |
|
| 215 |
+ ("public abstract boolean isZk34CompatibilityMode()"))
|
|
| 216 |
+(lw-ji:define-java-caller .start |
|
| 217 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 218 |
+ "start" |
|
| 219 |
+ :signatures |
|
| 220 |
+ ("public abstract void start()"))
|
|
| 221 |
+(lw-ji:define-java-caller .isstarted |
|
| 222 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 223 |
+ "isStarted" |
|
| 224 |
+ :signatures |
|
| 225 |
+ ("public abstract boolean isStarted()"))
|
|
| 226 |
+(lw-ji:define-java-caller .transaction |
|
| 227 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 228 |
+ "transaction" |
|
| 229 |
+ :signatures |
|
| 230 |
+ ("public abstract org.apache.curator.framework.api.transaction.CuratorMultiTransaction transaction()"))
|
|
| 231 |
+(lw-ji:define-java-caller .newwatcherremovecuratorframework |
|
| 232 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 233 |
+ "newWatcherRemoveCuratorFramework" |
|
| 234 |
+ :signatures |
|
| 235 |
+ ("public abstract org.apache.curator.framework.WatcherRemoveCuratorFramework newWatcherRemoveCuratorFramework()"))
|
|
| 236 |
+ |
|
| 237 |
+;;; End of class org.apache.curator.framework.CuratorFramework |
|
| 238 |
+ |
|
| 239 |
+ "start" |
|
| 240 |
+ :signatures |
|
| 241 |
+ ("public abstract void start()"))
|
|
| 242 |
+(lw-ji:define-java-caller curatorframework.isstarted |
|
| 243 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 244 |
+ "isStarted" |
|
| 245 |
+ :signatures |
|
| 246 |
+ ("public abstract boolean isStarted()"))
|
|
| 247 |
+(lw-ji:define-java-caller curatorframework.newwatcherremovecuratorframework |
|
| 248 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 249 |
+ "newWatcherRemoveCuratorFramework" |
|
| 250 |
+ :signatures |
|
| 251 |
+ ("public abstract org.apache.curator.framework.WatcherRemoveCuratorFramework newWatcherRemoveCuratorFramework()"))
|
|
| 252 |
+(lw-ji:define-java-caller curatorframework.transaction |
|
| 253 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 254 |
+ "transaction" |
|
| 255 |
+ :signatures |
|
| 256 |
+ ("public abstract org.apache.curator.framework.api.transaction.CuratorMultiTransaction transaction()"))
|
|
| 257 |
+ |
|
| 258 |
+;;; End of class org.apache.curator.framework.CuratorFramework |
|
| 259 |
+ |
|
| 260 |
+ "isStarted" |
|
| 261 |
+ :signatures |
|
| 262 |
+ ("public abstract boolean isStarted()"))
|
|
| 263 |
+(lw-ji:define-java-caller curatorframework.newwatcherremovecuratorframework |
|
| 264 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 265 |
+ "newWatcherRemoveCuratorFramework" |
|
| 266 |
+ :signatures |
|
| 267 |
+ ("public abstract org.apache.curator.framework.WatcherRemoveCuratorFramework newWatcherRemoveCuratorFramework()"))
|
|
| 268 |
+(lw-ji:define-java-caller curatorframework.transaction |
|
| 269 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 270 |
+ "transaction" |
|
| 271 |
+ :signatures |
|
| 272 |
+ ("public abstract org.apache.curator.framework.api.transaction.CuratorMultiTransaction transaction()"))
|
|
| 273 |
+ |
|
| 274 |
+;;; End of class org.apache.curator.framework.CuratorFramework |
|
| 275 |
+ |
|
| 276 |
+ "transaction" |
|
| 277 |
+ :signatures |
|
| 278 |
+ ("public abstract org.apache.curator.framework.api.transaction.CuratorMultiTransaction transaction()"))
|
|
| 279 |
+ |
|
| 280 |
+;;; End of class org.apache.curator.framework.CuratorFramework |
|
| 281 |
+ |
| 0 | 282 |
new file mode 100644 |
| ... | ... |
@@ -0,0 +1,83 @@ |
| 1 |
+;;; -*- Mode : lisp -*- |
|
| 2 |
+;;; This file was automatically generated by WRITE-JAVA-CLASS-DEFINITIONS-TO-FILE |
|
| 3 |
+ |
|
| 4 |
+ |
|
| 5 |
+;;; Definitions for Java class org.apache.curator.framework.CuratorFrameworkFactory |
|
| 6 |
+ |
|
| 7 |
+ |
|
| 8 |
+(eval-when (compile load eval) |
|
| 9 |
+ (let ((package-name "org.apache.curator.framework")) |
|
| 10 |
+ (unless (find-package package-name) (make-package package-name))) |
|
| 11 |
+ (lw-ji:intern-and-export-list '("CURATORFRAMEWORKFACTORY.GETLOCALADDRESS"
|
|
| 12 |
+ "CURATORFRAMEWORKFACTORY.TOSTRING" |
|
| 13 |
+ "CURATORFRAMEWORKFACTORY.GETCLASS" |
|
| 14 |
+ "CURATORFRAMEWORKFACTORY.EQUALS" |
|
| 15 |
+ "CURATORFRAMEWORKFACTORY.NOTIFY" |
|
| 16 |
+ "CURATORFRAMEWORKFACTORY.NEWCLIENT" |
|
| 17 |
+ "CURATORFRAMEWORKFACTORY.NOTIFYALL" |
|
| 18 |
+ "CURATORFRAMEWORKFACTORY.HASHCODE" |
|
| 19 |
+ "CURATORFRAMEWORKFACTORY.BUILDER" |
|
| 20 |
+ "CURATORFRAMEWORKFACTORY.WAIT" |
|
| 21 |
+ "CURATORFRAMEWORKFACTORY.") |
|
| 22 |
+ "org.apache.curator.framework")) |
|
| 23 |
+ |
|
| 24 |
+(in-package "org.apache.curator.framework") |
|
| 25 |
+(defconstant curatorframeworkfactory. "org.apache.curator.framework.CuratorFrameworkFactory") |
|
| 26 |
+(lw-ji:record-java-class-lisp-symbol "org.apache.curator.framework.CuratorFrameworkFactory" |
|
| 27 |
+ 'curatorframeworkfactory.) |
|
| 28 |
+(lw-ji:define-java-caller curatorframeworkfactory.getlocaladdress |
|
| 29 |
+ "org/apache/curator/framework/CuratorFrameworkFactory" |
|
| 30 |
+ "getLocalAddress" |
|
| 31 |
+ :signatures |
|
| 32 |
+ ("public static byte[] getLocalAddress()"))
|
|
| 33 |
+(lw-ji:define-java-caller curatorframeworkfactory.tostring |
|
| 34 |
+ "org/apache/curator/framework/CuratorFrameworkFactory" |
|
| 35 |
+ "toString" |
|
| 36 |
+ :signatures |
|
| 37 |
+ ("public java.lang.String toString()"))
|
|
| 38 |
+(lw-ji:define-java-caller curatorframeworkfactory.getclass |
|
| 39 |
+ "org/apache/curator/framework/CuratorFrameworkFactory" |
|
| 40 |
+ "getClass" |
|
| 41 |
+ :signatures |
|
| 42 |
+ ("public final java.lang.Class getClass()"))
|
|
| 43 |
+(lw-ji:define-java-caller curatorframeworkfactory.equals |
|
| 44 |
+ "org/apache/curator/framework/CuratorFrameworkFactory" |
|
| 45 |
+ "equals" |
|
| 46 |
+ :signatures |
|
| 47 |
+ ("public boolean equals(java.lang.Object)"))
|
|
| 48 |
+(lw-ji:define-java-caller curatorframeworkfactory.notify |
|
| 49 |
+ "org/apache/curator/framework/CuratorFrameworkFactory" |
|
| 50 |
+ "notify" |
|
| 51 |
+ :signatures |
|
| 52 |
+ ("public final void notify()"))
|
|
| 53 |
+(lw-ji:define-java-caller curatorframeworkfactory.newclient |
|
| 54 |
+ "org/apache/curator/framework/CuratorFrameworkFactory" |
|
| 55 |
+ "newClient" |
|
| 56 |
+ :signatures |
|
| 57 |
+ ("public static org.apache.curator.framework.CuratorFramework newClient(java.lang.String, org.apache.curator.RetryPolicy)"
|
|
| 58 |
+ "public static org.apache.curator.framework.CuratorFramework newClient(java.lang.String, int, int, org.apache.curator.RetryPolicy)")) |
|
| 59 |
+(lw-ji:define-java-caller curatorframeworkfactory.notifyall |
|
| 60 |
+ "org/apache/curator/framework/CuratorFrameworkFactory" |
|
| 61 |
+ "notifyAll" |
|
| 62 |
+ :signatures |
|
| 63 |
+ ("public final void notifyAll()"))
|
|
| 64 |
+(lw-ji:define-java-caller curatorframeworkfactory.hashcode |
|
| 65 |
+ "org/apache/curator/framework/CuratorFrameworkFactory" |
|
| 66 |
+ "hashCode" |
|
| 67 |
+ :signatures |
|
| 68 |
+ ("public int hashCode()"))
|
|
| 69 |
+(lw-ji:define-java-caller curatorframeworkfactory.builder |
|
| 70 |
+ "org/apache/curator/framework/CuratorFrameworkFactory" |
|
| 71 |
+ "builder" |
|
| 72 |
+ :signatures |
|
| 73 |
+ ("public static org.apache.curator.framework.CuratorFrameworkFactory$Builder builder()"))
|
|
| 74 |
+(lw-ji:define-java-caller curatorframeworkfactory.wait |
|
| 75 |
+ "org/apache/curator/framework/CuratorFrameworkFactory" |
|
| 76 |
+ "wait" |
|
| 77 |
+ :signatures |
|
| 78 |
+ ("public final void wait()"
|
|
| 79 |
+ "public final void wait(long, int)" |
|
| 80 |
+ "public final void wait(long)")) |
|
| 81 |
+ |
|
| 82 |
+;;; End of class org.apache.curator.framework.CuratorFrameworkFactory |
|
| 83 |
+ |
| 0 | 84 |
new file mode 100644 |
| ... | ... |
@@ -0,0 +1,64 @@ |
| 1 |
+;;; -*- Mode : lisp -*- |
|
| 2 |
+;;; This file was automatically generated by WRITE-JAVA-CLASS-DEFINITIONS-TO-FILE |
|
| 3 |
+ |
|
| 4 |
+ |
|
| 5 |
+;;; Definitions for Java class org.apache.curator.framework.api.GetChildrenBuilder |
|
| 6 |
+ |
|
| 7 |
+ |
|
| 8 |
+(defpackage "FWOAR.LW-CURATOR.JI.GCB" |
|
| 9 |
+ (:export |
|
| 10 |
+ ".STORINGSTATIN" |
|
| 11 |
+ ".INBACKGROUND" |
|
| 12 |
+ ".FORPATH" |
|
| 13 |
+ ".WATCHED" |
|
| 14 |
+ ".USINGWATCHER")) |
|
| 15 |
+ |
|
| 16 |
+(in-package "FWOAR.LW-CURATOR.JI.GCB") |
|
| 17 |
+(lw-ji:define-java-caller .storingstatin |
|
| 18 |
+ "org/apache/curator/framework/api/GetChildrenBuilder" |
|
| 19 |
+ "storingStatIn" |
|
| 20 |
+ :signatures |
|
| 21 |
+ ("public abstract java.lang.Object storingStatIn(org.apache.zookeeper.data.Stat)"))
|
|
| 22 |
+(lw-ji:define-java-caller .inbackground |
|
| 23 |
+ "org/apache/curator/framework/api/GetChildrenBuilder" |
|
| 24 |
+ "inBackground" |
|
| 25 |
+ :signatures |
|
| 26 |
+ ("public abstract java.lang.Object inBackground()"
|
|
| 27 |
+ "public abstract java.lang.Object inBackground(java.lang.Object)" |
|
| 28 |
+ "public abstract java.lang.Object inBackground(org.apache.curator.framework.api.BackgroundCallback)" |
|
| 29 |
+ "public abstract java.lang.Object inBackground(org.apache.curator.framework.api.BackgroundCallback, java.lang.Object)" |
|
| 30 |
+ "public abstract java.lang.Object inBackground(org.apache.curator.framework.api.BackgroundCallback, java.util.concurrent.Executor)" |
|
| 31 |
+ "public abstract java.lang.Object inBackground(org.apache.curator.framework.api.BackgroundCallback, java.lang.Object, java.util.concurrent.Executor)")) |
|
| 32 |
+(lw-ji:define-java-caller .forpath |
|
| 33 |
+ "org/apache/curator/framework/api/GetChildrenBuilder" |
|
| 34 |
+ "forPath" |
|
| 35 |
+ :signatures |
|
| 36 |
+ ("public abstract java.lang.Object forPath(java.lang.String)"))
|
|
| 37 |
+(lw-ji:define-java-caller .watched |
|
| 38 |
+ "org/apache/curator/framework/api/GetChildrenBuilder" |
|
| 39 |
+ "watched" |
|
| 40 |
+ :signatures |
|
| 41 |
+ ("public abstract java.lang.Object watched()"))
|
|
| 42 |
+(lw-ji:define-java-caller .usingwatcher |
|
| 43 |
+ "org/apache/curator/framework/api/GetChildrenBuilder" |
|
| 44 |
+ "usingWatcher" |
|
| 45 |
+ :signatures |
|
| 46 |
+ ("public abstract java.lang.Object usingWatcher(org.apache.curator.framework.api.CuratorWatcher)"
|
|
| 47 |
+ "public abstract java.lang.Object usingWatcher(org.apache.zookeeper.Watcher)")) |
|
| 48 |
+ |
|
| 49 |
+;;; End of class org.apache.curator.framework.api.GetChildrenBuilder |
|
| 50 |
+ |
|
| 51 |
+atched |
|
| 52 |
+ "org/apache/curator/framework/api/GetChildrenBuilder" |
|
| 53 |
+ "watched" |
|
| 54 |
+ :signatures |
|
| 55 |
+ ("public abstract java.lang.Object watched()"))
|
|
| 56 |
+(lw-ji:define-java-caller getchildrenbuilder.usingwatcher |
|
| 57 |
+ "org/apache/curator/framework/api/GetChildrenBuilder" |
|
| 58 |
+ "usingWatcher" |
|
| 59 |
+ :signatures |
|
| 60 |
+ ("public abstract java.lang.Object usingWatcher(org.apache.curator.framework.api.CuratorWatcher)"
|
|
| 61 |
+ "public abstract java.lang.Object usingWatcher(org.apache.zookeeper.Watcher)")) |
|
| 62 |
+ |
|
| 63 |
+;;; End of class org.apache.curator.framework.api.GetChildrenBuilder |
|
| 64 |
+ |
| 0 | 65 |
new file mode 100644 |
| ... | ... |
@@ -0,0 +1,70 @@ |
| 1 |
+;;; -*- Mode : lisp -*- |
|
| 2 |
+;;; This file was automatically generated by WRITE-JAVA-CLASS-DEFINITIONS-TO-FILE |
|
| 3 |
+ |
|
| 4 |
+ |
|
| 5 |
+;;; Definitions for Java class org.apache.curator.framework.api.GetDataBuilder |
|
| 6 |
+ |
|
| 7 |
+ |
|
| 8 |
+(defpackage "FWOAR.LW-CURATOR.JI.GDB" |
|
| 9 |
+ (:export |
|
| 10 |
+ ".STORINGSTATIN" |
|
| 11 |
+ ".INBACKGROUND" |
|
| 12 |
+ ".FORPATH" |
|
| 13 |
+ ".WATCHED" |
|
| 14 |
+ ".DECOMPRESSED" |
|
| 15 |
+ ".USINGWATCHER")) |
|
| 16 |
+ |
|
| 17 |
+(in-package "FWOAR.LW-CURATOR.JI.GDB") |
|
| 18 |
+(lw-ji:define-java-caller .storingstatin |
|
| 19 |
+ "org/apache/curator/framework/api/GetDataBuilder" |
|
| 20 |
+ "storingStatIn" |
|
| 21 |
+ :signatures |
|
| 22 |
+ ("public abstract java.lang.Object storingStatIn(org.apache.zookeeper.data.Stat)"))
|
|
| 23 |
+(lw-ji:define-java-caller .inbackground |
|
| 24 |
+ "org/apache/curator/framework/api/GetDataBuilder" |
|
| 25 |
+ "inBackground" |
|
| 26 |
+ :signatures |
|
| 27 |
+ ("public abstract java.lang.Object inBackground()"
|
|
| 28 |
+ "public abstract java.lang.Object inBackground(java.lang.Object)" |
|
| 29 |
+ "public abstract java.lang.Object inBackground(org.apache.curator.framework.api.BackgroundCallback)" |
|
| 30 |
+ "public abstract java.lang.Object inBackground(org.apache.curator.framework.api.BackgroundCallback, java.lang.Object)" |
|
| 31 |
+ "public abstract java.lang.Object inBackground(org.apache.curator.framework.api.BackgroundCallback, java.util.concurrent.Executor)" |
|
| 32 |
+ "public abstract java.lang.Object inBackground(org.apache.curator.framework.api.BackgroundCallback, java.lang.Object, java.util.concurrent.Executor)")) |
|
| 33 |
+(lw-ji:define-java-caller .forpath |
|
| 34 |
+ "org/apache/curator/framework/api/GetDataBuilder" |
|
| 35 |
+ "forPath" |
|
| 36 |
+ :signatures |
|
| 37 |
+ ("public abstract java.lang.Object forPath(java.lang.String)"))
|
|
| 38 |
+(lw-ji:define-java-caller .watched |
|
| 39 |
+ "org/apache/curator/framework/api/GetDataBuilder" |
|
| 40 |
+ "watched" |
|
| 41 |
+ :signatures |
|
| 42 |
+ ("public abstract java.lang.Object watched()"))
|
|
| 43 |
+(lw-ji:define-java-caller .decompressed |
|
| 44 |
+ "org/apache/curator/framework/api/GetDataBuilder" |
|
| 45 |
+ "decompressed" |
|
| 46 |
+ :signatures |
|
| 47 |
+ ("public abstract java.lang.Object decompressed()"))
|
|
| 48 |
+(lw-ji:define-java-caller .usingwatcher |
|
| 49 |
+ "org/apache/curator/framework/api/GetDataBuilder" |
|
| 50 |
+ "usingWatcher" |
|
| 51 |
+ :signatures |
|
| 52 |
+ ("public abstract java.lang.Object usingWatcher(org.apache.curator.framework.api.CuratorWatcher)"
|
|
| 53 |
+ "public abstract java.lang.Object usingWatcher(org.apache.zookeeper.Watcher)")) |
|
| 54 |
+ |
|
| 55 |
+;;; End of class org.apache.curator.framework.api.GetDataBuilder |
|
| 56 |
+ |
|
| 57 |
+d |
|
| 58 |
+ "org/apache/curator/framework/api/GetDataBuilder" |
|
| 59 |
+ "decompressed" |
|
| 60 |
+ :signatures |
|
| 61 |
+ ("public abstract java.lang.Object decompressed()"))
|
|
| 62 |
+(lw-ji:define-java-caller getdatabuilder.usingwatcher |
|
| 63 |
+ "org/apache/curator/framework/api/GetDataBuilder" |
|
| 64 |
+ "usingWatcher" |
|
| 65 |
+ :signatures |
|
| 66 |
+ ("public abstract java.lang.Object usingWatcher(org.apache.curator.framework.api.CuratorWatcher)"
|
|
| 67 |
+ "public abstract java.lang.Object usingWatcher(org.apache.zookeeper.Watcher)")) |
|
| 68 |
+ |
|
| 69 |
+;;; End of class org.apache.curator.framework.api.GetDataBuilder |
|
| 70 |
+ |
| 0 | 71 |
new file mode 100644 |
| ... | ... |
@@ -0,0 +1,23 @@ |
| 1 |
+;;; -*- Mode:Lisp; Syntax:ANSI-Common-Lisp; Package: ASDF-USER -*- |
|
| 2 |
+(in-package :asdf-user) |
|
| 3 |
+ |
|
| 4 |
+(defsystem :lw-curator |
|
| 5 |
+ :description "" |
|
| 6 |
+ :author "Ed L <edward@elangley.org>" |
|
| 7 |
+ :license "MIT" |
|
| 8 |
+ :depends-on (#:alexandria |
|
| 9 |
+ #:uiop |
|
| 10 |
+ #:serapeum |
|
| 11 |
+ #:fwoar-lisputils |
|
| 12 |
+ (:require "java-interface")) |
|
| 13 |
+ :serial t |
|
| 14 |
+ :components ((:file "packages") |
|
| 15 |
+ (:file "init") |
|
| 16 |
+ (:module "jinterface" |
|
| 17 |
+ :components ((:file "al") |
|
| 18 |
+ (:file "bebr") |
|
| 19 |
+ (:file "cf") |
|
| 20 |
+ (:file "cff") |
|
| 21 |
+ (:file "gcb") |
|
| 22 |
+ (:file "gdb"))) |
|
| 23 |
+ (:file "main"))) |
| 0 | 24 |
new file mode 100644 |
| ... | ... |
@@ -0,0 +1,11 @@ |
| 1 |
+(in-package :fwoar.lw-curator) |
|
| 2 |
+ |
|
| 3 |
+ |
|
| 4 |
+(defun get-consumer-partitions (client) |
|
| 5 |
+ (lw-ji:map-java-object-array |
|
| 6 |
+ 'identity |
|
| 7 |
+ (lw-ji:call-java-method "java.util.ArrayList.toArray" |
|
| 8 |
+ (|org.apache.curator.framework.api|:getchildrenbuilder.forpath |
|
| 9 |
+ (|org.apache.curator.framework|:curatorframework.getchildren client) |
|
| 10 |
+ "/consumers/optimus-prime-lab-6/offsets/action-txns")) |
|
| 11 |
+ :collect t)) |