(events->stream-slice read-direction stream-id ordered-events)
(live-processing-started)
(live-processing-started? {:everest.event/keys [type] :as event})
True if the given event
signifies the start of live processing.
True if the given `event` signifies the start of live processing.
(stream-slice {:keys [direction from next stream events]})
(subscription-started)
(subscription-started? {:everest.event/keys [type] :as event})
True if the given event
signifies the start of subscription.
True if the given `event` signifies the start of subscription.
(subscription-stopped)
(subscription-stopped? {:everest.event/keys [type] :as event})
True if the given event
signifies the end of subscription.
True if the given `event` signifies the end of subscription.
(transient-event {:everest.event/keys [type data metadata timestamp]
:or {data {} metadata {} timestamp (java.util.Date.)}})
Creates a transient event.
Usually this type of even is put!
into the :everest.event/this-stream
of
the subscription stream by the application.
Creates a transient event. Usually this type of even is `put!` into the `:everest.event/this-stream` of the subscription stream by the application.
(transient? {:everest.event/keys [stream] :as event})
True if the given event
is transient.
A transient event is generated by the application. It's not stored in the underlying event store.
True if the given `event` is transient. A transient event is generated by the application. It's not stored in the underlying event store.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close