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

Write LedgerDB src/sink #1566

Closed
Tracked by #1433
iamalwaysuncomfortable opened this issue Mar 3, 2022 · 0 comments · Fixed by #1831
Closed
Tracked by #1433

Write LedgerDB src/sink #1566

iamalwaysuncomfortable opened this issue Mar 3, 2022 · 0 comments · Fixed by #1831
Assignees

Comments

@iamalwaysuncomfortable
Copy link
Contributor

iamalwaysuncomfortable commented Mar 3, 2022

As part of implementing the block streaming framework (#1433), implement a src and sink pipeline for ledgerdb (i.e. [src1,src2]-->validation-->sink) which chains async iterators together to achieve the src, sink, and all intermediary logic.

In the simplest form, this might look like:

let src = GrpcClientSrc::new("peer1");
let src2 = GrpcClientSrc::new("peer2");
let validator = ValidatingElement::new(src1, src2);
let sink = LedgerDbSink::new(validator, path_to_db);

Optimally the source (and potentially sink?)can be made generic through traits can so that other types of streaming data can use this interface.

let src_generic = GrpcClientSrc::<GrpcClientImpl, RustType>::new()
@iamalwaysuncomfortable iamalwaysuncomfortable self-assigned this Mar 3, 2022
@iamalwaysuncomfortable iamalwaysuncomfortable moved this to In Progress in Blockchain Core Mar 3, 2022
@iamalwaysuncomfortable iamalwaysuncomfortable changed the title Write async ledgerdb src/sink Write LedgerDB src/sink Mar 3, 2022
@iamalwaysuncomfortable iamalwaysuncomfortable moved this to In Progress in Blockchain Core Mar 14, 2022
@iamalwaysuncomfortable iamalwaysuncomfortable linked a pull request Apr 21, 2022 that will close this issue
@iamalwaysuncomfortable iamalwaysuncomfortable moved this from In Progress to Done in Blockchain Core Apr 22, 2022
@jcape jcape closed this as completed Apr 22, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
Archived in project
Development

Successfully merging a pull request may close this issue.

2 participants