kafka-clj.pool.api
Public API for the Pool and Keyed Pools
All pools return objects of type PoolObj to get the value use pool-obj-val
Public API for the Pool and Keyed Pools All pools return objects of type PoolObj to get the value use pool-obj-val
avaiable?clj
(avaiable? keyed-pool k)Return the available objects in the pool keyed by k
Return the available objects in the pool keyed by k
close-allclj
(close-all keyed-pool)(close-all keyed-pool k)IKeyedObjPoolcljprotocol
-get-keyed-poolclj
(-get-keyed-pool this k)Returns an instance of IObjPool
Returns an instance of IObjPool
-keyed-pool-available?clj
(-keyed-pool-available? this k)Return the number of objects available in the pool keyed by k
Return the number of objects available in the pool keyed by k
-keyed-pool-closeclj
(-keyed-pool-close this k)-keyed-pool-close-allclj
(-keyed-pool-close-all this)-keyed-pool-remove-idle!clj
(-keyed-pool-remove-idle! this time-limit-ms)Remove any objects in all keyed pools that has been idle (ie. not polled and returned in more than time-limit-ms)
Remove any objects in all keyed pools that has been idle (ie. not polled and returned in more than time-limit-ms)
-keyed-pool-remove-ttl!clj
(-keyed-pool-remove-ttl! this time-limit-ms)Remove any objects in all keyed pools that has been live longer than time-limit-ms
Remove any objects in all keyed pools that has been live longer than time-limit-ms
-keyed-pool-statsclj
(-keyed-pool-stats this)The all the stats for each IObjPool stored in IKeyedObjPool
The all the stats for each IObjPool stored in IKeyedObjPool
IObjPoolcljprotocol
-available?clj
(-available? this)Return the number of objects available
Return the number of objects available
-close-allclj
(-close-all this)-pollclj
(-poll this timeout-ms)Return a pooled object of type PoolObj or throw a timeout exception
Return a pooled object of type PoolObj or throw a timeout exception
-pool-statsclj
(-pool-stats this)Return the stats for the given pool
Return the stats for the given pool
-remove-idle!clj
(-remove-idle! this time-limit-ms)Remove any objects in the pool that has been idle (ie. not polled and returned in more than time-limit-ms)
Remove any objects in the pool that has been idle (ie. not polled and returned in more than time-limit-ms)
-remove-ttl!clj
(-remove-ttl! this time-limit-ms)Remove any objects in the pool that has been live longer than time-limit-ms
Remove any objects in the pool that has been live longer than time-limit-ms
-returnclj
(-return this v)Return a pooled PoolObj object to the pool
Return a pooled PoolObj object to the pool
pollclj
(poll keyed-pool k)(poll keyed-pool k timeout-ms)Polls from a keyed pool, first we get the keyed poll, and then run poll on that pool
Polls from a keyed pool, first we get the keyed poll, and then run poll on that pool
pool-objclj
(pool-obj v)pool-obj-gen-tsclj
(pool-obj-gen-ts v)pool-obj-tsclj
(pool-obj-ts v)pool-obj-update-tsclj
(pool-obj-update-ts v ts)Update the ts of the pool obj and return a new instance of PoolObj
Update the ts of the pool obj and return a new instance of PoolObj
pool-obj-valclj
(pool-obj-val v)pool-statsclj
(pool-stats keyed-pool)Return a map of stats for the IKeyedObjPool
Return a map of stats for the IKeyedObjPool
returnclj
(return keyed-pool k v)Return to a keyed pool, first we get the keyed pool, and then run return on that pool v must be of type PoolObj Important: The actual object return is not checked to have been polled from the pool, its the caller's reponsibility to manage poll return sequences correctly.
Return to a keyed pool, first we get the keyed pool, and then run return on that pool v must be of type PoolObj Important: The actual object return is not checked to have been polled from the pool, its the caller's reponsibility to manage poll return sequences correctly.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close