onyx.triggers — org.onyxplatform/onyx 0.14.6

exceeds-percentile-watermark? clj/s

(exceeds-percentile-watermark? window
                               trigger
                               lower-extent-bound
                               upper-extent-bound
                               segment)

exceeds-watermark? clj/s

(exceeds-watermark? window upper-extent-bound segment)

next-fire-time clj/s

(next-fire-time {:keys [trigger/period] :as trigger})

percentile-watermark clj/s

percentile-watermark-fire? clj/s

(percentile-watermark-fire? trigger
                            _
                            {:keys [lower-bound upper-bound event-type segment
                                    window]})

punctuation clj/s

punctuation-fire? clj/s

(punctuation-fire? trigger state state-event)

punctuation-init-locals clj/s

(punctuation-init-locals trigger)

punctuation-init-state clj/s

(punctuation-init-state trigger)

punctuation-next-state clj/s

(punctuation-next-state trigger state state-event)

segment clj/s

segment-fire? clj/s

(segment-fire? {:keys [trigger/threshold] :as trigger}
               trigger-state
               {:keys [event-type] :as state-event})

segment-init-state clj/s

(segment-init-state _)

segment-next-state clj/s

(segment-next-state {:keys [trigger/threshold]}
                    state
                    {:keys [event-type] :as state-event})

timer clj/s

timer-fire? clj/s

(timer-fire? trigger [fire? _] state-event)

timer-init-state clj/s

(timer-init-state trigger)

timer-next-state clj/s

(timer-next-state {:keys [trigger/period] :as trigger}
                  [_ fire-time]
                  {:keys [event-type] :as state-event})

watermark clj/s

watermark-fire? clj/s

(watermark-fire? trigger
                 _
                 {:keys [event-type upper-bound watermarks] :as state-event})

watermark-init-locals clj/s

(watermark-init-locals {:keys [trigger/delay]})