View Source Electric.Replication.ShapeLogCollector (electric v1.0.0-beta.2)

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

handle_call(arg, from, state)

Callback implementation for GenStage.handle_call/3.

handle_cancel(arg, from, state)

Callback implementation for GenStage.handle_cancel/3.

handle_demand(demand, state)

Callback implementation for GenStage.handle_demand/2.

handle_relation_msg(rel, server)

handle_subscribe(atom, opts, from, state)

Callback implementation for GenStage.handle_subscribe/4.

init(opts)

Callback implementation for GenStage.init/1.

name(stack_id)

start_link(opts)

store_transaction(txn, server)

Functions

handle_call(arg, from, state)

Callback implementation for GenStage.handle_call/3.

handle_cancel(arg, from, state)

Callback implementation for GenStage.handle_cancel/3.

handle_demand(demand, state)

Callback implementation for GenStage.handle_demand/2.

handle_relation_msg(rel, server)

handle_subscribe(atom, opts, from, state)

Callback implementation for GenStage.handle_subscribe/4.

init(opts)

Callback implementation for GenStage.init/1.

name(stack_id)

start_link(opts)

store_transaction(txn, server)