watermill-sql icon indicating copy to clipboard operation
watermill-sql copied to clipboard

SQL (Postgres/MySQL) Pub/Sub for the Watermill project.

Results 7 watermill-sql issues
Sort by recently updated
recently updated
newest added

Watermill-SQL only actually uses ExecContext and QueryContext, which is all [Ent](https://entgo.io/) provides via the [SQL Raw API](https://entgo.io/docs/feature-flags/#sql-raw-api), I've trimmed the interfaces down so they are compatible.

Adding the [`comfylite3`](https://github.com/davidroman0O/comfylite3) wrapper of [the famous go-sqlite3](https://github.com/mattn/go-sqlite3) driver which compensate the lack of goroutine support by giving the illusion of it. Most other libraries that re-implement the entire sqlite3...

I am opening this draft PR to see if you are interested in this direction for the library (trimming down the interfaces to only what is used). If so I...

Bumps [golang.org/x/text](https://github.com/golang/text) from 0.3.3 to 0.3.8. Commits 434eadc language: reject excessively large Accept-Language strings 23407e7 go.mod: ignore cyclic dependency for tagging b18d3dd secure/precis: replace bytes.Compare with bytes.Equal 795e854 all: replace...

dependencies

Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.0.0-20200622213623-75b288015ac9 to 0.1.0. Commits See full diff in compare view [![Dependabot compatibility score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=golang.org/x/crypto&package-manager=go_modules&previous-version=0.0.0-20200622213623-75b288015ac9&new-version=0.1.0)](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter...

dependencies

#### Data mapping In the current implementation of [subscriber](https://github.com/ThreeDotsLabs/watermill-sql/blob/master/pkg/sql/subscriber.go), it is assumed that funtion `UnmarshalMessage` (SchemaAdapter) is used to extract data from a row. However, in the case of binlog...