binance-clj.websocket.buffer — io.github.ugurbay/binance-clj 1.0.1

Bounded non-blocking event buffer for WebSocket callback isolation.

create-buffer clj

(create-buffer)

(create-buffer {:keys [capacity overflow-policy]
                :or {capacity 1024 overflow-policy :drop-oldest}})

Creates a bounded queue. WebSocket producer threads are never blocked.

offer! clj

(offer! {:keys [queue overflow-policy statistics]} event)

Offers an event without blocking and returns true when it was retained.

overflow-policies clj

Supported behavior when the bounded queue is full.

poll! clj

(poll! {:keys [queue]} timeout-ms)

Returns the next event, waiting up to timeout-ms; nil means no event.

snapshot clj

(snapshot {:keys [queue capacity overflow-policy statistics]})

Returns non-sensitive queue capacity, depth, policy, and counters.