Liking cljdoc? Tell your friends :D

firestream.core


BUFFER-SIZEclj

source

channel-lenclj

source

commit!clj

(commit! consumer topic firestream-object)

Update offset for consumer in particular topic

Update offset for consumer in particular topic
sourceraw docstring

consumerclj

(consumer config)

Create a consumer

Create a consumer
sourceraw docstring

deserialize-dataclj

(deserialize-data raw)
source

distinct-and-orderedclj

(distinct-and-ordered coll)
source

poll!clj

(poll! consumer timeout)

Read data from subscription

Read data from subscription
sourceraw docstring

producerclj

(producer config)

Create a producer

Create a producer
sourceraw docstring

rootclj

source

send!clj

(send! producer topic key value)

Send new message to topic

Send new message to topic
sourceraw docstring

serialize-dataclj

(serialize-data topic key data)
source

set-rootclj

(set-root new-root)
source

shutdown!clj

(shutdown! consumer)
source

subscribe!clj

(subscribe! consumer topic)

Subscribe to a topic

Subscribe to a topic
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close