Integrate.Replication.Client (IntegrateDB v0.1.0) View Source

Database replication client.

Uses :epgsql for it's start_replication function. Borrows the connection config from the Integrate.Repo is need be. Note that epgsql doesn't support connecting via a unix socket.

Link to this section Summary

Functions

acknowledge_lsn(conn, lsn_tup)

Confirm successful processing of a WAL segment.

connect(config)

Create a database connection.

ensure_replication_slot(conn, slot)

Ensure there is a replication slot called name.

execute(conn, query)

Execute a query / sql statement.

start_replication(conn, publication, slot, handler)

Start consuming logical replication feed using a given publication and slot.

Link to this section Functions

acknowledge_lsn(conn, lsn_tup)

Confirm successful processing of a WAL segment.

Returns :ok on success.

connect(config)

Create a database connection.

Uses the Integrate.Repo config as default, can be overriden by passing in epqsql config directly opts.

Returns {:ok, conn} or {:error, reason}.

ensure_replication_slot(conn, slot)

Ensure there is a replication slot called name.

Returns :ok on success.

execute(conn, query)

Execute a query / sql statement.

Returns {:ok, cols, rows} or {:error, error}.

start_replication(conn, publication, slot, handler)

Start consuming logical replication feed using a given publication and slot.

The handler can be a pid or a module implementing the handle_x_log_data callback.

Returns :ok on success.