Liking cljdoc? Tell your friends :D
All platforms.
onyx.protocol.task-state
PTaskStateMachineclj/s≠protocol
update-event!clj/s
(update-event! this f)get-input-pipelineclj/s
(get-input-pipeline this)next-epoch!clj/s
(next-epoch! this)process-watermark!clj/s
(process-watermark! this watermark)set-epoch!clj/s
(set-epoch! this epoch)heartbeat!clj/s
(heartbeat! this)get-output-pipelineclj/s
(get-output-pipeline this)get-eventclj/s
(get-event this)advanced?clj/s
(advanced? this)set-event!clj/s
(set-event! this new-event)goto-recover!clj/s
(goto-recover! this)advanceclj/s
(advance this)next-cycle!clj/s
(next-cycle! this)log-stateclj/s
(log-state this)epochclj/s
(epoch this)set-min-epoch!clj/s
(set-min-epoch! this min-epoch)set-context!clj/s
(set-context! this new-context)replica-versionclj/s
(replica-version this)initial-sync-backoffclj/s
(initial-sync-backoff this)watermark-flag?clj/s
(watermark-flag? this)execclj/s
(exec this)get-coordinatorclj/s
(get-coordinator this)set-watermark-flag!clj/s
(set-watermark-flag! this flag)min-epochclj/s
(min-epoch this)seal-checkpoints!clj/s
(seal-checkpoints! this)(seal-checkpoints! this replica-version epoch)set-messenger!clj/s
(set-messenger! this new-messenger)startclj/s
(start this)next-replica!clj/s
(next-replica! this replica)set-coordinator!clj/s
(set-coordinator! this new-coordinator)get-replicaclj/s
(get-replica this)get-contextclj/s
(get-context this)get-messengerclj/s
(get-messenger this)get-state-storeclj/s
(get-state-store this)set-replica!clj/s
(set-replica! this new-replica)get-watermarkclj/s
(get-watermark this)set-windows-state!clj/s
(set-windows-state! this new-windows-state)killed?clj/s
(killed? this)stopclj/s
(stop this scheduler-event)sealed?clj/s
(sealed? this)goto-next-iteration!clj/s
(goto-next-iteration! this)set-sealed!clj/s
(set-sealed! this new-sealed?)goto-next-batch!clj/s
(goto-next-batch! this)set-state-store!clj/s
(set-state-store! this state-store)new-iteration?clj/s
(new-iteration? this)evict-peer!clj/s
(evict-peer! this peer-id)get-windows-stateclj/s
(get-windows-state this)reset-event!clj/s
(reset-event! this)get-lifecycleclj/s
(get-lifecycle this)cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close