onyx.types

->MonitorEvent

(->MonitorEvent event)
Positional factory function for class onyx.types.MonitorEvent.

->MonitorEventBytes

(->MonitorEventBytes event bytes)
Positional factory function for class onyx.types.MonitorEventBytes.

->MonitorEventLatency

(->MonitorEventLatency event latency)
Positional factory function for class onyx.types.MonitorEventLatency.

->MonitorEventLatencyBytes

(->MonitorEventLatencyBytes event latency bytes)
Positional factory function for class onyx.types.MonitorEventLatencyBytes.

->MonitorTaskEventCount

(->MonitorTaskEventCount event count)
Positional factory function for class onyx.types.MonitorTaskEventCount.

->Result

(->Result root leaves)
Positional factory function for class onyx.types.Result.

->Route

(->Route flow exclusions post-transformation action pred-failure)
Positional factory function for class onyx.types.Route.

->StateEvent

(->StateEvent event-type task-event segment grouped? group-key lower-bound upper-bound log-type trigger-update aggregation-update window next-state)
Positional factory function for class onyx.types.StateEvent.

->TriggerState

(->TriggerState window-id refinement on sync fire-all-extents? state pred watermark-percentage doc period threshold sync-fn id idx init-state create-state-update apply-state-update pre-evictor post-evictor state-context-trigger? & overage)
Positional factory function for class onyx.types.TriggerState.

barrier

(barrier replica-version epoch short-id)

barrier-id

checkpointed-state-event

(checkpointed-state-event task-event replica-version epoch checkpointed)

heartbeat

(heartbeat replica-version epoch src-peer-id dst-peer-id session-id short-id)

heartbeat-id

map->MonitorEvent

(map->MonitorEvent m__6522__auto__)
Factory function for class onyx.types.MonitorEvent, taking a map of keywords to field values.

map->MonitorEventBytes

(map->MonitorEventBytes m__6522__auto__)
Factory function for class onyx.types.MonitorEventBytes, taking a map of keywords to field values.

map->MonitorEventLatency

(map->MonitorEventLatency m__6522__auto__)
Factory function for class onyx.types.MonitorEventLatency, taking a map of keywords to field values.

map->MonitorEventLatencyBytes

(map->MonitorEventLatencyBytes m__6522__auto__)
Factory function for class onyx.types.MonitorEventLatencyBytes, taking a map of keywords to field values.

map->MonitorTaskEventCount

(map->MonitorTaskEventCount m__6522__auto__)
Factory function for class onyx.types.MonitorTaskEventCount, taking a map of keywords to field values.

map->Result

(map->Result m__6522__auto__)
Factory function for class onyx.types.Result, taking a map of keywords to field values.

map->Route

(map->Route m__6522__auto__)
Factory function for class onyx.types.Route, taking a map of keywords to field values.

map->StateEvent

(map->StateEvent m__6522__auto__)
Factory function for class onyx.types.StateEvent, taking a map of keywords to field values.

map->TriggerState

(map->TriggerState m__6522__auto__)
Factory function for class onyx.types.TriggerState, taking a map of keywords to field values.

max-control-message-size

message

(message replica-version short-id payload)

message-id

new-state-event

(new-state-event event-type task-event replica-version epoch)

ready

(ready replica-version src-peer-id short-id)

ready-id

ready-reply

(ready-reply replica-version src-peer-id dst-peer-id session-id short-id)

ready-reply-id