supabase / realtime / c4ba2aa63901dd2a48affdf60b2d20b3398b8e55

88%

push

github

feat: gen_rpc pub sub adapter (#1529)

Add a PubSub adapter that uses gen_rpc to send messages to other nodes.

It uses :gen_rpc.abcast/3 instead of :erlang.send/2

The adapter works very similarly to the PG2 adapter. It consists of
multiple workers that forward to the local node using PubSub.local_broadcast.

The way to choose the worker to be used is based on the sending process
just like PG2 adapter does

The number of workers is controlled by `:pool_size` or `:broadcast_pool_size`.
This distinction exists because Phoenix.PubSub uses `:pool_size` to
define how many partitions the PubSub registry will use. It's possible
to control them separately by using `:broadcast_pool_size`

27 of 28 new or added lines in 3 files covered. (96.43%)

2066 of 2421 relevant lines covered (85.34%)

2500.34 hits per line