This creates a CatalogUpdateMessage type that is used to send CatalogUpdates; this type performs the send on the oneshot Sender so that the consumer of the message does not need to do so. Subscribers to the catalog get a CatalogSubscription, which uses the CatalogUpdateMessage type to ACK the message broadcast from the catalog. This means that catalog message broadcast can fail, but this commit does not provide any means of rolling back a catalog update. A test was added to check that it works. |
||
---|---|---|
.. | ||
src | ||
Cargo.toml |