qbits.tape.tailer — io.zalky/tape 0.3.5-rc1

->tailer-direction clj

ITailer clj protocol

index clj

(index tailer)

Returns current tailer index

queue clj

(queue tailer)

Returns Queue associated with that tailer

read! clj

(read! tailer)

Returns message from queue or nil if none are available

set-direction! clj

(set-direction! tailer dir)

Set tailer direction from :backward or :forward

tailer clj

(tailer tailer)

Returns the tailer object

to-end! clj

(to-end! tailer)

Goto the end of the queue

to-index! clj

(to-index! tailer i)

Goto specified queue index

to-start! clj

(to-start! tailer)

Set index to the start of the queue

make clj

(make queue)

(make queue {:keys [poll-interval id] :or {poll-interval 50}})

Creates a new tailer that can consume a queue instance. Takes a queue to read from as first argument.

poll-interval will set the wait interval the tailer will apply when used in a reducible or seq context only when there are no new message ready to be consumed.

clojure.datafy/datafy can be called on the tailer to get associated data

A tailer can also be consumed as a Seq or a Reducible.

You can effectively do (doseq [msg tailer] ...) or (run! #(do-something %) tailer).

More info about tailers : https://github.com/OpenHFT/Chronicle-Queue#how-does-chronicle-queue-work