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
|
497dfe0144
|
wip
|
2024-03-22 10:06:19 +01:00 |
|
GroovieGermanikus
|
37ed49c210
|
clippy
|
2024-03-11 15:50:43 +01:00 |
|
GroovieGermanikus
|
1fc40f0cd3
|
task example
|
2024-03-11 15:41:47 +01:00 |
|
GroovieGermanikus
|
48efa7bbe8
|
restart attempt counter in ready state
|
2024-03-11 15:27:32 +01:00 |
|
GroovieGermanikus
|
048ad2be28
|
clippy+fmt
|
2024-01-31 18:53:07 +01:00 |
|
GroovieGermanikus
|
1ddd4bd24a
|
clippy+fmt
|
2024-01-26 19:25:57 +01:00 |
|
GroovieGermanikus
|
68221ce0cc
|
clippy+fmt
|
2024-01-26 19:25:39 +01:00 |
|
GroovieGermanikus
|
f22a0f289e
|
remove exclamation mark from logs
|
2024-01-23 17:50:10 +01:00 |
|
GroovieGermanikus
|
1d0b7890c3
|
move Message type
|
2024-01-22 18:26:26 +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
|
afefb1847b
|
cleanup
|
2024-01-19 11:34:45 +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
|
b9875cbb6c
|
cleanup
|
2024-01-19 09:04:25 +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
|
33cb8cbfa7
|
split impl
|
2024-01-18 13:45:19 +01:00 |
|
GroovieGermanikus
|
fa05a1bd5f
|
add connection state
|
2024-01-18 10:09:32 +01:00 |
|
GroovieGermanikus
|
16c1218f0e
|
simple consumer
|
2024-01-11 08:25:26 +01:00 |
|
GroovieGermanikus
|
f4fe77167d
|
version 0.7.1
|
2023-12-22 17:05:48 +01:00 |
|
GroovieGermanikus
|
25b0801285
|
cleanup
|
2023-12-21 10:50:52 +01:00 |
|
GroovieGermanikus
|
bcd3f77842
|
use GeyserFilter as factory
|
2023-12-21 07:52:37 +01:00 |
|
GroovieGermanikus
|
9484c64d84
|
move example code
|
2023-12-20 09:13:10 +01:00 |
|
GroovieGermanikus
|
4a92064efd
|
clippy
|
2023-12-19 14:19:27 +01:00 |
|
GroovieGermanikus
|
3d50dce545
|
implement channelizer
|
2023-12-19 13:42:26 +01:00 |
|
GroovieGermanikus
|
342303a9ec
|
remove label
|
2023-12-19 11:57:23 +01:00 |
|
GroovieGermanikus
|
4aeeb45027
|
small refactors
|
2023-12-19 11:27:42 +01:00 |
|
GroovieGermanikus
|
db2288c312
|
remove unused variable
|
2023-12-19 08:16:50 +01:00 |
|
GroovieGermanikus
|
366461bb2f
|
extract filter
|
2023-12-15 17:02:42 +01:00 |
|
GroovieGermanikus
|
b1790fb028
|
track conneciton attempts and do exponention backoff
|
2023-12-15 16:38:19 +01:00 |
|
GroovieGermanikus
|
c3c22c87fc
|
remove broken reconnect count
|
2023-12-15 16:28:01 +01:00 |
|
GroovieGermanikus
|
1f1df6ea32
|
tag stream reconnect message
|
2023-12-15 16:11:01 +01:00 |
|
GroovieGermanikus
|
dfed859d0c
|
use streams.merge()
|
2023-12-15 12:01:29 +01:00 |
|
GroovieGermanikus
|
a7f957a528
|
deleted task/channel version
(moved to hacking-task-channel)
|
2023-12-15 11:45:00 +01:00 |
|
GroovieGermanikus
|
6081426f74
|
minor cleanups
|
2023-12-15 11:43:00 +01:00 |
|
GroovieGermanikus
|
0e4b5bf1ea
|
fix all clippy
|
2023-12-15 10:28:25 +01:00 |
|
GroovieGermanikus
|
7c1319377d
|
clippy
|
2023-12-15 10:25:21 +01:00 |
|
GroovieGermanikus
|
32709aff8a
|
move mock code
|
2023-12-15 10:20:41 +01:00 |
|
GroovieGermanikus
|
4d5bce1b5e
|
split autoreconnect + multiplex
|
2023-12-15 10:09:13 +01:00 |
|
GroovieGermanikus
|
3e687c8196
|
move code to experimental mod
|
2023-12-14 18:46:37 +01:00 |
|
GroovieGermanikus
|
e040abfb00
|
restore task/channel version
|
2023-12-14 18:42:27 +01:00 |
|
GroovieGermanikus
|
c7fa02d85b
|
pull out mapper
|
2023-12-14 13:09:43 +01:00 |
|
GroovieGermanikus
|
c66173afef
|
works
|
2023-12-14 12:58:47 +01:00 |
|
GroovieGermanikus
|
8e8d7c4e07
|
add drain pattern
|
2023-12-14 11:39:07 +01:00 |
|
GroovieGermanikus
|
37f76e010c
|
add experimental perfectseq
|
2023-12-14 11:37:50 +01:00 |