ha-handler/lib/ha_handler/pgsql/watcher.ex

30 lines
737 B
Elixir
Raw Normal View History

2022-02-19 10:18:05 +01:00
defmodule HAHandler.PGSQL.Watcher do
use GenServer
require Logger
2022-02-19 10:18:05 +01:00
def start_link(opts) do
GenServer.start_link(__MODULE__, opts)
end
2022-02-19 10:18:05 +01:00
@impl true
def init(opts) do
# Starts a Postgrex child but does not means the connection was
# successful.
# TODO: set dbconnections backoff and connect hooks
# See https://github.com/elixir-ecto/db_connection/blob/master/lib/db_connection.ex#L343
{:ok, pid} = Postgrex.start_link(opts)
2022-02-19 10:18:05 +01:00
state = %{
backend: pid,
hostname: Keyword.get(opts, :hostname)
}
2022-02-19 10:18:05 +01:00
{:ok, state}
end
2022-02-19 10:18:05 +01:00
@impl true
def handle_call({:execute, query, params}, _from, %{backend: backend} = state) do
{:reply, Postgrex.query(backend, query, params), state}
end
2022-02-19 10:18:05 +01:00
end