Electric.Replication.ShapeLogCollector (electric v1.2.4)

View Source

When any txn comes from postgres, we need to store it into the log for this shape if and only if it has txid >= xmin of the snapshot.

Summary

Functions

activate_mocked_functions_from_test_process()
active_shapes(server_ref)
child_spec(init_arg)

Returns a specification to start this module under a supervisor.

handle_continue(atom, state)

Callback implementation for GenServer.handle_continue/2.

handle_relation_msg(rel, server)
init(opts)

Callback implementation for GenServer.init/1.

name(stack_id)
notify_flushed(server_ref, shape_handle, offset)
remove_shape(server_ref, shape_handle)
set_last_processed_lsn(server_ref, last_processed_lsn)
start_link(opts)
store_transaction(txn, server)
subscribe(server_ref, shape_handle, shape, atom)

Functions

activate_mocked_functions_from_test_process()

active_shapes(server_ref)

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

handle_continue(atom, state)

Callback implementation for GenServer.handle_continue/2.

handle_relation_msg(rel, server)

init(opts)

Callback implementation for GenServer.init/1.

name(stack_id)

notify_flushed(server_ref, shape_handle, offset)

remove_shape(server_ref, shape_handle)

set_last_processed_lsn(server_ref, last_processed_lsn)

start_link(opts)

store_transaction(txn, server)

subscribe(server_ref, shape_handle, shape, atom)