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)