qbits.tape.tailer

Liking cljdoc? Tell your friends :D

Clojure only.

->tailer-direction
ITailer
make

->tailer-direction^clj

ITailer^cljprotocol

index^clj

(index tailer)

Returns current tailer index

Returns current tailer index

queue^clj

(queue tailer)

Returns Queue associated with that tailer

Returns Queue associated with that tailer

read!^clj

(read! tailer)

Returns message from queue or nil if none are available

Returns message from queue or nil if none are available

set-direction!^clj

(set-direction! tailer dir)

Set tailer direction from :backward or :forward

Set tailer direction from :backward or :forward

to-end!^clj

(to-end! tailer)

Goto the end of the queue

Goto the end of the queue

to-index!^clj

(to-index! tailer i)

Goto specified queue index

Goto specified queue index

to-start!^clj

(to-start! tailer)

Set index to the start of the queue

Set index to the start of the queue

source

make^clj

(make queue)

(make queue {:keys [poll-interval] :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

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

source raw docstring