Guilherme Balena Versiani
Guilherme Balena Versiani
**How to reproduce:** Suppose you have a function containing: ```erlang FirstWatchRequest0 = eetcd_watch:new(), FirstWatchRequest1 = eetcd_watch:with_key(FirstWatchRequest0, Key1), FirstWatchRequest = eetcd_watch:with_prefix(FirstWatchRequest1), {ok, WatchConn, _} = eetcd_watch:watch(EtcdConn, FirstWatchRequest), SecondWatchRequest0 = eetcd_watch:new(), SecondWatchRequest1...
Steps to reproduce: 1. Connect to `etcd`; 2. Interrupt the connectivity, and wait for all connections to timeout/disconnect; 3. Restablish connectivity. **Expected:** `eetcd` reconnects to etcd cluster. **Behavior:** it doesn't...
Adding resiliency to the etcd connections: * While doing health check, detects if active connections list is empty; * If so, restore `freeze_conns` using the `member_list` and reconnect. As aside...
DNS poll, Kubernetes, Kubernetes DNS, Kubernetes DNS SRV and Rancher strategies all don't reconnect nodes case they disconnect for any reason. They need that the backing service discovery also bounces...
So `Swarm.Tracker` can figure out what is intended to happen on `:DOWN` message. Basically the version 3.4.0 this change is based on ignores handoffs when the reason isn’t `:noconnection` (node...
I'm using `Swarm` in a big cluster and I'm always getting the following error in exactly one node: ``` 00:34:51.845 [error] GenStateMachine Swarm.Tracker terminating ** (FunctionClauseError) no function clause matching...
https://github.com/bitwalker/swarm/blob/4aee63d83ad5ee6ee095b38b3ff93a4dbb7c3400/lib/swarm/tracker/tracker.ex#L1187 By definition, `Swarm.Distribution.Strategy.key_to_node/2` can return `node() | :undefined`. However this exact line is actually accepting `{:error, {:invalid_ring, :no_nodes}}` as a valid return value, which is actually what `HashRing.key_to_node/2` returns...
Horde.DynamicSupervisor in active process redistribution clashes with Horde.Registry name conflicts
I've been using `Horde.DynamicSupervisor` along with `Horde.Registry`, whereas the child `id` passed to the dynamic supervisor is unique and it is also registered under another unique name, using a `:via`...
Instead of using `MerkleMap`, the `DeltaCrdt` implementation can use just the `MerkleMap.MerkleTree`. Advantage is a slight reduction in the processing time (~ /2) as it is not needed to insert...
Here is the chumak’s process tree: ``` {your process goes here} | +--------> chumak_socket | | decode_and_send_to_parent(Frame, State). | | +----------> chumak_peer (holds the gen_tcp) ``` `chumak_peer` reads frames from...