Liking cljdoc? Tell your friends :D

firestream.core


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

firestream!clj

(firestream! consumer topic)

Subscribe to a topic with realtime updates

Subscribe to a topic with realtime updates
sourceraw docstring

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

pull-topic-data!clj

(pull-topic-data! consumer topic)

Pull data from the topic

Pull data from the topic
sourceraw docstring

rootclj

source

send!clj

(send! producer topic key value)
(send! producer topic key value unique)

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

unsubscribe!clj

(unsubscribe! consumer topic)

Unsubscribe to a topic

Unsubscribe to a topic
sourceraw docstring

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

× close