PGDeltaStream
A Golang webserver that streams Postgres logical replication changes at-least-once over WebSockets.
What is PGDeltaStream?
PGDeltaStream is a stateless Go service that streams PostgreSQL table changes in real-time over WebSockets using PostgreSQL's logical decoding feature. It provides at-least-once delivery guarantees by allowing clients to take a snapshot of current data and then stream subsequent changes, with the ability to acknowledge offsets to resume from the last consumed position.
Developers and engineers building real-time applications, data pipelines, or event-driven systems that need reliable, low-latency change data capture (CDC) from PostgreSQL databases. It is particularly useful for those implementing custom replication solutions or streaming database events to external services.
Developers choose PGDeltaStream for its simplicity and reliability as a reference implementation of PostgreSQL logical replication in Go, offering a straightforward way to stream database changes with at-least-once delivery without managing persistent state. Its stateless design and built-in snapshot initialization simplify deployment and ensure no event data is lost during client reconnections.
Overview
Streaming Postgres logical replication changes atleast-once over websockets
Use Cases
Best For
Related Projects
Found a gem we're missing?
Open-Awesome is built by the community, for the community. Submit a project, suggest an awesome list, or help improve the catalog on GitHub.
