Commit Graph

602 Commits

Author SHA1 Message Date
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
a10zn8
214abc4722 Revert "problem: timeout on unit tests" 2022-12-16 15:19:15 +04:00
a10zn8
8c656ca28b Merge pull request #88 from p2p-org/timeout-tests-ws
problem: timeout on unit tests
2022-12-16 14:42:09 +04:00
Maksim Fomenkov
56760319e3 code style 2022-12-16 03:04:58 +03:00