Logical Replication

A project to play with and test Postgres logical replication using Rust.

Why

Logical replication gives the ability to subscribe to the Postgres write-ahead-log messages and decode them into usable (and transactional) data. There are many uses for this functionality, for example:

• a web server could store (and invalidate) a local cache of a table in a database to prevent a database round-trip.
• a notification could be sent to a user as a result of an action by another user connected to a different web server instance.

Logical replication is lower level than the Postgres LISTEN functionality, causes no performance impact and does not require the user to choose which tables to listen to.

What

The main test is in types/mod.rs.

This test attempts to perform deterministic simulation by first attaching the logicalreplication listener to an empty database then:

1. Deterministically produce random batches of transactions against an in-memory representation of the table.
2. Applying the batched transactions to the Postgres database.
3. Listening to the logical replication stream and trying to apply them to a second in-memory representation of the table.
4. Stopping the test after n iterations and then testing that all three representations align.

How

1. Start postgres with logical replication mode - see the docker-compose.yaml and the Dockerfile for configuration.
2. Run cargo install sqlx-cli to set up the sqlx command line utility to allow database migrations.
3. Run sqlx migrate run to set up the intial database.
4. Run cargo test.

Further

Ideas of what would be helpful:

• It would be good to build a procedural macro similar to structmap which automates the generation of applying what is received from the logical decoding (effectively a vector of hashmaps) directly to structs.

• This version deliberately chooses decoderbufs but work could be done to ensure it works with wal2json too and that output data is standardised.

Acknowledgements

Thank you to:

• rust-postgres: rust-postgres/rust-postgres#116
• Materialize's fork of rust-postgres with the patches required to support logical decoding: https://github.com/MaterializeInc/rust-postgres
• postgres-decoderbufs: https://github.com/debezium/postgres-decoderbufs
• this example: https://github.com/debate-map/app/blob/afc6467b6c6c961f7bcc7b7f901f0ff5cd79d440/Packages/app-server-rs/src/pgclient.rs