com.brunobonacci.mulog.buffer — com.brunobonacci/mulog 0.3.1

Logging library designed to log data events instead of plain words.

This namespace contains the implementation of a ring-buffer and a wrapper agent used to buffer the events before their are published to the downstream systems by the publishers.

agent-buffer clj

(agent-buffer capacity)

PRingBuffer clj protocol

RingBuffer protocol

clear clj

(clear this)

removes all the items in the ring buffer

dequeue clj

(dequeue this offset)

removes all the items in the ring buffer up to the and including the given offset

enqueue clj

(enqueue this item)

Add an item to the Ring Buffer.

items clj

(items this)

Returns a sequence of pairs [<offset> <item>]

recurring-task clj

(recurring-task delay-millis task)

ring-buffer clj

(ring-buffer capacity)

Create an empty ring buffer with the specified [capacity].

scheduled-thread-pool clj

(scheduled-thread-pool core-pool-size)

timer-pool clj