View Source Electric.Postgres.ReplicationClient.ConnectionSetup (electric v0.9.5)

This module encapsulates the initial setup of a replication connection opened by Electric.Postgres.ReplicationClient.

A state machine is implemented to run a series of SQL queries prior to switching the connection into the logical streaming mode. This helps keep the main ReplicationClient module focused on the handling of logical messages.

Summary

Types

callback_return()
query_result()
state()
step()

Functions

process_query_result(result, state)
start(state)
start_streaming(state)

Types

Link to this type

callback_return()

View Source 
@type callback_return() ::
  {:noreply, state()}
  | {:query, iodata(), state()}
  | {:stream, iodata(), Postgrex.ReplicationConnection.stream_opts(), state()}
Link to this type

query_result()

View Source 
@type query_result() :: [Postgrex.Result.t()] | Postgrex.Error.t()
Link to this type

state()

View Source 
@type state() :: Electric.Postgres.ReplicationClient.State.t()
Link to this type

step()

View Source 
@type step() :: Electric.Postgres.ReplicationClient.step()

Functions

Link to this function

process_query_result(result, state)

View Source 
@spec process_query_result(query_result(), state()) :: callback_return()
Link to this function

start(state)

View Source 
@spec start(state()) :: callback_return()
Link to this function

start_streaming(state)

View Source 
@spec start_streaming(state()) :: callback_return()