onyx.triggers

exceeds-percentile-watermark?

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

exceeds-watermark?

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

next-fire-time

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

percentile-watermark

percentile-watermark-fire?

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

punctuation

punctuation-fire?

(punctuation-fire? trigger state state-event)

punctuation-init-locals

(punctuation-init-locals trigger)

punctuation-init-state

(punctuation-init-state trigger)

punctuation-next-state

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

segment

segment-fire?

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

segment-init-state

(segment-init-state _)

segment-next-state

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

timer

timer-fire?

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

timer-init-state

(timer-init-state trigger)

timer-next-state

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

watermark

watermark-fire?

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

watermark-init-locals

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