Liking cljdoc? Tell your friends :D
Clojure only.

crux.tx.consumer

index-recordsclj

(index-records indexer records)
source

OffsetBasedQueuecljprotocol

next-events-from-offsetclj

(next-events-from-offset this offset)
source

Offsetscljprotocol

read-offsetsclj

(read-offsets this)

store-offsetsclj

(store-offsets this offsets)
source

offsets-based-queueclj

(offsets-based-queue indexer q)
source

Queuecljprotocol

mark-processedclj

(mark-processed this records)

next-eventsclj

(next-events this)
source

start-indexing-consumerclj

(start-indexing-consumer {:keys [idle-sleep-ms queue accept-fn index-fn]})
source

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts
Ctrl+kJump to recent docs
←Move to previous article
→Move to next article
Ctrl+/Jump to the search field
Raise an issueBrowse cljdoc sourceChat on Slack
× close