superfly / corrosion

Gossip-based service discovery (and more) for large distributed systems.
https://superfly.github.io/corrosion/
Apache License 2.0
718 stars 22 forks source link

pubsub: make sure to catch up sub in a transaction #229

Closed pborzenkov closed 4 months ago

pborzenkov commented 4 months ago

So the last sent row and the last change ID values are consistent. Otherwise it might skip all the changes happened between reading the rows and querying the last change ID.

pborzenkov commented 4 months ago

Not tested yet.