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
Callback implementation for GenStage.handle_call/3
.
Callback implementation for GenStage.handle_cancel/3
.
Callback implementation for GenStage.handle_demand/2
.
Callback implementation for GenStage.handle_subscribe/4
.
Callback implementation for GenStage.init/1
.
Functions
Callback implementation for GenStage.handle_call/3
.
Callback implementation for GenStage.handle_cancel/3
.
Callback implementation for GenStage.handle_demand/2
.
Callback implementation for GenStage.handle_subscribe/4
.
Callback implementation for GenStage.init/1
.