onyx.state.serializers.utils — org.onyxplatform/onyx 0.14.3

build-coders clj

(build-coders group-idx
              group-reverse-idx
              window-definitions
              trigger-definitions)

equals clj

(equals bs1 bs2)

event->state-serializers clj

(event->state-serializers
  {:keys [onyx.core/task-map onyx.core/windows onyx.core/triggers] :as event})

get-trigger-coder clj

(get-trigger-coder {:keys [grouped?] :as w})

get-window-coder clj

(get-window-coder {:keys [grouped? extent idx entry-idx] :as w})

instantiate clj

(instantiate {:keys [idx entry-idx] :as w})

max-window-key-size-bytes clj

state-serializers clj

(state-serializers grouped? windows triggers)