View Source Electric.Replication.ShapeLogCollector (electric v0.9.5)

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

Link to this function

handle_call(arg, from, state)

View Source

Callback implementation for GenStage.handle_call/3.

Link to this function

handle_cancel(arg, from, state)

View Source

Callback implementation for GenStage.handle_cancel/3.

Link to this function

handle_demand(demand, state)

View Source

Callback implementation for GenStage.handle_demand/2.

Link to this function

handle_relation_msg(rel, server)

View Source
Link to this function

handle_subscribe(atom, opts, from, state)

View Source

Callback implementation for GenStage.handle_subscribe/4.

Callback implementation for GenStage.init/1.

Link to this function

store_transaction(txn, server)

View Source