[Backport v4.x] backport full node streaming to v4.x branch (#1270) #1349
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.
[CT-645] Move off chain updates and v1 to a different package ([CT-645] Move off chain updates and v1 to a different package #1131)
[CT-645] Add protos for orderbook stream query service
move removal reasons to a separate package
[CT-645] Add protos for orderbook stream query service ([CT-645] Add protos for orderbook stream query service #1133)
[CT-645] Add protos for orderbook stream query service
make update not nullable
fix build
[CT-644] instantiate grpc stream manager ([CT-644] instantiate grpc stream manager #1134)
[CT-644] instantiate grpc stream manager
update type
update channel type
[CT-646] stream offchain updates through stream manager ([CT-646] stream offchain updates through stream manager #1138)
[CT-646] stream offchain updates through stream manager
comments
fix lint
get rid of finished
comments
comments
[CT-652] add command line flag for full node streaming ([CT-652] add command line flag for full node streaming #1145)
[CT-647] construct the initial orderbook snapshot ([CT-647] construct the initial orderbook snapshot #1147)
[CT-647] construct the initial orderbook snapshot
[CT-647] initialize new streams and send orderbook snapshot ([CT-647] initialize new streams and send orderbook snapshot #1152)
[CT-647] initialize new streams and send orderbook snapshot
use sync once
comments
[CT-700] separate indexer and grpc streaming events ([CT-700] separate indexer and grpc streaming events #1209)
[CT-700] separate indexer and grpc streaming events
fix tests
comments
update
[CT-700] only send response when there is at least one update ([CT-700] only send response when there is at least one update #1216)
[CT-712] send order update when short term order state fill amounts are pruned ([CT-712] send order update when short term order state fill amounts a… #1241)
[CT-712] send fill amount updates for reverted operations ([CT-712] send fill amount updates for reverted operations in prepare check state #1240)
[CT-723] add block number + stage to grpc updates ([CT-723] add block number + stage to grpc updates #1252)
[CT-723] add block number + stage to grpc updates
add indexer changes
[CT-727] avoid state reads when sending updates ([CT-727] avoid state reads when sending updates #1261)
Changelist
[Describe or list the changes made in this PR]
Test Plan
[Describe how this PR was tested (if applicable)]
Author/Reviewer Checklist
state-breaking
label.indexer-postgres-breaking
label.PrepareProposal
orProcessProposal
, manually add the labelproposal-breaking
.feature:[feature-name]
.backport/[branch-name]
.refactor
,chore
,bug
.