Reliable example / Consumer improvements during Metadata updates (#181)

* reliable client example implementation * WIP: adding a reliable-best pratices example * fixing a bug in consumer happening on metadata update during stream restart * fixing mypy issues * fixed an issue on subscribe during node restart * improving example
qweeze · Apr 10, 2024 · 8f90160 · 8f90160
1 parent a81176a
commit 8f90160
Show file tree

Hide file tree

Showing 17 changed files with 421 additions and 452 deletions.
diff --git a/README.md b/README.md
@@ -259,7 +259,7 @@ Example:
             await producer.reconnect_stream(stream)
 ```
 
-Please take a look at the complete examples [here](https://github.com/qweeze/rstream/blob/master/docs/examples/check_connection_broken/)
+Please take a look at the complete reliable client example [here](https://github.com/qweeze/rstream/blob/master/docs/examples/reliable_client/)
 
 ### Metadata Update
 
@@ -268,7 +268,7 @@ linked to the stream and then it sends the Metadata update event.
 the behaviour is similar to what we have for disconnections. In case of the Producer/Superstream Producer 
 the Client will try to automatically reconnect while the Consumer needs to manage the on_close_handler event.
 
-Please take a look at the complete examples [here](https://github.com/qweeze/rstream/blob/master/docs/examples/metadata_update/)
+Please take a look at the complete reliable client example [here](https://github.com/qweeze/rstream/blob/master/docs/examples/reliable_client/)
 
 ## Load Balancer
 

diff --git a/docs/examples/check_connection_broken/README.md b/docs/examples/check_connection_broken/README.md
diff --git a/docs/examples/check_connection_broken/consumer_handle_connections_issues_with_close.py b/docs/examples/check_connection_broken/consumer_handle_connections_issues_with_close.py
diff --git a/.../examples/check_connection_broken/consumer_handle_connections_issues_with_reconnection.py b/.../examples/check_connection_broken/consumer_handle_connections_issues_with_reconnection.py
diff --git a/docs/examples/check_connection_broken/superstream_consumer_handle_connections_issues.py b/docs/examples/check_connection_broken/superstream_consumer_handle_connections_issues.py
diff --git a/docs/examples/check_connection_broken/superstream_consumer_handle_reconnection.py b/docs/examples/check_connection_broken/superstream_consumer_handle_reconnection.py
diff --git a/docs/examples/metadata_update/README.md b/docs/examples/metadata_update/README.md
diff --git a/docs/examples/metadata_update/super_stream_consumer_metadata_update.py b/docs/examples/metadata_update/super_stream_consumer_metadata_update.py