diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-02-16 12:13:30 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-02-16 12:13:30 -0800 |
| commit | c29439a8f7fa506e27c28f11cde40a31dba3aef9 (patch) | |
| tree | 32ddf451719f4ad2073c880012d4dd29e9e4299c | |
| parent | 7ce8460a967c08ff836b60900984e6163995c148 (diff) | |
| download | kafka-python-sansio.tar.gz | |
protocol notessansio
| -rw-r--r-- | protocol_notes.txt | 56 |
1 files changed, 56 insertions, 0 deletions
diff --git a/protocol_notes.txt b/protocol_notes.txt new file mode 100644 index 0000000..5d73098 --- /dev/null +++ b/protocol_notes.txt @@ -0,0 +1,56 @@ +state machine + +events = receive_bytes(data) +send(request) +bytes_to_send() + + +current broker connection methods: + + check state: + blacked_out + connected + connecting + disconnected + can_send_more + + connect + close + send + recv + check_version + +connection state transitions: + + connecting + handshake + authenticating + connected + disconnected + handshake + authenticating + connected + disconnected + authenticating + connected + disconnected + connected + disconnected + + + + +consumer: + coordinator_unknown + coordinator_check_pending + coordinator_known + join_group_needed + join_group_pending + join_group_follower + join_group_leader + join_group_sync + group_active + leave_group_pending + + + |