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

Utility functions.

anomaly? clj

(anomaly? response)

average clj

(average & args)

average+ clj

(average+ & args)

average- clj

(average- & args)

backoff-seq clj

(backoff-seq)

(backoff-seq max)

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

buffer-millis clj

channel? clj

(channel? c)

clamp clj

(clamp start end x)

combo-batching clj

(combo-batching chan msecs)

(combo-batching chan msecs max)

deadline-batching clj

(deadline-batching chan max)

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.

defmulti* clj macro

(defmulti* symbol dispatch-fn)

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

interval-batching clj

(interval-batching chan msecs)

(interval-batching chan msecs max)

Partitions the original chan by non-empty time intervals.

message->deadline clj

(message->deadline message)

message->identifier clj

(message->identifier message)

message->queue-url clj

(message->queue-url message)

message->timeout clj

(message->timeout message)

quot+ clj

(quot+ & nums)

with-deadline clj

(with-deadline message duration)

with-timeout clj

(with-timeout message timeout)