Packages
electric
0.8.0
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 connection supervisor is a rest-for-one supervisor that starts `Connection.Manager`,
followed by `Shapes.Supervisor`.
Connection.Manager monitors all of the connection process that it starts and if any one of
the goes down with a critical error (such as Postgres shutting down), the connection manager
itself will shut down. This will cause the shutdown of Shapes.Supervisor, due to the nature
of the rest-for-one supervision strategy, and, since the latter supervisor is started as a
`temporary` child of the connection supervisor, it won't be restarted until its child spec is
re-added by a new call to `start_shapes_supervisor/0`.
This supervision design is deliberate: none of the "shapes" processes can function without a
working DB pool and we only have a DB pool when the Connection.Manager process can see that
all of its database connections are healthy. Connection.Manager tries to reopen connections
when they are closed, with an exponential backoff, so it is the first process to know when a
connection has been restored and it's also the one that starts Shapes.Supervisor once it
has successfully initialized a database connection pool.
"""
use Supervisor
def name(electric_instance_id, tenant_id) do
Electric.Application.process_name(electric_instance_id, tenant_id, __MODULE__)
end
def name(opts) do
electric_instance_id = Access.fetch!(opts, :electric_instance_id)
tenant_id = Access.fetch!(opts, :tenant_id)
name(electric_instance_id, tenant_id)
end
def start_link(opts) do
Supervisor.start_link(__MODULE__, opts, name: name(opts))
end
def init(opts) do
Supervisor.init([{Electric.Connection.Manager, opts}], strategy: :rest_for_one)
end
def start_shapes_supervisor(opts) do
electric_instance_id = Keyword.fetch!(opts, :electric_instance_id)
tenant_id = Keyword.fetch!(opts, :tenant_id)
shape_cache_opts = Keyword.fetch!(opts, :shape_cache_opts)
inspector = Keyword.fetch!(shape_cache_opts, :inspector)
shape_cache_spec = {Electric.ShapeCache, shape_cache_opts}
shape_log_collector_spec =
{Electric.Replication.ShapeLogCollector,
electric_instance_id: electric_instance_id, tenant_id: tenant_id, inspector: inspector}
child_spec =
Supervisor.child_spec(
{
Electric.Shapes.Supervisor,
electric_instance_id: electric_instance_id,
tenant_id: tenant_id,
shape_cache: shape_cache_spec,
log_collector: shape_log_collector_spec
},
restart: :temporary
)
Supervisor.start_child(name(opts), child_spec)
end
end