d-core.core.stream.protocol — org.clojars.cinguilherme/d-core-async-messaging 0.2.1

StreamBackend clj protocol

append-batch! clj

(append-batch! this stream payloads-bytes)

append-payload! clj

(append-payload! this stream payload-bytes)

get-cursor clj

(get-cursor this key)

list-streams clj

(list-streams this pattern)

next-sequence! clj

(next-sequence! this key)

read-payloads clj

(read-payloads this stream opts)

set-cursor! clj

(set-cursor! this key cursor)

trim-stream! clj

(trim-stream! this stream id)