Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Support streaming entry chunk ingestion #34

Open
masih opened this issue Nov 20, 2024 · 1 comment
Open

Support streaming entry chunk ingestion #34

masih opened this issue Nov 20, 2024 · 1 comment

Comments

@masih
Copy link
Member

masih commented Nov 20, 2024

With the improved storage provider architectures, like Curio, SPs are now capable of fetching advertisement entries fast (within 10s of milliseconds). In that world, the bottleneck shifts from entry chuck generation to roundtrips between indexer and SP.

Consider supporting streaming response when fetching ad entries:

  • SP continuously writes multihashes in expected order
  • indexers cumulatively calculate the CID of the hashes received, until the CID matches the expected CID in advertisement (with some upper bound to the max number of multihashes accumulated, currently at ~16K)
  • SP uses keep-alive to signal WIP in returning further entities to indexers (with some upper bound for maximum wait time on indexer side).

This approach should significantly improve ingestion time for SPs that are able to serve entries fast enough. It shifts the ingest architecture to a reactive model that would avoid roundtrip bottlenecks.

@masih
Copy link
Member Author

masih commented Nov 20, 2024

cc @magik6k

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant