onyx.messaging.aeron.utils — com.github.clojure-finance/onyx 0.16.0

action->kw clj

(action->kw action)

channel clj

(channel peer-config)

(channel addr port)

(channel addr port term-length)

heartbeat-stream-id clj

image->map clj

(image->map image)

max-aeron-message-length clj

(max-aeron-message-length peer-config)

short-circuit? clj

(short-circuit? peer-config site)

stream-id clj

(stream-id task-id slot-id site)

try-close-conn clj

(try-close-conn conn)

try-close-publication clj

(try-close-publication publication)

try-close-subscription clj

(try-close-subscription subscription)