trellis-pg

https://github.com/salesforce-misc/trellis

A native extension over the trellis crate's BlockingTrellis, so a Rails app can define and run Trellis's streaming transforms in its own process, against its own Postgres database, without deploying a separate service.