pgflo / pg_flo

Stream, transform, and route PostgreSQL data in real-time.
https://pgflo.io
Apache License 2.0
664 stars 13 forks source link

Perform DDL operations on target destinations from Sinks #8

Closed shayonj closed 1 month ago

shayonj commented 2 months ago

Postgres sink can look for DDL event type and run that on the target destination. We already do that here but may be it shouldn't block other operations since DDLs can take long?

https://github.com/shayonj/shayonj-pg_flo/blob/f1f4ab8820b90ec40161011bddf6bb9e13f58442/pkg/sinks/postgres.go#L207-L211