Open gavin-norman-sociomantic opened 6 years ago
This could include the whole record batch management, as well (on both sides).
It should use the new record batcher, too.
Should probably include https://github.com/sociomantic-tsunami/dlsproto/pull/84 by default.
Btw, I the code pretty much ready, I'll clean it up and submit a PR in the next few days. I've successfully converted DMQ's Consume request and DLS's GetRange reqeuest to use it.
Oh, yes, I think it should include that feature by default (it also includes double-buffering).
Should use https://github.com/sociomantic-tsunami/swarm/blob/v4.x.x/src/swarm/neo/util/Batch.d internally (at the request's option?).
Feature: extend finished
notification to indicate the number of nodes where the request finished successfully/with an error.
Btw, I the code pretty much ready, I'll clean it up and submit a PR in the next few days. I've successfully converted DMQ's Consume request and DLS's GetRange reqeuest to use it.
:(
Moved to v5.5.0.
The existing request core is fairly minimal. I'm sure there's a lot more common code that could be added (basic fiber implementations, for example).
Ditto for the node side of the equation (where no core code exists atm).