onyx.protocol.task-state
PTaskStateMachine
protocol
members
advance
(advance this)advanced?
(advanced? this)epoch
(epoch this)evict-peer!
(evict-peer! this peer-id)exec
(exec this)get-context
(get-context this)get-coordinator
(get-coordinator this)get-event
(get-event this)get-input-pipeline
(get-input-pipeline this)get-lifecycle
(get-lifecycle this)get-messenger
(get-messenger this)get-output-pipeline
(get-output-pipeline this)get-replica
(get-replica this)get-state-store
(get-state-store this)get-watermark
(get-watermark this)get-windows-state
(get-windows-state this)goto-next-batch!
(goto-next-batch! this)goto-next-iteration!
(goto-next-iteration! this)goto-recover!
(goto-recover! this)heartbeat!
(heartbeat! this)initial-sync-backoff
(initial-sync-backoff this)killed?
(killed? this)log-state
(log-state this)min-epoch
(min-epoch this)new-iteration?
(new-iteration? this)next-cycle!
(next-cycle! this)next-epoch!
(next-epoch! this)next-replica!
(next-replica! this replica)process-watermark!
(process-watermark! this watermark)replica-version
(replica-version this)reset-event!
(reset-event! this)seal-checkpoints!
(seal-checkpoints! this)(seal-checkpoints! this replica-version epoch)sealed?
(sealed? this)set-context!
(set-context! this new-context)set-coordinator!
(set-coordinator! this new-coordinator)set-epoch!
(set-epoch! this epoch)set-event!
(set-event! this new-event)set-messenger!
(set-messenger! this new-messenger)set-min-epoch!
(set-min-epoch! this min-epoch)set-replica!
(set-replica! this new-replica)set-sealed!
(set-sealed! this new-sealed?)set-state-store!
(set-state-store! this state-store)set-watermark-flag!
(set-watermark-flag! this flag)set-windows-state!
(set-windows-state! this new-windows-state)start
(start this)stop
(stop this scheduler-event)update-event!
(update-event! this f)watermark-flag?
(watermark-flag? this)