|
|
3428c31f16
|
Use tokio channels again
|
2024-04-14 20:06:58 -05:00 |
|
|
|
6f95c72070
|
Add new feature for testing with errors, test & fix job retries
|
2024-03-10 22:02:27 -05:00 |
|
|
|
4976fcb2eb
|
Remove unneeded code
|
2024-03-09 22:53:46 -06:00 |
|
|
|
c1e651c01a
|
Use BytesStream in more places
|
2024-02-22 16:03:04 -06:00 |
|
|
|
c65b49339f
|
Take at most 2048 variants and proxies during each cleanup job
|
2024-01-25 16:26:29 -06:00 |
|
|
|
9ceb26bb5c
|
Clippy
|
2024-01-07 10:09:06 -06:00 |
|
|
|
bcf73eb4e4
|
Improve cooperation from from_iterator to prevent task starvation
|
2024-01-05 19:50:10 -06:00 |
|
|
|
bfc2410552
|
Add trace-level logs to every loop (paranoid)
|
2023-12-28 11:58:38 -06:00 |
|
|
|
b94ba5fcfc
|
Inline process background future, clean tracing a bit
|
2023-12-22 13:12:19 -06:00 |
|
|
|
c795c1edfa
|
Replace most of actix-rt with tokio, give names to tasks
|
2023-10-20 19:08:11 -05:00 |
|
|
|
745e990fa0
|
Remove direct dependency on actix-rt and actix-server
|
2023-09-24 15:45:10 -05:00 |
|
|
|
cde4a72203
|
Add metrics to object storage body streams
|
2023-09-20 19:46:10 -05:00 |
|
|
|
4a5b9712aa
|
Combine map_ok and map_err underlying impl
|
2023-09-10 23:51:07 -04:00 |
|
|
|
2b10c48619
|
Update io-uring to use streem for file bytes
|
2023-09-10 23:45:24 -04:00 |
|
|
|
1b97ac1c5a
|
Start replacing manual stream implementations with streem
|
2023-09-10 18:55:13 -04:00 |
|
|
|
e15a82c0c7
|
Add external validation check
|
2023-09-05 20:45:07 -05:00 |
|
|
|
a43de122f9
|
postgres: add already-claimed case, general: tracing paranoia
|
2023-09-03 21:30:47 -05:00 |
|
|
|
b28cc38c38
|
Simplify Streamer
|
2023-08-23 19:12:59 -05:00 |
|
|
|
95637fdfe5
|
Remove direct dep on futures-util
|
2023-08-23 19:10:10 -05:00 |
|
|
|
8f50a15b25
|
Reduce reliance on futures-util
|
2023-08-23 11:59:42 -05:00 |
|
|
|
1ee77b19d8
|
Make Repo object safe. Create migration
|
2023-08-15 19:19:03 -05:00 |
|
|
|
e493e90dd4
|
Defensive tracing
|
2022-04-07 12:56:40 -05:00 |
|
|
|
63d66050c8
|
Enable buffering iterator items for iterstream
|
2022-03-29 16:18:00 -05:00 |
|
|
|
5adb3fde89
|
Move some Stream implementations into 'stream' module
|
2022-03-29 15:59:17 -05:00 |
|
|
|
e7c3e2c96c
|
Rename stream module
|
2021-10-20 19:00:41 -05:00 |
|
|
|
e7b4e4d1cc
|
Remove a few boxes
|
2021-10-20 18:58:32 -05:00 |
|
|
|
09cb2a53b0
|
Rewrite to avoid direct AsyncX impls
|
2021-10-13 19:06:53 -05:00 |
|
|
|
f390c62cbf
|
Wrap BytesFreezer in span
|
2021-09-25 16:39:10 -05:00 |
|
|
|
ba68bcbde3
|
Add better span information to commands, spawned tasks
|
2021-09-25 15:23:05 -05:00 |
|
|
|
5d3e6f50b3
|
Instrument better with Tracing
|
2021-09-13 20:22:42 -05:00 |
|
|
|
bf1a16d7d3
|
Abort process writer task if reader is dropped
|
2021-09-11 16:35:38 -05:00 |
|
|
|
45606f4579
|
Add application-level dimension limiting, bail on failed processes
|
2021-09-09 14:16:12 -05:00 |
|
|
|
ac79a9d5cd
|
Use futures-util instead of hand-implemented types
|
2021-09-05 20:00:31 -05:00 |
|
|
|
e21fd29c09
|
Drop unneeded dependencies
|
2021-09-04 14:20:31 -05:00 |
|
|
|
08c3169d3f
|
Fewer streams
|
2021-09-04 12:42:40 -05:00 |
|
|
|
1119ed740e
|
WIP: Try to pass AsyncRead types around instead of Streams
|
2021-09-03 19:53:53 -05:00 |
|
|
|
a6f2082b37
|
Spawn new task to avoid complexity/bugs
|
2021-08-31 10:17:08 -05:00 |
|
|
|
c1d4e3b87e
|
Start work on piping bytes around from memory instead of going to disk and back
|
2021-08-30 21:19:47 -05:00 |
|
