mirror of
https://github.com/digital-asset/daml.git
synced 2024-09-20 17:28:46 +03:00
d30b6eb94b
* Implement proper stream pagination The previous pagination mechanism for streaming ledger entries was implemented as a recursive method call with manually concatenating akka Sources. However, this didn't work properly and resulted in all the subsources being forced immediately, resulting in parallel requests for all pages (0-100, 100-200, 200-300, ...) instead of the expected mechanism of loading the first page and on upstream request (i.e. client requests for more data over grpc) loading the next page of data. The current mechanism uses Source.unfoldAsync which makes the paging mechanism work as expected: sequential loading of pages on demand. * Serialize and deserialize Transactions outside the SQL Executor This frees up the SQL Executor threads sooner for other work and the conversion work only happens on a by need basis when the consumer requests more data. |
||
---|---|---|
.. | ||
kvutils | ||
src/main/scala/com/daml/ledger/participant/state/v1 | ||
BUILD.bazel |