fix: Listen and ReplicationConnection supervisor setup (#1438)

* fix: Listen and ReplicationConnection supervisor setup

Use the same amount of partitions that Connect has given that they map
1:1

Also move ReplicationConnection and Listen supervisors above Connect as
they need to be up and running before Connect can start

* chore: document CONNECT_PARTITION_SLOTS

It's already used on config/runtime.exs

Author: edgurgel

README.md

@@ -160,6 +160,7 @@ If you're using the default tenant, the URL is `ws://realtime-dev.localhost:4000
 | JANITOR_CLEANUP_CHILDREN_TIMEOUT     | number  | Timeout for each async task for janitor cleanup                                                                                                                                                                                                                                                                                 |
 | JANITOR_CHUNK_SIZE                   | number  | Number of tenants to process per chunk. Each chunk will be processed by a Task                                                                                                                                                                                                                                                  |
 | MIGRATION_PARTITION_SLOTS            | number  | Number of dynamic supervisor partitions used by the migrations process                                                                                                                                                                                                                                                          |
+| CONNECT_PARTITION_SLOTS              | number  | Number of dynamic supervisor partitions used by the Connect, ReplicationConnect and Listen processes                                                                                                                                                                                                                            |
 | METRICS_CLEANER_SCHEDULE_TIMER_IN_MS | number  | Time in ms to run the Metric Cleaner task                                                                                                                                                                                                                                                                                       |
 | REQUEST_ID_BAGGAGE_KEY               | string  | OTEL Baggage key to be used as request id                                                                                                                                                                                                                                                                                       |
 | OTEL_SDK_DISABLED                    | boolean | Disable OpenTelemetry tracing completely when 'true'                                                                                                                                                                                                                                                                            |

lib/realtime/application.ex

@@ -86,11 +86,18 @@ defmodule Realtime.Application do
         {PartitionSupervisor,
          child_spec: DynamicSupervisor,
          strategy: :one_for_one,
-         name: Connect.DynamicSupervisor,
+         name: ReplicationConnection.DynamicSupervisor,
+         partitions: connect_partition_slots},
+        {PartitionSupervisor,
+         child_spec: DynamicSupervisor,
+         strategy: :one_for_one,
+         name: Listen.DynamicSupervisor,
          partitions: connect_partition_slots},
         {PartitionSupervisor,
-         child_spec: DynamicSupervisor, strategy: :one_for_one, name: ReplicationConnection.DynamicSupervisor},
-        {PartitionSupervisor, child_spec: DynamicSupervisor, strategy: :one_for_one, name: Listen.DynamicSupervisor},
+         child_spec: DynamicSupervisor,
+         strategy: :one_for_one,
+         name: Connect.DynamicSupervisor,
+         partitions: connect_partition_slots},
         RealtimeWeb.Endpoint,
         RealtimeWeb.Presence
       ] ++ extensions_supervisors() ++ janitor_tasks()

mix.exs

@@ -4,7 +4,7 @@ defmodule Realtime.MixProject do
   def project do
     [
       app: :realtime,
-      version: "2.57.10",
+      version: "2.57.11",
       elixir: "~> 1.17.3",
       elixirc_paths: elixirc_paths(Mix.env()),
       start_permanent: Mix.env() == :prod,