forked from onyx-platform/onyx
-
Notifications
You must be signed in to change notification settings - Fork 0
/
task_state.cljc
51 lines (50 loc) · 1.41 KB
/
task_state.cljc
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
(ns onyx.protocol.task-state)
(defprotocol PTaskStateMachine
(killed? [this])
(start [this])
(stop [this scheduler-event])
(new-iteration? [this])
(advanced? [this])
(next-replica! [this replica])
(next-cycle! [this])
(get-input-pipeline [this])
(get-output-pipeline [this])
(set-replica! [this new-replica])
(set-sealed! [this new-sealed?])
(sealed? [this])
(set-watermark-flag! [this flag])
(watermark-flag? [this])
(get-replica [this])
(get-windows-state [this])
(set-windows-state! [this new-windows-state])
(get-lifecycle [this])
(initial-sync-backoff [this])
(log-state [this])
(heartbeat! [this])
(reset-event! [this])
(set-event! [this new-event])
(evict-peer! [this peer-id])
(update-event! [this f])
(seal-checkpoints! [this] [this replica-version epoch])
(get-event [this])
(set-messenger! [this new-messenger])
(get-messenger [this])
(get-watermark [this])
(process-watermark! [this watermark])
(set-coordinator! [this new-coordinator])
(get-coordinator [this])
(set-context! [this new-context])
(get-context [this])
(set-state-store! [this state-store])
(get-state-store [this])
(replica-version [this])
(epoch [this])
(set-epoch! [this epoch])
(next-epoch! [this])
(goto-recover! [this])
(goto-next-batch! [this])
(goto-next-iteration! [this])
(min-epoch [this])
(set-min-epoch! [this min-epoch])
(exec [this])
(advance [this]))