-
Notifications
You must be signed in to change notification settings - Fork 128
HIP-1056 Add block stream poller #10250
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
Conversation
Signed-off-by: Xin Li <[email protected]>
Signed-off-by: Xin Li <[email protected]>
Signed-off-by: Xin Li <[email protected]>
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## main #10250 +/- ##
============================================
+ Coverage 92.18% 92.21% +0.03%
- Complexity 8005 8024 +19
============================================
Files 980 982 +2
Lines 33444 33502 +58
Branches 4218 4225 +7
============================================
+ Hits 30830 30894 +64
+ Misses 1612 1608 -4
+ Partials 1002 1000 -2 ☔ View full report in Codecov by Sentry. |
Signed-off-by: Xin Li <[email protected]>
...or-importer/src/main/java/com/hedera/mirror/importer/config/MetricsExecutionInterceptor.java
Show resolved
Hide resolved
...or-importer/src/main/java/com/hedera/mirror/importer/config/MetricsExecutionInterceptor.java
Show resolved
Hide resolved
Signed-off-by: Xin Li <[email protected]>
hedera-mirror-importer/src/main/java/com/hedera/mirror/importer/ImporterProperties.java
Show resolved
Hide resolved
Signed-off-by: Xin Li <[email protected]>
Signed-off-by: Xin Li <[email protected]>
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks good to me
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
...mporter/src/main/java/com/hedera/mirror/importer/downloader/block/BlockPollerProperties.java
Outdated
Show resolved
Hide resolved
...or-importer/src/main/java/com/hedera/mirror/importer/downloader/block/BlockStreamPoller.java
Outdated
Show resolved
Hide resolved
...or-importer/src/main/java/com/hedera/mirror/importer/downloader/block/BlockStreamPoller.java
Outdated
Show resolved
Hide resolved
...or-importer/src/main/java/com/hedera/mirror/importer/downloader/block/BlockStreamPoller.java
Outdated
Show resolved
Hide resolved
...or-importer/src/main/java/com/hedera/mirror/importer/downloader/block/BlockStreamPoller.java
Outdated
Show resolved
Hide resolved
...or-importer/src/main/java/com/hedera/mirror/importer/downloader/block/BlockStreamPoller.java
Outdated
Show resolved
Hide resolved
...orter/src/main/java/com/hedera/mirror/importer/downloader/provider/S3StreamFileProvider.java
Show resolved
Hide resolved
...or-importer/src/main/java/com/hedera/mirror/importer/downloader/block/BlockStreamPoller.java
Show resolved
Hide resolved
...or-importer/src/main/java/com/hedera/mirror/importer/downloader/block/BlockStreamPoller.java
Outdated
Show resolved
Hide resolved
Signed-off-by: Xin Li <[email protected]>
Signed-off-by: Xin Li <[email protected]>
ea59d61
Signed-off-by: Xin Li <[email protected]>
...or-importer/src/main/java/com/hedera/mirror/importer/downloader/block/BlockStreamPoller.java
Outdated
Show resolved
Hide resolved
...or-importer/src/main/java/com/hedera/mirror/importer/downloader/block/BlockStreamPoller.java
Show resolved
Hide resolved
...or-importer/src/main/java/com/hedera/mirror/importer/downloader/block/BlockStreamPoller.java
Outdated
Show resolved
Hide resolved
...or-importer/src/main/java/com/hedera/mirror/importer/downloader/block/BlockStreamPoller.java
Outdated
Show resolved
Hide resolved
...or-importer/src/main/java/com/hedera/mirror/importer/downloader/block/BlockStreamPoller.java
Outdated
Show resolved
Hide resolved
Signed-off-by: Xin Li <[email protected]>
Signed-off-by: Xin Li <[email protected]>
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Description:
This PR adds block stream poller
BlockStreamPoller
RecordFileDownloader
bean if block stream poller is enabledconfiguration.md
StreamFileProvider
to support downloading block stream files without listingMetricsExecutionInterceptor
to support block stream file pathRelated issue(s):
Fixes #9895
Notes for reviewer:
Checklist