kafka-clj.pool.util — kafka-clj 4.0.3

Pool utility functions and data types

assert-timeout! clj

(assert-timeout! timeout-ms start-ts)

When timeout-ms have passed since start-ts a TimeoutException is thrown

call-safely clj

(call-safely f & args)

close-scheduled-exec-service! clj

(close-scheduled-exec-service! exec-service)

Close and shutdown the executor service

create-pool-obj clj

(create-pool-obj v)

now clj

(now)

pool-obj-idle-timeout? clj

(pool-obj-idle-timeout? v timeout-ms)

True if (diff curr-time (.ts v)) > timeout-ms

pool-obj-ttl-timeout? clj

(pool-obj-ttl-timeout? v timeout-ms)

True if (diff curr-time (.gen-ts v)) > timeout-ms

schedule clj

(schedule exec-service check-freq-ms f)

Scheduled the function f at a fixed rate at check-freq-ms

scheduled-exec-service clj

(scheduled-exec-service n)

Create a single threaded exec service that creates daemon threads with name n

timeout? clj

(timeout? timeout-ms start-ts)

True if the diff between now and start-ts is more than timeout-ms