GroovieGermanikus
|
0604573f4e
|
log if env config missing
|
2024-06-14 10:22:56 +02:00 |
GroovieGermanikus
|
c096a04125
|
set nodelay + add env for window+biffer sizes
|
2024-06-14 10:16:16 +02:00 |
GroovieGermanikus
|
32aeb332b1
|
try to enable compression
|
2024-05-08 16:45:13 +02:00 |
GroovieGermanikus
|
86412cfd71
|
define AtomicSlot
|
2024-05-08 15:25:32 +02:00 |
GroovieGermanikus
|
bd439a3390
|
Merge branch 'release/v0.10.x+yellowstone.1.13' into groovie/performancetest-grpc
|
2024-05-08 11:26:31 +02:00 |
GroovieGermanikus
|
193a1b6878
|
make SubscribeRequest forward-compatible
|
2024-05-08 11:20:58 +02:00 |
GroovieGermanikus
|
edd3a1a543
|
histogram
|
2024-04-29 14:54:37 +02:00 |
GroovieGermanikus
|
1393527259
|
calculate delta
|
2024-04-29 14:49:34 +02:00 |
GroovieGermanikus
|
e09e5e2d36
|
collectors
|
2024-04-29 09:58:39 +02:00 |
GroovieGermanikus
|
1d1a01c8ae
|
clarify await_or_exit behavior on channel close
|
2024-04-29 09:08:23 +02:00 |
GroovieGermanikus
|
dd78804e5a
|
clarify await_or_exit behavior on channel close
|
2024-04-29 09:08:09 +02:00 |
GroovieGermanikus
|
85d04ac111
|
export GeyserGrpcClient, GeyserGrpcClientResult, GeyserGrpcClientError
|
2024-04-16 13:37:54 +02:00 |
GroovieGermanikus
|
dd18a2074d
|
use dedicated AST
|
2024-04-16 12:29:00 +02:00 |
GroovieGermanikus
|
fef2e70520
|
cleanup
|
2024-04-16 12:17:36 +02:00 |
godmodegalactus
|
280f03d4d5
|
Changing Notify channel to broadcast channel
|
2024-04-16 10:45:25 +02:00 |
godmodegalactus
|
7f115fb8b5
|
Adding notify channel to stop tasks
|
2024-04-16 10:45:09 +02:00 |
GroovieGermanikus
|
1d2937ad95
|
clippy
|
2024-04-16 10:12:59 +02:00 |
GroovieGermanikus
|
c1ca3e2e67
|
1.13 with buffer window size
|
2024-04-11 14:57:04 +02:00 |
GroovieGermanikus
|
a821ca219b
|
stream: replace panic with log+reconnect
|
2024-03-22 10:56:40 +01:00 |
GroovieGermanikus
|
497dfe0144
|
wip
|
2024-03-22 10:06:19 +01:00 |
GroovieGermanikus
|
813931f210
|
fix stream message attempt counter
|
2024-03-11 17:56:16 +01:00 |
GroovieGermanikus
|
37ed49c210
|
clippy
|
2024-03-11 15:50:43 +01:00 |
GroovieGermanikus
|
26bc7a3683
|
make attempt counter 1-based
|
2024-03-11 15:45:28 +01:00 |
GroovieGermanikus
|
f1e174c1dc
|
make attempt 1-based
|
2024-03-11 15:41:55 +01:00 |
GroovieGermanikus
|
4ffe39849f
|
fix double-increment of attempt
|
2024-03-11 15:36:56 +01:00 |
GroovieGermanikus
|
48efa7bbe8
|
restart attempt counter in ready state
|
2024-03-11 15:27:32 +01:00 |
GroovieGermanikus
|
a6ab686fa4
|
add create_geyser_autoconnection_task_with_mpsc
|
2024-02-15 14:56:10 +01:00 |
GroovieGermanikus
|
66c4256438
|
create_geyser_autoconnection_task allows caller-provided mpsc
|
2024-02-15 12:00:19 +01:00 |
GroovieGermanikus
|
048ad2be28
|
clippy+fmt
|
2024-01-31 18:53:07 +01:00 |
GroovieGermanikus
|
5c568a2602
|
remove grpc_subscription.rs
|
2024-01-26 19:32:37 +01:00 |
GroovieGermanikus
|
68221ce0cc
|
clippy+fmt
|
2024-01-26 19:25:39 +01:00 |
GroovieGermanikus
|
db034040e8
|
handle timeout for stream version
|
2024-01-26 19:19:05 +01:00 |
GroovieGermanikus
|
ec43c2972e
|
handle timeout
|
2024-01-26 19:16:21 +01:00 |
GroovieGermanikus
|
f22a0f289e
|
remove exclamation mark from logs
|
2024-01-23 17:50:10 +01:00 |
GroovieGermanikus
|
1b9926fc1b
|
slots
|
2024-01-23 14:48:47 +01:00 |
GroovieGermanikus
|
1d0b7890c3
|
move Message type
|
2024-01-22 18:26:26 +01:00 |
GroovieGermanikus
|
b3808da95e
|
example
|
2024-01-22 10:56:07 +01:00 |
GroovieGermanikus
|
6e15250b96
|
minor cleanup
|
2024-01-22 10:55:03 +01:00 |
GroovieGermanikus
|
87a4bbc484
|
use channel_plugger in test
|
2024-01-19 11:46:19 +01:00 |
GroovieGermanikus
|
46f56872e5
|
introduce T
|
2024-01-19 11:46:06 +01:00 |
GroovieGermanikus
|
afefb1847b
|
cleanup
|
2024-01-19 11:34:45 +01:00 |
GroovieGermanikus
|
80d5c979f3
|
channel plugger mspc->broadcast
|
2024-01-19 11:33:37 +01:00 |
GroovieGermanikus
|
11b24bc537
|
testcase lagging
|
2024-01-19 09:23:55 +01:00 |
GroovieGermanikus
|
0200e9d469
|
map fatal errors
|
2024-01-19 09:13:37 +01:00 |
GroovieGermanikus
|
9dec39dfeb
|
test/example for autoconnect
|
2024-01-19 09:04:03 +01:00 |
GroovieGermanikus
|
cf0c83b0c5
|
compile
|
2024-01-19 08:50:08 +01:00 |
GroovieGermanikus
|
dc53a50e57
|
switch to mpsc
|
2024-01-19 08:43:47 +01:00 |
GroovieGermanikus
|
21f2ef3b7c
|
wip
|
2024-01-19 08:25:05 +01:00 |
GroovieGermanikus
|
33cb8cbfa7
|
split impl
|
2024-01-18 13:45:19 +01:00 |
GroovieGermanikus
|
ca55a8bba8
|
handle connect problems
|
2024-01-18 13:38:15 +01:00 |