StakeSquid/dshackle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
1,380 Commits 2 Branches 0 Tags
a5590f66032aca230e2bc4dc951e924d06d3dcf2
Commit Graph

955 Commits

Author SHA1 Message Date
a10zn8
1e8c4e1ab1 Change Status class to data class for better logging 
Log every node status change in blockchain rpc
 2023-01-25 13:29:58 +04:00
a10zn8
8eac1178ec propagate grpc provided upstream id 2023-01-24 19:59:34 +04:00
a10zn8
c9fa1faa3f it is dangerous to use tryEmitNext without check of result in multithreaded case. emitNext with EmitFailureHandler are safe option for such situations. 
Also added logging for upstream status changes
 2023-01-24 18:06:23 +04:00
KirillPamPam
731ee2c747 Merge pull request #119 from p2p-org/add_supportedSubs 
Add supported subscription methods to SubscribeNodeStatus response
 2023-01-23 19:44:48 +04:00
Кирилл
0f7fd35b12 Add supported sub methods to SubscribeNodeStatus 2023-01-23 17:22:43 +04:00
a10zn8
6148d96499 remove excessive logging 2023-01-20 19:12:34 +04:00
a10zn8
a46b456a25 improve logging 
- log merged head stop
- add network name to label
- log only non-empty deltas of grpc upstreams changes
 2023-01-19 18:16:23 +04:00
a10zn8
16f8121a46 Stabilisation of upstreams: 
- reverted removing of configured upstreams in case of unavailability
- small refactoring in grpc upstreams
- fixing of bug of statuses subscription
 2023-01-19 17:37:24 +04:00
a10zn8
d18d96513d Added log for grpc upstreams processing 2023-01-19 16:08:46 +04:00
a10zn8
d4b1e8ee1c revert old metric that can cause gc problems 2023-01-18 19:12:42 +04:00
Кирилл
c82ff9d6cf Move to Java 17 2023-01-18 14:49:57 +04:00
a10zn8
1efbba29f3 set lag = 0 in case single upstream in multisream 2023-01-17 20:13:25 +04:00
a10zn8
ed82aa373a Added fixed channel executor thread pool 2023-01-17 20:02:03 +04:00
a10zn8
a23d28b5e6 fixed small typos in thread pools names 
lag observer should be created only in case there are more than 1 upstreams exists
 2023-01-17 12:56:34 +04:00
a10zn8
6beda847b1 Small improvements after dynamic head introduction 
- add injection of schedulers for dynamic heads
- more logging
- replace onBackpressureBuffer to directBestEffort multicast sink
 2023-01-16 17:39:30 +04:00
a10zn8
8891539b73 Merge pull request #109 from p2p-org/dynamic-merged-head 2023-01-12 19:27:38 +04:00
Vyacheslav Shebanov
ef6246c4a3 Merge pull request #107 from p2p-org/fix/ehtereum-call-selector 
ethereum call selector and passthrough interaction: keep same upstrea…
 2023-01-12 15:11:08 +02:00
a10zn8
bb035b4469 dymanic head subscription 2023-01-12 15:52:59 +04:00
Termina1
5488c201c5 fix stylw 2023-01-12 13:11:02 +02:00
Termina1
f298b99251 subscribe status send current upstream state on subscription 2023-01-12 13:05:47 +02:00
Termina1
0826f9a2be ethereum call selector and passthrough interaction: keep same upstream matcher 2023-01-12 12:51:11 +02:00
Termina1
72982c9284 added node id for node status 2023-01-11 18:00:52 +02:00
a10zn8
65fc2bfe7b missing responses through a WS connection 2023-01-11 15:39:35 +04:00
Termina1
1fdf816ca2 passthrough mode - ignore call specific selectors 2023-01-10 20:52:43 +02:00
Termina1
8066b88108 fix linter 2023-01-10 13:40:19 +02:00
Termina1
4aa54cb907 subscribe node status - remove head subscription and remove sampling, afraid of missing updates 2023-01-10 13:33:35 +02:00
Vyacheslav Shebanov
ca77d77d16 Merge pull request #102 from p2p-org/fix-node-status-subscription 
fix node status subsciption for gRPC upstreams
 2023-01-09 20:53:49 +02:00
Termina1
ed9d39b733 fix stylw 2023-01-09 20:38:15 +02:00
Termina1
b769446b0e add handler for not able to emit removal event 2023-01-09 20:19:37 +02:00
Termina1
424338eb8e fix serializing to json of json rpc request 2023-01-09 16:21:51 +02:00
Termina1
38f8a6817a handle subscription updates for upstream removals separately 2023-01-06 13:58:01 +02:00
Termina1
85caff4537 fix node status subsciption for gRPC upstreams 2023-01-05 20:34:56 +02:00
a10zn8
031ee74bbc rename readers/routers according to their functions 2022-12-28 13:10:42 +04:00
a10zn8
2b5c29be17 JsonRpcReader type alias 2022-12-27 17:40:56 +04:00
a10zn8
25dde8cfdf blockchain supported subscriptions data 2022-12-27 17:31:52 +04:00
a10zn8
08b47d128c Move from homemade solutions to Caffeine 2022-12-23 14:36:46 +04:00
a10zn8
e0fdfa4420 ws subscription refactoring 
added support of pending transactions subscription
 2022-12-22 17:03:10 +04:00
a10zn8
7bc4acb376 Merge pull request #98 from p2p-org/fix-upstream-id 
now return first resolver as upstream-id in case of quorum rpc read.
 2022-12-22 13:13:59 +04:00
Termina1
92ac7fb9ad tryProxy does not makes sense for > than 1 upstream selectors 2022-12-21 20:55:22 +02:00
a10zn8
44ba9b47ba now return first resolver as upstream-id in case of quorum rpc read. 2022-12-21 22:02:08 +04:00
MaxFomenkov
8bbcdb6785 Merge pull request #93 from p2p-org/subscribe_node_status 
subscribe node status
 2022-12-20 17:06:37 +03:00
Maksim Fomenkov
214cb4fd8e fixed code style 2022-12-20 16:39:26 +03:00
Maksim Fomenkov
a1c234d3bf fixed re-subscription 2022-12-20 16:33:25 +03:00
Maksim Fomenkov
f6c6c8d4ef fixed review comments 2022-12-20 15:36:20 +03:00
Maksim Fomenkov
5894501f0c fixed labels grouping 2022-12-20 15:00:52 +03:00
Maksim Fomenkov
8f0c9d1187 added sampling 2022-12-20 12:01:34 +03:00
a10zn8
29d888c013 health endpoint should be stopped in case application starts to shut down 2022-12-19 19:28:36 +04:00
a10zn8
5db9e1bfd1 Merge pull request #87 from p2p-org/do-not-write-ws-exception-stacktrace 
do not call fillInStackTrace in exception constructor in happy path
 2022-12-19 16:14:31 +04:00
Maksim Fomenkov
db97b656cf fix style and tests 2022-12-19 11:41:05 +03:00
Maksim Fomenkov
1f611c8268 subscribe node status 2022-12-19 11:12:12 +03:00