GroovieGermanikus
|
3667c61552
|
avoid de-serialization of wire format
|
2023-08-08 16:36:24 +02:00 |
|
GroovieGermanikus
|
8a1b74b569
|
wrap forward packet
|
2023-08-08 15:57:09 +02:00 |
|
GroovieGermanikus
|
47629018de
|
rename request wire format
|
2023-08-08 15:41:29 +02:00 |
|
GroovieGermanikus
|
b19a7a5907
|
Revert "use TryFrom+TryInto for (de-)serialization if proxy_request_format"
This reverts commit 946536f423.
|
2023-08-08 15:30:42 +02:00 |
|
GroovieGermanikus
|
946536f423
|
use TryFrom+TryInto for (de-)serialization if proxy_request_format
|
2023-08-08 13:13:27 +02:00 |
|
GroovieGermanikus
|
905cb2f9ad
|
docs on autoconnect
|
2023-08-08 12:11:05 +02:00 |
|
GroovieGermanikus
|
dd5ad1b875
|
make connection failures more explicit
|
2023-08-08 11:22:46 +02:00 |
|
GroovieGermanikus
|
485bb399a8
|
add sharding to spread work across connections
|
2023-08-08 10:29:00 +02:00 |
|
GroovieGermanikus
|
75c2b316e1
|
Merge remote-tracking branch 'origin/groovie/tpu-proxy-as-module-with-integration-test' into groovie/tpu-proxy-as-module-with-integration-test
|
2023-08-07 22:25:25 +02:00 |
|
GroovieGermanikus
|
6938a0aa86
|
clippy-fmt
|
2023-08-07 22:24:33 +02:00 |
|
GroovieGermanikus
|
bcd8d29abf
|
fix fanout to n agents using broadcast channel
|
2023-08-07 22:19:56 +02:00 |
|
GroovieGermanikus
|
2651469bb7
|
remove DS_Store
|
2023-08-07 18:40:55 +02:00 |
|
GroovieGermanikus
|
d7e1539e06
|
fix sender getting dropped in .listen
|
2023-08-03 10:54:59 +02:00 |
|
GroovieGermanikus
|
9cb24e6788
|
log forward channel buffering
|
2023-08-03 09:08:38 +02:00 |
|
GroovieGermanikus
|
f00d174c30
|
simplified validator identity
|
2023-08-02 15:09:50 +02:00 |
|
GroovieGermanikus
|
92e0972f41
|
cargo fmt
|
2023-08-02 14:55:31 +02:00 |
|
GroovieGermanikus
|
12fb60267f
|
fix all clippy errors
|
2023-08-02 14:55:11 +02:00 |
|
GroovieGermanikus
|
92a977fb98
|
clippy
|
2023-08-02 14:26:13 +02:00 |
|
GroovieGermanikus
|
b41d05e613
|
cleanup minor todos
|
2023-08-02 14:15:39 +02:00 |
|
GroovieGermanikus
|
2f97cb8385
|
cleanup
|
2023-08-02 13:57:00 +02:00 |
|
GroovieGermanikus
|
89ad1bc136
|
comment on selfsigned cert logic
|
2023-08-02 13:46:54 +02:00 |
|
GroovieGermanikus
|
035ce6e3d5
|
fmt+clippy
|
2023-07-31 14:26:21 +02:00 |
|
GroovieGermanikus
|
4844844e21
|
add error context
|
2023-07-31 14:22:56 +02:00 |
|
GroovieGermanikus
|
62a2f76c93
|
add exit signal
|
2023-07-31 13:39:41 +02:00 |
|
GroovieGermanikus
|
86f25724eb
|
minor cleanup
|
2023-07-31 13:27:03 +02:00 |
|
GroovieGermanikus
|
949646c517
|
quic util cleanup
|
2023-07-31 11:41:58 +02:00 |
|
GroovieGermanikus
|
9bfc9ac33e
|
split tls client/server/self signed
|
2023-07-31 11:30:53 +02:00 |
|
GroovieGermanikus
|
ff803fd4ef
|
minor rename
|
2023-07-31 11:14:19 +02:00 |
|
GroovieGermanikus
|
40bdae5066
|
cleanup unused quic code
|
2023-07-31 11:09:49 +02:00 |
|
GroovieGermanikus
|
0b718bc934
|
cleanup mod dependencies
|
2023-07-31 10:48:52 +02:00 |
|
GroovieGermanikus
|
0e19b85d55
|
clenaup proxy.rs
|
2023-07-31 10:16:36 +02:00 |
|
GroovieGermanikus
|
aea5657135
|
works: split listener+forwarder
|
2023-07-31 09:58:17 +02:00 |
|
GroovieGermanikus
|
20c2710202
|
cargo fix
|
2023-07-29 11:26:21 +02:00 |
|
GroovieGermanikus
|
94686f31b6
|
fix compile ValidatorIdentity
|
2023-07-29 11:24:10 +02:00 |
|
GroovieGermanikus
|
1d4e626dc8
|
make proxy address configurable
|
2023-07-29 00:14:49 +02:00 |
|
GroovieGermanikus
|
88b6935319
|
fix wrong agent-tpu assignment
|
2023-07-29 00:06:02 +02:00 |
|
GroovieGermanikus
|
c13f0f5e7c
|
add validator identity
|
2023-07-28 23:06:41 +02:00 |
|
GroovieGermanikus
|
816f978ee6
|
make validator id optional from cli
|
2023-07-28 23:04:53 +02:00 |
|
GroovieGermanikus
|
385d94bc02
|
use fanout
|
2023-07-28 22:23:57 +02:00 |
|
GroovieGermanikus
|
7cae76bb3d
|
drain queues
|
2023-07-28 14:47:38 +02:00 |
|
GroovieGermanikus
|
8ea7428afd
|
inline proxy outbound quinn handling
|
2023-07-28 14:39:59 +02:00 |
|
GroovieGermanikus
|
7abf1351e8
|
add quinn auto reconnect
|
2023-07-28 14:38:55 +02:00 |
|
GroovieGermanikus
|
d2d28bb474
|
add tx forwarder
|
2023-07-27 16:13:39 +02:00 |
|
GroovieGermanikus
|
23ffbc50ab
|
refactor
|
2023-07-27 11:27:31 +02:00 |
|
GroovieGermanikus
|
d378209195
|
restore DashMap dependency
|
2023-07-27 11:20:03 +02:00 |
|
GroovieGermanikus
|
3bebfa2c3b
|
replace DashMap
|
2023-07-27 00:06:20 +02:00 |
|
GroovieGermanikus
|
f2dbdd8dea
|
add cli option
|
2023-07-26 23:33:49 +02:00 |
|
GroovieGermanikus
|
0102058052
|
connection stats
|
2023-07-26 13:22:56 +02:00 |
|
GroovieGermanikus
|
400048ccba
|
integrate send_transaction_batch
|
2023-07-26 11:10:57 +02:00 |
|
GroovieGermanikus
|
7b33ec7d32
|
set quic client+server transport config
* lite-rpc -> proxy
* proxy -> TPU
|
2023-07-26 11:10:12 +02:00 |
|
GroovieGermanikus
|
4f09278cd2
|
works
|
2023-07-25 13:54:34 +02:00 |
|
GroovieGermanikus
|
5a4546c807
|
implement chunk+parallel sending
|
2023-07-25 12:54:47 +02:00 |
|
GroovieGermanikus
|
391a42ec22
|
wip
|
2023-07-25 12:00:39 +02:00 |
|
GroovieGermanikus
|
c9c6b7b98e
|
use stream per client-proxy connection
|
2023-07-25 09:50:21 +02:00 |
|
GroovieGermanikus
|
a2207da37a
|
wip works
|
2023-07-25 09:04:25 +02:00 |
|
GroovieGermanikus
|
fd2cf5a0eb
|
fix dashmap arc issue
|
2023-07-24 15:59:09 +02:00 |
|
GroovieGermanikus
|
19f7922e1f
|
build dumb lazy-one-connection per tpu allocation strategy
|
2023-07-24 15:52:56 +02:00 |
|
GroovieGermanikus
|
067c1a10f7
|
experiment with tokio tracing
|
2023-07-24 11:14:04 +02:00 |
|
GroovieGermanikus
|
0d1c95c327
|
move proxy send code
|
2023-07-24 10:45:17 +02:00 |
|
GroovieGermanikus
|
9c1ce6b942
|
wire up quic proxy connection path
|
2023-07-20 17:54:26 +02:00 |
|
GroovieGermanikus
|
228c58d861
|
cut dependency between quic-proxy and lite-rpc crate
|
2023-07-20 09:28:55 +02:00 |
|
GroovieGermanikus
|
7c3f7bea74
|
refactor out tpu_quic_connection
|
2023-06-29 11:05:49 +02:00 |
|
GroovieGermanikus
|
f5979eb098
|
WIP: refactor active type connection
|
2023-06-27 17:06:35 +02:00 |
|
GroovieGermanikus
|
c406f447cc
|
remove useless async
|
2023-06-27 16:55:38 +02:00 |
|
GroovieGermanikus
|
c0d4b18df5
|
improve error handling on accept stream
|
2023-06-27 16:53:27 +02:00 |
|
GroovieGermanikus
|
eb25711496
|
comment tpu_service input
|
2023-06-27 13:35:21 +02:00 |
|
GroovieGermanikus
|
a786e190bd
|
add readme
|
2023-06-27 12:08:26 +02:00 |
|
GroovieGermanikus
|
77c801ff45
|
proxy forwarding works
|
2023-06-26 22:10:06 +02:00 |
|
GroovieGermanikus
|
1146589b09
|
proxy works
|
2023-06-26 08:58:48 +02:00 |
|
GroovieGermanikus
|
f7ad7da021
|
use quic uni instead of bi stream
|
2023-06-26 08:08:45 +02:00 |
|
GroovieGermanikus
|
eb33095778
|
introduce proxy request
|
2023-06-26 08:05:18 +02:00 |
|
GroovieGermanikus
|
47fd8b15d3
|
rountrip test with instruction
|
2023-06-25 21:53:19 +02:00 |
|
GroovieGermanikus
|
4e25095744
|
define basic proxy wire format
|
2023-06-23 10:37:33 +02:00 |
|
GroovieGermanikus
|
90e04680af
|
add sample client
|
2023-06-23 09:16:57 +02:00 |
|
GroovieGermanikus
|
56743e7695
|
integrate proxy with lite-rpc for testing
|
2023-06-22 18:54:09 +02:00 |