-
Notifications
You must be signed in to change notification settings - Fork 3
feat: Add 'Get Latest X Events and Switch to Live Streaming' Method #133
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
Merged
Merged
Changes from all commits
Commits
Show all changes
54 commits
Select commit
Hold shift + click to select a range
8dd02c2
feat: latest then live
0xNeshi d0dc9d7
feat: notify the client about chain tip reached
0xNeshi fdd41b4
feat: rename ChainTipReached -> SwitchingToLive
0xNeshi 528bf86
feat: rewind, sync and live modes run in separate threads
0xNeshi cd0d303
Revert "feat: rewind, sync and live modes run in separate threads"
0xNeshi ff1dadc
feat: make handly_sync stream data in a separate thread
0xNeshi 7c963a0
ref: minor handle_sync optimization
0xNeshi a076062
feat: make stream_rewind run in separate thread
0xNeshi 6d1ddb1
test: add tests (not working)
0xNeshi b6336de
feat: stream_from supports starting from future block
0xNeshi 37cb8e3
feat: ensure correct ordering of logs (first rewind then live)
0xNeshi 6de0d03
docs: reword comment
0xNeshi 2876ea9
fix: drop rewind_tx when rewind step is complete
0xNeshi f55cbab
test: fix scan_latest_then_live_exact_historical_count_then_live
0xNeshi a4de6f7
test: fix + add no live blocks test case
0xNeshi e2ce574
docs: improve comment explanations
0xNeshi d95f05a
docs: update readme
0xNeshi 4685262
docs: update doc-comment
0xNeshi c81aac2
test: add example
0xNeshi e46bd76
docs: add duplicate reorg handling warning
0xNeshi c1e9116
build: add missing workspace example member to cargo
0xNeshi 2104acd
docs: update where stale
0xNeshi c92bb81
ref: clippy
0xNeshi b5aecd6
fix: duplicate reorg handling
0xNeshi d8b70b9
docs: remove parallel reorg warnings
0xNeshi 89c7532
ref: src/event_scanner.rs
0xNeshi b458047
fix: await all log consumers (preserve old behavior in other modes) (…
0xNeshi 6d9cf45
fix: drop broadcast sender to indicate log consumers should be dropped
0xNeshi e59ebcb
fix: add missing live stream broadcaster drop
0xNeshi bd1e2eb
ref: move clippy allows to tests/common
0xNeshi aa0fec1
Merge remote-tracking branch 'origin/main' into latest-then-live
0xNeshi bff6587
test: fix doc tests
0xNeshi 9db2569
chore: merge with main
0xNeshi 9c35781
feat: Split sync scanners
0xNeshi a6fd39e
ref: remove printlns
0xNeshi c97f5a0
docs: add comment on why we use test-log
0xNeshi e24696b
Merge remote-tracking branch 'origin/main' into latest-then-live
0xNeshi 4857720
test: fix test_sync_scanner_builder_last_call_wins
0xNeshi e71902a
test: align example names
0xNeshi c4eb6d6
docs: remove README section and update appropriate sync doc comment
0xNeshi 6b60e20
docs: fix links
0xNeshi 0f0bba4
test: fix doc tests
0xNeshi 4158f0e
chore: merge with main
0xNeshi d8a0e29
docs: remove with_ prefix
0xNeshi 244f5fb
docs: move latest events docs out of readme to appropriate builder fn
0xNeshi 8a288cd
docs: remove errors section from readme
0xNeshi 0dba25b
ref: move from_latest-related imports into the module
0xNeshi d4d9f0f
doc: explain handle_stream
0xNeshi a1313f3
ref: minor
0xNeshi 7648eb7
ref: add #[allow(clippy::missing_panics_doc)] to from_latest start
0xNeshi 24b4556
test: turn increase/decreaase macros into fns
0xNeshi 8cd7f91
test: extend testcounter
0xNeshi f4c7ba9
Update README.md
0xNeshi d613e52
Update README.md
0xNeshi File filter
Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
There are no files selected for viewing
Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.
Oops, something went wrong.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
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.
Align names