firestream.core — alekcz/firestream 0.6.0

channel-len clj

commit! clj

(commit! consumer topic firestream-object)

Update offset for consumer in particular topic

consumer clj

(consumer config)

Create a consumer

deserialize-data clj

(deserialize-data raw)

distinct-and-ordered clj

(distinct-and-ordered coll)

firestream! clj

(firestream! consumer topic)

Subscribe to a topic with realtime updates

poll! clj

(poll! consumer timeout)

Read data from subscription

producer clj

(producer config)

Create a producer

pull-topic-data! clj

(pull-topic-data! consumer topic)

Pull data from the topic

root clj

send! clj

(send! producer topic key value)

(send! producer topic key value unique)

Send new message to topic

serialize-data clj

(serialize-data topic key data)

set-root clj

(set-root new-root)

shutdown! clj

(shutdown! consumer)

subscribe! clj

(subscribe! consumer topic)

Subscribe to a topic

unsubscribe! clj

(unsubscribe! consumer topic)

Unsubscribe to a topic