piped.utils — org.clojars.rutledgepaulv/piped 0.1.0

Utility functions.

anomaly? clj

(anomaly? response)

average clj

(average & args)

average+ clj

(average+ & args)

average- clj

(average- & args)

backoff-seq clj

(backoff-seq max)

Returns an infinite seq of exponential back-off timeouts with random jitter.

channel? clj

(channel? c)

clamp clj

(clamp start end x)

deadline-batching clj

(deadline-batching chan max key-fn)

Batches messages from chan and emits the most recently accumulated batch whenever the max batch size is reached or one of the messages in the batch has become 'due' for action. key-fn is a function of a message that returns a channel that closes when the message is 'due'

deadline-safety-buffer clj

defmulti* clj macro

(defmulti* symbol dispatch-fn)

Like clojure.core/defmulti, but actually updates the dispatch value when you reload it.

dev-null clj

(dev-null)

distinct-by clj

(distinct-by f)

(distinct-by f coll)

Like distinct but according to a key-fn instead of the element itself.

interval-batching clj

(interval-batching chan msecs)

(interval-batching chan msecs max)

Partitions the original chan by non-empty time intervals.

maximum-messages-received clj

maximum-wait-time-seconds clj

message->deadline clj

(message->deadline message)

message->queue-url clj

(message->queue-url message)

message->timeout clj

(message->timeout message)

minimum-messages-received clj

minimum-wait-time-seconds clj

on-chan-close clj macro

(on-chan-close chan & body)

Execute body when the channel is closed. This is immediate upon channel closing and occurs on the same thread that closed chan.

visibility-timeout-seconds clj

with-deadline clj

(with-deadline message duration)

with-timeout clj

(with-timeout message timeout)