Packages
electric
1.7.3
1.7.8
1.7.7
1.7.6
1.7.5
1.7.4
1.7.3
1.7.2
1.7.1
1.7.0
1.6.10
1.6.9
1.6.8
1.6.7
1.6.6
1.6.5
1.6.4
1.6.3
1.6.2
1.6.1
1.6.0
1.5.1
1.5.0
1.4.16
1.4.16-beta-1
1.4.15
1.4.14
1.4.13
1.4.12
1.4.11
1.4.10
1.4.8
1.4.7
1.4.6
1.4.5
1.4.4
1.4.3
1.4.2
1.4.1
1.4.0
1.3.4
1.3.3
1.3.2
1.2.4
1.2.3
1.2.2
1.2.1
1.2.0
1.1.14
1.1.13
1.1.12
1.1.11
1.1.10
1.1.9
1.1.8
1.1.7
1.1.6
retired
1.1.5
retired
1.1.4
retired
1.1.3
retired
1.1.2
1.1.1
1.1.0
1.0.24
1.0.23
1.0.22
1.0.21
1.0.20
1.0.19
1.0.18
1.0.17
1.0.15
1.0.13
1.0.12
1.0.11
1.0.10
1.0.9
1.0.5
1.0.4
1.0.3
1.0.2
1.0.1
1.0.0
1.0.0-beta.23
1.0.0-beta.22
1.0.0-beta.20
1.0.0-beta.19
1.0.0-beta.18
1.0.0-beta.17
1.0.0-beta.16
1.0.0-beta.15
1.0.0-beta.14
1.0.0-beta.13
1.0.0-beta.12
1.0.0-beta.11
1.0.0-beta.10
1.0.0-beta.9
1.0.0-beta.8
1.0.0-beta.7
1.0.0-beta.6
1.0.0-beta.5
1.0.0-beta.4
1.0.0-beta.3
1.0.0-beta.2
1.0.0-beta.1
0.9.5
0.9.4
0.9.3
0.9.2
0.9.1
0.9.0
0.8.1
0.8.0
0.7.7
0.7.6
0.7.5
0.7.4
0.7.3
0.7.2
0.7.1
0.7.0
0.6.3
0.6.2
0.6.1
0.5.2
0.4.4
Postgres sync engine. Sync little subsets of your Postgres data into local apps and services.
Current section
Files
Jump to
Current section
Files
lib/electric/connection/supervisor.ex
defmodule Electric.Connection.Supervisor do
@moduledoc """
The main connection supervisor that looks after Connection.Manager.
It starts Connection.Manager.Supervisor which then directly supervises
Connection.Manager and ConnectionResolver processes.
Connection.Manager acts a bit like a supervisor for database connection processes:
- it opens database connections in the right order
- restarts them during initialization if they fail for recoverable reasons
- restarts the replication client at any point if it crashes due to a non-fatal error
- coordinates with CoreSupervisor to start the Shapes.Supervisor at the right point
in time, passing it the right set of options that have been informed by connection
manager's own initialization sequence up to that point
If a database connection shuts down due to a non-recoverable error, the connection manager
process will ask this supervisor to shut down, which in the single-tenant mode results in the
whole OTP application shutting down.
"""
# The `restart: :transient, significant: true` combo allows for shutting the supervisor down
# and signalling the parent supervisor to shut itself down as well if that one has
# `:auto_shutdown` set to `:any_significant` or `:all_significant`.
use Supervisor, restart: :transient, significant: true
require Logger
def name(stack_ref) do
Electric.ProcessRegistry.name(stack_ref, __MODULE__)
end
def start_link(opts) do
Supervisor.start_link(__MODULE__, opts, name: name(opts))
end
def shutdown(stack_id, %Electric.DbConnectionError{} = reason) do
if Application.get_env(:electric, :start_in_library_mode, true) do
# Log a warning as these errors are to be expected if the stack has been
# misconfigured or if the database is not available.
Logger.warning(
"Stopping connection supervisor with stack_id=#{inspect(stack_id)} " <>
"due to an unrecoverable error: #{reason.message}"
)
else
# Log an emergency error in the standalone mode, as the application cannot procede and will be shut down.
Logger.emergency(reason.message)
end
Supervisor.stop(name(stack_id: stack_id), {:shutdown, reason}, 1_000)
end
def init(opts) do
stack_id = Keyword.fetch!(opts, :stack_id)
Process.set_label({:connection_supervisor, stack_id})
Logger.metadata(stack_id: stack_id)
Electric.Telemetry.Sentry.set_tags_context(stack_id: stack_id)
children = [
{Electric.Connection.Restarter,
stack_id: stack_id, stack_events_registry: Keyword.fetch!(opts, :stack_events_registry)},
{Electric.Connection.Manager.Supervisor, opts}
]
Supervisor.init(children, strategy: :rest_for_one)
end
end