Marco Primi

- Wait for all routines (producers, consumers, chaos) to complete before checking stream state - Avoid leaking routines - Minor comment enhancements Signed-off-by: Marco Primi

Stuck forever in `down` command (despite `shutdown.timeout_seconds`)

5

This is a follow-up to https://github.com/F1bonacc1/process-compose/issues/251 where i was seeing call to `list` getting stuck. Since then I have added a `shutdown.timeout_seconds` parameter to ensure timely shutdown. However I am...

Sample data in Quickstart guide lacks timestamp

2

### Which OpenObserve functionalities are the source of the bug? Don't known / other ### Is this a regression? No ### Description The sample data provided in the [quickstart](https://openobserve.ai/docs/quickstart/) does...

Multi-threaded use of subscription may result in server spamming

3

### Proposed change `(*Subscription).Fetch` is thread safe, but not "multithread-friendly". Suppose an application implements the following logic: ``` // pseudo-go numThreads = 2 for i in numThreads { go func()...

Document `Subscription` (and possibly other types) as thread-safe

1

### Proposed change `Subscription` (and probably) other types, are thread safe. This is great, it simplifies multi-threaded application code which does not need to provide its own locking. e.g. ```...

Support for multiple keys as described in the README is currently broken, add a warning to anyone attempting to use it. Hopefully this can be reverted at some point in...

Recovering from `ClusterClient` that reaches status `CLOSED`

3

I'm evaluating and experimenting with Aeron Cluster, my code is based on the [cluster-rsm example from the Cookbook](https://github.com/aeron-io/aeron-cookbook-code/tree/main/cluster-rsm) . Specifically I am investigating resilience and recovery in the presence of...