hasura/pgdeltastream

Streaming Postgres logical replication changes atleast-once over websockets

pgdeltastream's Issues

Write better tests

Currently the tests written are sort of monolithic. We need to write more specific tests.

Support multi client workflow

The current design supports only a single client. Support needs to be added for multiple clients.

Enable table/schema filtering that is available with wal2json

@sidmutha
Can you link the appropriate docs and provide a rough design of this would be implemented in pgdeltastream?

Set up a build script

A Makefile that builds the binary and docker image and versions using git commits/tags.

Unsafe concurrent use of ReplicationConn

pgx.ReplicationConn consists of a pgx.Conn internally, of which the documentation states:

Conn is a PostgreSQL connection handle. It is not safe for concurrent usage. Use ConnPool to manage access to multiple database connections from multiple goroutines.

In db/lr.go the method sendPeriodicHeartbeats() is accessing the session.ReplConn concurrently with the main loop in LRStream.