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

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.

channel? clj

(channel? c)

clamp clj

(clamp start end x)

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. deadline-fn is a function of a message that returns a channel that closes when the message is 'due'. deadline-fn may return nil if a message has no particular urgency.

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)