fix: provide socket_options to Postgres libcluster strategy (#1471)

edgurgel · web-flow · commit 119cd54b47f1 · 2025-07-22T15:03:14.000+12:00
diff --git a/config/runtime.exs b/config/runtime.exs
@@ -278,6 +278,7 @@ cluster_topologies =
               parameters: [
                 application_name: "cluster_node_#{node()}"
               ],
+              socket_options: socket_options,
               heartbeat_interval: 5_000,
               node_timeout: 15_000,
               channel_name: System.get_env("POSTGRES_CLUSTER_CHANNEL_NAME", "realtime_cluster_#{version}")
diff --git a/lib/realtime/cluster_strategy/postgres.ex b/lib/realtime/cluster_strategy/postgres.ex
@@ -29,6 +29,7 @@ defmodule Realtime.Cluster.Strategy.Postgres do
       database: Keyword.fetch!(state.config, :database),
       port: Keyword.fetch!(state.config, :port),
       parameters: Keyword.fetch!(state.config, :parameters),
+      socket_options: Keyword.fetch!(state.config, :socket_options),
       channel_name: Keyword.fetch!(state.config, :channel_name)
     ]
 
diff --git a/mix.exs b/mix.exs
@@ -4,7 +4,7 @@ defmodule Realtime.MixProject do
   def project do
     [
       app: :realtime,
-      version: "2.41.3",
+      version: "2.41.4",
       elixir: "~> 1.17.3",
       elixirc_paths: elixirc_paths(Mix.env()),
       start_permanent: Mix.env() == :prod,
diff --git a/test/realtime/cluster_strategy/postgres_test.exs b/test/realtime/cluster_strategy/postgres_test.exs
@@ -49,6 +49,7 @@ defmodule Realtime.Cluster.Strategy.PostgresTest do
       parameters: [
         application_name: "#{node()}"
       ],
+      socket_options: [:inet],
       heartbeat_interval: 5_000,
       node_timeout: 15_000,
       channel_name: "test_channel_name"

Original file line number	Diff line number	Diff line change
`@@ -29,6 +29,7 @@ defmodule Realtime.Cluster.Strategy.Postgres do`
`29`	`29`	`database: Keyword.fetch!(state.config, :database),`
`30`	`30`	`port: Keyword.fetch!(state.config, :port),`
`31`	`31`	`parameters: Keyword.fetch!(state.config, :parameters),`
	`32`	`+ socket_options: Keyword.fetch!(state.config, :socket_options),`
`32`	`33`	`channel_name: Keyword.fetch!(state.config, :channel_name)`
`33`	`34`	`]`
`34`	`35`
Original file line number	Diff line number	Diff line change
`@@ -4,7 +4,7 @@ defmodule Realtime.MixProject do`
`4`	`4`	`def project do`
`5`	`5`	`[`
`6`	`6`	`app: :realtime,`
`7`		`- version: "2.41.3",`
	`7`	`+ version: "2.41.4",`
`8`	`8`	`elixir: "~> 1.17.3",`
`9`	`9`	`elixirc_paths: elixirc_paths(Mix.env()),`
`10`	`10`	`start_permanent: Mix.env() == :prod,`