Browse code
chore: update generated source and generator
Ed Langley authored on 02/05/2020 08:52:03Showing 8 changed files
- generate-ji-definitions.lisp
- jinterface/al.lisp
- jinterface/bebr.lisp
- jinterface/cf.lisp
- jinterface/cff.lisp
- jinterface/gcb.lisp
- jinterface/gdb.lisp
- main.lisp
| ... | ... |
@@ -12,30 +12,42 @@ |
| 12 | 12 |
(lw-ji:write-java-class-definitions-to-file java-class-name |
| 13 | 13 |
(jinterface-dest dest) |
| 14 | 14 |
:prefix "" |
| 15 |
- :lisp-name nil |
|
| 16 |
- :create-defpackage t |
|
| 17 |
- :package-name package |
|
| 18 |
- :if-exists :overwrite)) |
|
| 15 |
+ :lisp-name package |
|
| 16 |
+ :if-exists :supersede)) |
|
| 19 | 17 |
(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))) |
|
| 18 |
+ `(list |
|
| 19 |
+ ,@(mapcar (fw.lu:destructuring-lambda ((&key java-class dest name)) |
|
| 20 |
+ `(write-class-def ,java-class ,dest ,name)) |
|
| 21 |
+ defs))) |
|
| 22 |
+ |
|
| 24 | 23 |
|
| 25 | 24 |
(defun run () |
| 26 | 25 |
(write-class-defs |
| 27 | 26 |
(:java-class "org.apache.curator.framework.CuratorFramework" |
| 28 |
- :package :fwoar.lw-curator.ji.framework |
|
| 27 |
+ :name 'fwoar.lw-curator.ji.framework::class |
|
| 29 | 28 |
:dest "cf.lisp") |
| 30 | 29 |
|
| 30 |
+ (:java-class "org.apache.curator.framework.CuratorFrameworkFactory" |
|
| 31 |
+ :name 'fwoar.lw-curator.ji.cff::class |
|
| 32 |
+ :dest "cff.lisp") |
|
| 33 |
+ |
|
| 34 |
+ (:java-class "org.apache.curator.retry.BoundedExponentialBackoffRetry" |
|
| 35 |
+ :name 'fwoar.lw-curator.ji.bebr::class |
|
| 36 |
+ :dest "bebr.lisp") |
|
| 37 |
+ |
|
| 31 | 38 |
(:java-class "org.apache.curator.framework.api.GetChildrenBuilder" |
| 32 |
- :package :fwoar.lw-curator.ji.gcb |
|
| 39 |
+ :name 'fwoar.lw-curator.ji.gcb::class |
|
| 33 | 40 |
:dest "gcb.lisp") |
| 34 | 41 |
|
| 35 | 42 |
(:java-class "org.apache.curator.framework.api.GetDataBuilder" |
| 36 |
- :package :fwoar.lw-curator.ji.gdb |
|
| 43 |
+ :name 'fwoar.lw-curator.ji.gdb::class |
|
| 37 | 44 |
:dest "gdb.lisp") |
| 38 | 45 |
|
| 39 | 46 |
(:java-class "java.util.ArrayList" |
| 40 |
- :package :fwoar.lw-curator.ji.al |
|
| 47 |
+ :name 'fwoar.lw-curator.ji.al::class |
|
| 41 | 48 |
:dest "al.lisp"))) |
| 49 |
+ |
|
| 50 |
+#+(or) |
|
| 51 |
+(progn |
|
| 52 |
+ (run) |
|
| 53 |
+ (ql:quickload :lw-curator)) |
| ... | ... |
@@ -5,46 +5,51 @@ |
| 5 | 5 |
;;; Definitions for Java class java.util.ArrayList |
| 6 | 6 |
|
| 7 | 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")) |
|
| 8 |
+(eval-when (compile load eval) |
|
| 9 |
+ (let ((package-name "FWOAR.LW-CURATOR.JI.AL")) |
|
| 10 |
+ (unless (find-package package-name) (make-package package-name))) |
|
| 11 |
+ (lw-ji:intern-and-export-list '(".CONTAINS"
|
|
| 12 |
+ ".RETAINALL" |
|
| 13 |
+ ".FOREACH" |
|
| 14 |
+ ".CLONE" |
|
| 15 |
+ ".ADD" |
|
| 16 |
+ ".GET" |
|
| 17 |
+ ".ITERATOR" |
|
| 18 |
+ ".REPLACEALL" |
|
| 19 |
+ ".TOSTRING" |
|
| 20 |
+ ".GETCLASS" |
|
| 21 |
+ ".EQUALS" |
|
| 22 |
+ ".CLEAR" |
|
| 23 |
+ ".ISEMPTY" |
|
| 24 |
+ ".SIZE" |
|
| 25 |
+ ".SUBLIST" |
|
| 26 |
+ ".NOTIFY" |
|
| 27 |
+ ".REMOVE" |
|
| 28 |
+ ".CONTAINSALL" |
|
| 29 |
+ ".LASTINDEXOF" |
|
| 30 |
+ ".PARALLELSTREAM" |
|
| 31 |
+ ".ADDALL" |
|
| 32 |
+ ".INDEXOF" |
|
| 33 |
+ ".STREAM" |
|
| 34 |
+ ".SPLITERATOR" |
|
| 35 |
+ ".TRIMTOSIZE" |
|
| 36 |
+ ".NOTIFYALL" |
|
| 37 |
+ ".HASHCODE" |
|
| 38 |
+ ".ENSURECAPACITY" |
|
| 39 |
+ ".REMOVEALL" |
|
| 40 |
+ ".TOARRAY" |
|
| 41 |
+ ".SET" |
|
| 42 |
+ ".REMOVEIF" |
|
| 43 |
+ ".WAIT" |
|
| 44 |
+ ".LISTITERATOR" |
|
| 45 |
+ ".SORT" |
|
| 46 |
+ ".NEW" |
|
| 47 |
+ "CLASS") |
|
| 48 |
+ "FWOAR.LW-CURATOR.JI.AL")) |
|
| 46 | 49 |
|
| 47 | 50 |
(in-package "FWOAR.LW-CURATOR.JI.AL") |
| 51 |
+(defconstant class "java.util.ArrayList") |
|
| 52 |
+(lw-ji:record-java-class-lisp-symbol "java.util.ArrayList" 'class) |
|
| 48 | 53 |
(lw-ji:define-java-constructor .new |
| 49 | 54 |
"java.util.ArrayList" |
| 50 | 55 |
:signatures |
| ... | ... |
@@ -239,38 +244,3 @@ |
| 239 | 244 |
|
| 240 | 245 |
;;; End of class java.util.ArrayList |
| 241 | 246 |
|
| 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 |
- |
| ... | ... |
@@ -6,84 +6,84 @@ |
| 6 | 6 |
|
| 7 | 7 |
|
| 8 | 8 |
(eval-when (compile load eval) |
| 9 |
- (let ((package-name "org.apache.curator.retry")) |
|
| 9 |
+ (let ((package-name "FWOAR.LW-CURATOR.JI.BEBR")) |
|
| 10 | 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")) |
|
| 11 |
+ (lw-ji:intern-and-export-list '(".GETN"
|
|
| 12 |
+ ".TOSTRING" |
|
| 13 |
+ ".GETCLASS" |
|
| 14 |
+ ".EQUALS" |
|
| 15 |
+ ".NOTIFY" |
|
| 16 |
+ ".GETBASESLEEPTIMEMS" |
|
| 17 |
+ ".ALLOWRETRY" |
|
| 18 |
+ ".GETMAXSLEEPTIMEMS" |
|
| 19 |
+ ".NOTIFYALL" |
|
| 20 |
+ ".HASHCODE" |
|
| 21 |
+ ".WAIT" |
|
| 22 |
+ ".NEW" |
|
| 23 |
+ "CLASS") |
|
| 24 |
+ "FWOAR.LW-CURATOR.JI.BEBR")) |
|
| 25 | 25 |
|
| 26 |
-(in-package "org.apache.curator.retry") |
|
| 27 |
-(defconstant boundedexponentialbackoffretry. "org.apache.curator.retry.BoundedExponentialBackoffRetry") |
|
| 26 |
+(in-package "FWOAR.LW-CURATOR.JI.BEBR") |
|
| 27 |
+(defconstant class "org.apache.curator.retry.BoundedExponentialBackoffRetry") |
|
| 28 | 28 |
(lw-ji:record-java-class-lisp-symbol "org.apache.curator.retry.BoundedExponentialBackoffRetry" |
| 29 |
- 'boundedexponentialbackoffretry.) |
|
| 30 |
-(lw-ji:define-java-constructor boundedexponentialbackoffretry.new |
|
| 29 |
+ 'class) |
|
| 30 |
+(lw-ji:define-java-constructor .new |
|
| 31 | 31 |
"org.apache.curator.retry.BoundedExponentialBackoffRetry" |
| 32 | 32 |
:signatures |
| 33 | 33 |
("org.apache.curator.retry.BoundedExponentialBackoffRetry(int,int,int)")
|
| 34 | 34 |
:class-symbol |
| 35 | 35 |
nil) |
| 36 |
-(lw-ji:define-java-caller boundedexponentialbackoffretry.getn |
|
| 36 |
+(lw-ji:define-java-caller .getn |
|
| 37 | 37 |
"org/apache/curator/retry/BoundedExponentialBackoffRetry" |
| 38 | 38 |
"getN" |
| 39 | 39 |
:signatures |
| 40 | 40 |
("public int getN()"))
|
| 41 |
-(lw-ji:define-java-caller boundedexponentialbackoffretry.tostring |
|
| 41 |
+(lw-ji:define-java-caller .tostring |
|
| 42 | 42 |
"org/apache/curator/retry/BoundedExponentialBackoffRetry" |
| 43 | 43 |
"toString" |
| 44 | 44 |
:signatures |
| 45 | 45 |
("public java.lang.String toString()"))
|
| 46 |
-(lw-ji:define-java-caller boundedexponentialbackoffretry.getclass |
|
| 46 |
+(lw-ji:define-java-caller .getclass |
|
| 47 | 47 |
"org/apache/curator/retry/BoundedExponentialBackoffRetry" |
| 48 | 48 |
"getClass" |
| 49 | 49 |
:signatures |
| 50 | 50 |
("public final java.lang.Class getClass()"))
|
| 51 |
-(lw-ji:define-java-caller boundedexponentialbackoffretry.equals |
|
| 51 |
+(lw-ji:define-java-caller .equals |
|
| 52 | 52 |
"org/apache/curator/retry/BoundedExponentialBackoffRetry" |
| 53 | 53 |
"equals" |
| 54 | 54 |
:signatures |
| 55 | 55 |
("public boolean equals(java.lang.Object)"))
|
| 56 |
-(lw-ji:define-java-caller boundedexponentialbackoffretry.notify |
|
| 56 |
+(lw-ji:define-java-caller .notify |
|
| 57 | 57 |
"org/apache/curator/retry/BoundedExponentialBackoffRetry" |
| 58 | 58 |
"notify" |
| 59 | 59 |
:signatures |
| 60 | 60 |
("public final void notify()"))
|
| 61 |
-(lw-ji:define-java-caller boundedexponentialbackoffretry.getbasesleeptimems |
|
| 61 |
+(lw-ji:define-java-caller .getbasesleeptimems |
|
| 62 | 62 |
"org/apache/curator/retry/BoundedExponentialBackoffRetry" |
| 63 | 63 |
"getBaseSleepTimeMs" |
| 64 | 64 |
:signatures |
| 65 | 65 |
("public int getBaseSleepTimeMs()"))
|
| 66 |
-(lw-ji:define-java-caller boundedexponentialbackoffretry.allowretry |
|
| 66 |
+(lw-ji:define-java-caller .allowretry |
|
| 67 | 67 |
"org/apache/curator/retry/BoundedExponentialBackoffRetry" |
| 68 | 68 |
"allowRetry" |
| 69 | 69 |
:signatures |
| 70 | 70 |
("public boolean allowRetry(int, long, org.apache.curator.RetrySleeper)"))
|
| 71 |
-(lw-ji:define-java-caller boundedexponentialbackoffretry.getmaxsleeptimems |
|
| 71 |
+(lw-ji:define-java-caller .getmaxsleeptimems |
|
| 72 | 72 |
"org/apache/curator/retry/BoundedExponentialBackoffRetry" |
| 73 | 73 |
"getMaxSleepTimeMs" |
| 74 | 74 |
:signatures |
| 75 | 75 |
("public int getMaxSleepTimeMs()"))
|
| 76 |
-(lw-ji:define-java-caller boundedexponentialbackoffretry.notifyall |
|
| 76 |
+(lw-ji:define-java-caller .notifyall |
|
| 77 | 77 |
"org/apache/curator/retry/BoundedExponentialBackoffRetry" |
| 78 | 78 |
"notifyAll" |
| 79 | 79 |
:signatures |
| 80 | 80 |
("public final void notifyAll()"))
|
| 81 |
-(lw-ji:define-java-caller boundedexponentialbackoffretry.hashcode |
|
| 81 |
+(lw-ji:define-java-caller .hashcode |
|
| 82 | 82 |
"org/apache/curator/retry/BoundedExponentialBackoffRetry" |
| 83 | 83 |
"hashCode" |
| 84 | 84 |
:signatures |
| 85 | 85 |
("public int hashCode()"))
|
| 86 |
-(lw-ji:define-java-caller boundedexponentialbackoffretry.wait |
|
| 86 |
+(lw-ji:define-java-caller .wait |
|
| 87 | 87 |
"org/apache/curator/retry/BoundedExponentialBackoffRetry" |
| 88 | 88 |
"wait" |
| 89 | 89 |
:signatures |
| ... | ... |
@@ -5,47 +5,53 @@ |
| 5 | 5 |
;;; Definitions for Java class org.apache.curator.framework.CuratorFramework |
| 6 | 6 |
|
| 7 | 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")) |
|
| 8 |
+(eval-when (compile load eval) |
|
| 9 |
+ (let ((package-name "FWOAR.LW-CURATOR.JI.FRAMEWORK")) |
|
| 10 |
+ (unless (find-package package-name) (make-package package-name))) |
|
| 11 |
+ (lw-ji:intern-and-export-list '(".CREATECONTAINERS"
|
|
| 12 |
+ ".GETCURRENTCONFIG" |
|
| 13 |
+ ".GETACL" |
|
| 14 |
+ ".BLOCKUNTILCONNECTED" |
|
| 15 |
+ ".RECONFIG" |
|
| 16 |
+ ".SETACL" |
|
| 17 |
+ ".POSTSAFENOTIFY" |
|
| 18 |
+ ".DELETE" |
|
| 19 |
+ ".RUNSAFE" |
|
| 20 |
+ ".INTRANSACTION" |
|
| 21 |
+ ".GETCHILDREN" |
|
| 22 |
+ ".CLEARWATCHERREFERENCES" |
|
| 23 |
+ ".CLOSE" |
|
| 24 |
+ ".CREATE" |
|
| 25 |
+ ".WATCHES" |
|
| 26 |
+ ".USINGNAMESPACE" |
|
| 27 |
+ ".TRANSACTIONOP" |
|
| 28 |
+ ".GETCONNECTIONSTATELISTENABLE" |
|
| 29 |
+ ".GETCURATORLISTENABLE" |
|
| 30 |
+ ".GETSTATE" |
|
| 31 |
+ ".GETSCHEMASET" |
|
| 32 |
+ ".NEWNAMESPACEAWAREENSUREPATH" |
|
| 33 |
+ ".SYNC" |
|
| 34 |
+ ".GETCONFIG" |
|
| 35 |
+ ".GETZOOKEEPERCLIENT" |
|
| 36 |
+ ".GETUNHANDLEDERRORLISTENABLE" |
|
| 37 |
+ ".NONNAMESPACEVIEW" |
|
| 38 |
+ ".GETDATA" |
|
| 39 |
+ ".GETNAMESPACE" |
|
| 40 |
+ ".SETDATA" |
|
| 41 |
+ ".GETCONNECTIONSTATEERRORPOLICY" |
|
| 42 |
+ ".CHECKEXISTS" |
|
| 43 |
+ ".ISZK34COMPATIBILITYMODE" |
|
| 44 |
+ ".START" |
|
| 45 |
+ ".ISSTARTED" |
|
| 46 |
+ ".TRANSACTION" |
|
| 47 |
+ ".NEWWATCHERREMOVECURATORFRAMEWORK" |
|
| 48 |
+ "CLASS") |
|
| 49 |
+ "FWOAR.LW-CURATOR.JI.FRAMEWORK")) |
|
| 47 | 50 |
|
| 48 | 51 |
(in-package "FWOAR.LW-CURATOR.JI.FRAMEWORK") |
| 52 |
+(defconstant class "org.apache.curator.framework.CuratorFramework") |
|
| 53 |
+(lw-ji:record-java-class-lisp-symbol "org.apache.curator.framework.CuratorFramework" |
|
| 54 |
+ 'class) |
|
| 49 | 55 |
(lw-ji:define-java-caller .createcontainers |
| 50 | 56 |
"org/apache/curator/framework/CuratorFramework" |
| 51 | 57 |
"createContainers" |
| ... | ... |
@@ -92,16 +98,16 @@ |
| 92 | 98 |
"runSafe" |
| 93 | 99 |
:signatures |
| 94 | 100 |
("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 | 101 |
(lw-ji:define-java-caller .intransaction |
| 101 | 102 |
"org/apache/curator/framework/CuratorFramework" |
| 102 | 103 |
"inTransaction" |
| 103 | 104 |
:signatures |
| 104 | 105 |
("public abstract org.apache.curator.framework.api.transaction.CuratorTransaction inTransaction()"))
|
| 106 |
+(lw-ji:define-java-caller .getchildren |
|
| 107 |
+ "org/apache/curator/framework/CuratorFramework" |
|
| 108 |
+ "getChildren" |
|
| 109 |
+ :signatures |
|
| 110 |
+ ("public abstract org.apache.curator.framework.api.GetChildrenBuilder getChildren()"))
|
|
| 105 | 111 |
(lw-ji:define-java-caller .clearwatcherreferences |
| 106 | 112 |
"org/apache/curator/framework/CuratorFramework" |
| 107 | 113 |
"clearWatcherReferences" |
| ... | ... |
@@ -234,48 +240,5 @@ |
| 234 | 240 |
:signatures |
| 235 | 241 |
("public abstract org.apache.curator.framework.WatcherRemoveCuratorFramework newWatcherRemoveCuratorFramework()"))
|
| 236 | 242 |
|
| 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 | 243 |
;;; End of class org.apache.curator.framework.CuratorFramework |
| 281 | 244 |
|
| ... | ... |
@@ -6,72 +6,72 @@ |
| 6 | 6 |
|
| 7 | 7 |
|
| 8 | 8 |
(eval-when (compile load eval) |
| 9 |
- (let ((package-name "org.apache.curator.framework")) |
|
| 9 |
+ (let ((package-name "FWOAR.LW-CURATOR.JI.CFF")) |
|
| 10 | 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")) |
|
| 11 |
+ (lw-ji:intern-and-export-list '(".GETLOCALADDRESS"
|
|
| 12 |
+ ".TOSTRING" |
|
| 13 |
+ ".GETCLASS" |
|
| 14 |
+ ".EQUALS" |
|
| 15 |
+ ".NOTIFY" |
|
| 16 |
+ ".NEWCLIENT" |
|
| 17 |
+ ".NOTIFYALL" |
|
| 18 |
+ ".HASHCODE" |
|
| 19 |
+ ".BUILDER" |
|
| 20 |
+ ".WAIT" |
|
| 21 |
+ "CLASS") |
|
| 22 |
+ "FWOAR.LW-CURATOR.JI.CFF")) |
|
| 23 | 23 |
|
| 24 |
-(in-package "org.apache.curator.framework") |
|
| 25 |
-(defconstant curatorframeworkfactory. "org.apache.curator.framework.CuratorFrameworkFactory") |
|
| 24 |
+(in-package "FWOAR.LW-CURATOR.JI.CFF") |
|
| 25 |
+(defconstant class "org.apache.curator.framework.CuratorFrameworkFactory") |
|
| 26 | 26 |
(lw-ji:record-java-class-lisp-symbol "org.apache.curator.framework.CuratorFrameworkFactory" |
| 27 |
- 'curatorframeworkfactory.) |
|
| 28 |
-(lw-ji:define-java-caller curatorframeworkfactory.getlocaladdress |
|
| 27 |
+ 'class) |
|
| 28 |
+(lw-ji:define-java-caller .getlocaladdress |
|
| 29 | 29 |
"org/apache/curator/framework/CuratorFrameworkFactory" |
| 30 | 30 |
"getLocalAddress" |
| 31 | 31 |
:signatures |
| 32 | 32 |
("public static byte[] getLocalAddress()"))
|
| 33 |
-(lw-ji:define-java-caller curatorframeworkfactory.tostring |
|
| 33 |
+(lw-ji:define-java-caller .tostring |
|
| 34 | 34 |
"org/apache/curator/framework/CuratorFrameworkFactory" |
| 35 | 35 |
"toString" |
| 36 | 36 |
:signatures |
| 37 | 37 |
("public java.lang.String toString()"))
|
| 38 |
-(lw-ji:define-java-caller curatorframeworkfactory.getclass |
|
| 38 |
+(lw-ji:define-java-caller .getclass |
|
| 39 | 39 |
"org/apache/curator/framework/CuratorFrameworkFactory" |
| 40 | 40 |
"getClass" |
| 41 | 41 |
:signatures |
| 42 | 42 |
("public final java.lang.Class getClass()"))
|
| 43 |
-(lw-ji:define-java-caller curatorframeworkfactory.equals |
|
| 43 |
+(lw-ji:define-java-caller .equals |
|
| 44 | 44 |
"org/apache/curator/framework/CuratorFrameworkFactory" |
| 45 | 45 |
"equals" |
| 46 | 46 |
:signatures |
| 47 | 47 |
("public boolean equals(java.lang.Object)"))
|
| 48 |
-(lw-ji:define-java-caller curatorframeworkfactory.notify |
|
| 48 |
+(lw-ji:define-java-caller .notify |
|
| 49 | 49 |
"org/apache/curator/framework/CuratorFrameworkFactory" |
| 50 | 50 |
"notify" |
| 51 | 51 |
:signatures |
| 52 | 52 |
("public final void notify()"))
|
| 53 |
-(lw-ji:define-java-caller curatorframeworkfactory.newclient |
|
| 53 |
+(lw-ji:define-java-caller .newclient |
|
| 54 | 54 |
"org/apache/curator/framework/CuratorFrameworkFactory" |
| 55 | 55 |
"newClient" |
| 56 | 56 |
:signatures |
| 57 | 57 |
("public static org.apache.curator.framework.CuratorFramework newClient(java.lang.String, org.apache.curator.RetryPolicy)"
|
| 58 | 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 |
|
| 59 |
+(lw-ji:define-java-caller .notifyall |
|
| 60 | 60 |
"org/apache/curator/framework/CuratorFrameworkFactory" |
| 61 | 61 |
"notifyAll" |
| 62 | 62 |
:signatures |
| 63 | 63 |
("public final void notifyAll()"))
|
| 64 |
-(lw-ji:define-java-caller curatorframeworkfactory.hashcode |
|
| 64 |
+(lw-ji:define-java-caller .hashcode |
|
| 65 | 65 |
"org/apache/curator/framework/CuratorFrameworkFactory" |
| 66 | 66 |
"hashCode" |
| 67 | 67 |
:signatures |
| 68 | 68 |
("public int hashCode()"))
|
| 69 |
-(lw-ji:define-java-caller curatorframeworkfactory.builder |
|
| 69 |
+(lw-ji:define-java-caller .builder |
|
| 70 | 70 |
"org/apache/curator/framework/CuratorFrameworkFactory" |
| 71 | 71 |
"builder" |
| 72 | 72 |
:signatures |
| 73 | 73 |
("public static org.apache.curator.framework.CuratorFrameworkFactory$Builder builder()"))
|
| 74 |
-(lw-ji:define-java-caller curatorframeworkfactory.wait |
|
| 74 |
+(lw-ji:define-java-caller .wait |
|
| 75 | 75 |
"org/apache/curator/framework/CuratorFrameworkFactory" |
| 76 | 76 |
"wait" |
| 77 | 77 |
:signatures |
| ... | ... |
@@ -5,15 +5,21 @@ |
| 5 | 5 |
;;; Definitions for Java class org.apache.curator.framework.api.GetChildrenBuilder |
| 6 | 6 |
|
| 7 | 7 |
|
| 8 |
-(defpackage "FWOAR.LW-CURATOR.JI.GCB" |
|
| 9 |
- (:export |
|
| 10 |
- ".STORINGSTATIN" |
|
| 11 |
- ".INBACKGROUND" |
|
| 12 |
- ".FORPATH" |
|
| 13 |
- ".WATCHED" |
|
| 14 |
- ".USINGWATCHER")) |
|
| 8 |
+(eval-when (compile load eval) |
|
| 9 |
+ (let ((package-name "FWOAR.LW-CURATOR.JI.GCB")) |
|
| 10 |
+ (unless (find-package package-name) (make-package package-name))) |
|
| 11 |
+ (lw-ji:intern-and-export-list '(".STORINGSTATIN"
|
|
| 12 |
+ ".INBACKGROUND" |
|
| 13 |
+ ".FORPATH" |
|
| 14 |
+ ".WATCHED" |
|
| 15 |
+ ".USINGWATCHER" |
|
| 16 |
+ "CLASS") |
|
| 17 |
+ "FWOAR.LW-CURATOR.JI.GCB")) |
|
| 15 | 18 |
|
| 16 | 19 |
(in-package "FWOAR.LW-CURATOR.JI.GCB") |
| 20 |
+(defconstant class "org.apache.curator.framework.api.GetChildrenBuilder") |
|
| 21 |
+(lw-ji:record-java-class-lisp-symbol "org.apache.curator.framework.api.GetChildrenBuilder" |
|
| 22 |
+ 'class) |
|
| 17 | 23 |
(lw-ji:define-java-caller .storingstatin |
| 18 | 24 |
"org/apache/curator/framework/api/GetChildrenBuilder" |
| 19 | 25 |
"storingStatIn" |
| ... | ... |
@@ -48,17 +54,3 @@ |
| 48 | 54 |
|
| 49 | 55 |
;;; End of class org.apache.curator.framework.api.GetChildrenBuilder |
| 50 | 56 |
|
| 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 |
- |
| ... | ... |
@@ -5,16 +5,22 @@ |
| 5 | 5 |
;;; Definitions for Java class org.apache.curator.framework.api.GetDataBuilder |
| 6 | 6 |
|
| 7 | 7 |
|
| 8 |
-(defpackage "FWOAR.LW-CURATOR.JI.GDB" |
|
| 9 |
- (:export |
|
| 10 |
- ".STORINGSTATIN" |
|
| 11 |
- ".INBACKGROUND" |
|
| 12 |
- ".FORPATH" |
|
| 13 |
- ".WATCHED" |
|
| 14 |
- ".DECOMPRESSED" |
|
| 15 |
- ".USINGWATCHER")) |
|
| 8 |
+(eval-when (compile load eval) |
|
| 9 |
+ (let ((package-name "FWOAR.LW-CURATOR.JI.GDB")) |
|
| 10 |
+ (unless (find-package package-name) (make-package package-name))) |
|
| 11 |
+ (lw-ji:intern-and-export-list '(".STORINGSTATIN"
|
|
| 12 |
+ ".INBACKGROUND" |
|
| 13 |
+ ".FORPATH" |
|
| 14 |
+ ".WATCHED" |
|
| 15 |
+ ".DECOMPRESSED" |
|
| 16 |
+ ".USINGWATCHER" |
|
| 17 |
+ "CLASS") |
|
| 18 |
+ "FWOAR.LW-CURATOR.JI.GDB")) |
|
| 16 | 19 |
|
| 17 | 20 |
(in-package "FWOAR.LW-CURATOR.JI.GDB") |
| 21 |
+(defconstant class "org.apache.curator.framework.api.GetDataBuilder") |
|
| 22 |
+(lw-ji:record-java-class-lisp-symbol "org.apache.curator.framework.api.GetDataBuilder" |
|
| 23 |
+ 'class) |
|
| 18 | 24 |
(lw-ji:define-java-caller .storingstatin |
| 19 | 25 |
"org/apache/curator/framework/api/GetDataBuilder" |
| 20 | 26 |
"storingStatIn" |
| ... | ... |
@@ -54,17 +60,3 @@ |
| 54 | 60 |
|
| 55 | 61 |
;;; End of class org.apache.curator.framework.api.GetDataBuilder |
| 56 | 62 |
|
| 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 |
- |
| ... | ... |
@@ -1,11 +1,57 @@ |
| 1 | 1 |
(in-package :fwoar.lw-curator) |
| 2 | 2 |
|
| 3 |
+(defun o->s (jo) |
|
| 4 |
+ (map 'string 'code-char |
|
| 5 |
+ (lw-ji:primitive-array-to-lisp-array jo))) |
|
| 3 | 6 |
|
| 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)) |
|
| 7 |
+(defun al->lisp (al) |
|
| 8 |
+ (lw-ji:map-java-object-array 'identity |
|
| 9 |
+ (fwoar.lw-curator.ji.al:.toarray al) |
|
| 10 |
+ :collect t)) |
|
| 11 |
+ |
|
| 12 |
+(defun client (host) |
|
| 13 |
+ (fwoar.lw-curator.ji.cff:.newclient host |
|
| 14 |
+ (fwoar.lw-curator.ji.bebr:.new 100 5000 10))) |
|
| 15 |
+ |
|
| 16 |
+(defun call-with-client (client lambda) |
|
| 17 |
+ (fwoar.lw-curator.ji.framework:.start client) |
|
| 18 |
+ (unwind-protect (funcall lambda client) |
|
| 19 |
+ (fwoar.lw-curator.ji.framework:.close client))) |
|
| 20 |
+ |
|
| 21 |
+(defmacro with-client ((sym host) &body body) |
|
| 22 |
+ `(let ((,sym (client ,host))) |
|
| 23 |
+ (call-with-client ,sym |
|
| 24 |
+ (lambda (,sym) |
|
| 25 |
+ ,@body)))) |
|
| 26 |
+ |
|
| 27 |
+(defun get-consumers (client) |
|
| 28 |
+ (al->lisp |
|
| 29 |
+ (fwoar.lw-curator.ji.gcb:.forpath |
|
| 30 |
+ (fwoar.lw-curator.ji.framework:.getchildren client) |
|
| 31 |
+ "/consumers"))) |
|
| 32 |
+ |
|
| 33 |
+(defun get-consumer-topics (client consumer) |
|
| 34 |
+ (al->lisp |
|
| 35 |
+ (fwoar.lw-curator.ji.gcb:.forpath |
|
| 36 |
+ (fwoar.lw-curator.ji.framework:.getchildren client) |
|
| 37 |
+ (format nil "/consumers/~a/offsets" consumer)))) |
|
| 38 |
+ |
|
| 39 |
+(defun get-consumer-partitions (client consumer topic) |
|
| 40 |
+ (al->lisp |
|
| 41 |
+ (fwoar.lw-curator.ji.gcb:.forpath |
|
| 42 |
+ (fwoar.lw-curator.ji.framework:.getchildren client) |
|
| 43 |
+ (format nil "/consumers/~a/offsets/~a" consumer topic)))) |
|
| 44 |
+ |
|
| 45 |
+(defun get-consumer-owner (client consumer topic partition) |
|
| 46 |
+ (o->s |
|
| 47 |
+ (fwoar.lw-curator.ji.gdb:.forpath |
|
| 48 |
+ (fwoar.lw-curator.ji.framework:.getdata client) |
|
| 49 |
+ (format nil "/consumers/~a/owners/~a/~a" consumer topic partition)))) |
|
| 50 |
+ |
|
| 51 |
+(defun get-consumer-offset (client consumer topic partition) |
|
| 52 |
+ (nth-value 0 |
|
| 53 |
+ (parse-integer |
|
| 54 |
+ (o->s |
|
| 55 |
+ (fwoar.lw-curator.ji.gdb:.forpath |
|
| 56 |
+ (fwoar.lw-curator.ji.framework:.getdata client) |
|
| 57 |
+ (format nil "/consumers/~a/offsets/~a/~a" consumer topic partition)))))) |