diff --git a/elixir/apps/domain/lib/domain/config/definitions.ex b/elixir/apps/domain/lib/domain/config/definitions.ex index 1264e0411..c2c49f77e 100644 --- a/elixir/apps/domain/lib/domain/config/definitions.ex +++ b/elixir/apps/domain/lib/domain/config/definitions.ex @@ -69,7 +69,9 @@ defmodule Domain.Config.Definitions do :database_pool_size, :database_ssl_enabled, :database_ssl_opts, - :database_parameters + :database_parameters, + :database_replication_slot_name, + :database_publication_name ]}, {"Cloud Platform", [ @@ -290,16 +292,6 @@ defmodule Domain.Config.Definitions do """ defconfig(:database_password, :string, default: nil, sensitive: true) - @doc """ - Replication user that will be used to connect to replication slots. - """ - defconfig(:database_replication_user, :string, default: nil, sensitive: true) - - @doc """ - Replication password for the replication user. - """ - defconfig(:database_replication_password, :string, default: nil, sensitive: true) - @doc """ Size of the connection pool to the PostgreSQL database. """ @@ -315,6 +307,16 @@ defmodule Domain.Config.Definitions do """ defconfig(:database_ssl_enabled, :boolean, default: false) + @doc """ + Name of the replication slot used by Firezone. + """ + defconfig(:database_replication_slot_name, :string, default: "events_slot") + + @doc """ + Name of the publication used by Firezone. + """ + defconfig(:database_publication_name, :string, default: "events") + @doc """ SSL options for connecting to the PostgreSQL database. diff --git a/elixir/config/runtime.exs b/elixir/config/runtime.exs index 2888308cb..4d1070426 100644 --- a/elixir/config/runtime.exs +++ b/elixir/config/runtime.exs @@ -29,6 +29,8 @@ if config_env() == :prod do config :domain, Domain.Events.ReplicationConnection, enabled: compile_config!(:background_jobs_enabled), + replication_slot_name: compile_config!(:database_replication_slot_name), + publication_name: compile_config!(:database_publication_name), connection_opts: [ hostname: compile_config!(:database_host), port: compile_config!(:database_port),