Liking cljdoc? Tell your friends :D

firestream.core


commit!clj

(commit! consumer offset-map)

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

expiryclj

source

firestream-rootclj

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

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

send-queueclj

source

set-expiryclj

(set-expiry milli)
source

set-rootclj

(set-root new-root)
source

shutdown!clj

(shutdown! producer)

Shutdown producer background thread

Shutdown producer background thread
sourceraw docstring

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