Daniil Fedotov

Timeout in state 'timeout'

1

Sometimes, when database is slow and number of requests is big psql_connection is crushing because of message 'timeout' got in state 'timeout'. Is it a valid behaviour? I am using...

Stream client components could use some documentation Stream protocol documentation: https://github.com/ockam-network/proposals/tree/main/design/0009-stream-protocol Example stream client usage: https://github.com/ockam-network/ockam/blob/develop/implementations/elixir/ockam/ockam/lib/ockam/examples/stream/stream.ex

Connection recovery helper.

9

The helper function to simplify connection recovery via event emitter. This function uses a callback, which can be called multiple times, hence cannot be promisified. TODO: - [x] Multiple hosts...

Document connection recovery.

2

Add a section to docs to explain connection recovery and use of a connection recovery helper.

Handle rabbit_delayed_message restarts.

1

If the `rabbit_delayed_message` process is restarted, a timer is not being started automatically until `go` is called or a new message is scheduled for delay. This can cause significant delays...

If a state machine is using external mutable state emitting `{release_cursor, Index, State}` does not make much sense. Especially because effects will be processed after a batch of commands are...

Named monitors

6

Since monitors are supposed to be effects, it's not possible to take a monitor reference and save it in the state. When a machine needs to monitor more than one...

Deserializer error. Seems to be trying to deserialize not serialized data

1

I'm occasionally getting the following error on my test servers when starting consumer group manager: ```Elixir {:error, { %RuntimeError{ message: "Parse error during %Kayrock.ApiVersions.V0.Request{client_id: \"kafka_ex\", correlation_id: 0} response deserializer. Couldn't...

Support TCP keepalive for TCP clients

5

Current implementations of TCP clients need to rely on ad-hoc heartbeats in order to keep the TCP connection open. Those heartbeats are implemented as empty Ockam Routing messages, which is...

There are two functions defined in `Ockam.TypedCBOR` for encoding: `encode` and `encode!`. Former is calling `wrap_exception(&encode!...` which will return `{:error, reason}` if there is an exception in `encode!` instead of...