File tree 1 file changed +56
-0
lines changed
1 file changed +56
-0
lines changed Original file line number Diff line number Diff line change
1
+ state machine
2
+
3
+ events = receive_bytes(data)
4
+ send(request)
5
+ bytes_to_send()
6
+
7
+
8
+ current broker connection methods:
9
+
10
+ check state:
11
+ blacked_out
12
+ connected
13
+ connecting
14
+ disconnected
15
+ can_send_more
16
+
17
+ connect
18
+ close
19
+ send
20
+ recv
21
+ check_version
22
+
23
+ connection state transitions:
24
+
25
+ connecting
26
+ handshake
27
+ authenticating
28
+ connected
29
+ disconnected
30
+ handshake
31
+ authenticating
32
+ connected
33
+ disconnected
34
+ authenticating
35
+ connected
36
+ disconnected
37
+ connected
38
+ disconnected
39
+
40
+
41
+
42
+
43
+ consumer:
44
+ coordinator_unknown
45
+ coordinator_check_pending
46
+ coordinator_known
47
+ join_group_needed
48
+ join_group_pending
49
+ join_group_follower
50
+ join_group_leader
51
+ join_group_sync
52
+ group_active
53
+ leave_group_pending
54
+
55
+
56
+
You can’t perform that action at this time.
0 commit comments