Alexander
|
43b042aef8
|
[Sink] new message iterator (#945)
* feat(backend): implemented new version of sink message iterator
|
2023-01-20 09:49:49 +01:00 |
|
Alexander
|
8a8cf4d938
|
feat(backend/sink): manually sync all files on partitions rebalanced event (#847)
|
2022-11-29 11:34:39 +01:00 |
|
Alexander Zavorotynskiy
|
70d7210e9a
|
feat(backend/sink): write big messages directly to file
|
2022-11-28 14:58:18 +01:00 |
|
Alexander
|
9e319ed27c
|
[Sink] Improved files sync algo (#831)
* feat(backend): use channel of changed sessions instead of sync.Map
* feat(backend): avoid memory alloc for message body in message iterator
* feat(backend): removed unnecessary locks in file syncer
* feat(backend): sync.Map with prev updates
* feat(backend): improved write algorith (added bufio.Writer)
* feat(backend): session writer refactoring
* feat(backend): removed unnecessary type definition
* feat(backend): added write retrier to avoid data losing
* feat(backend): refactoring
* feat(backend): added session file implementation
|
2022-11-25 17:25:55 +01:00 |
|
Alexander
|
e67c3ec876
|
[Sink] Zombie session killer feature (#829)
* feat(backend): added zombie session killer feature
|
2022-11-22 11:53:21 +01:00 |
|
Alexander
|
5a1cd27ebc
|
[Sink] Async session writer (#826)
* feat(backend): implemented async session writer module
|
2022-11-21 19:22:10 +01:00 |
|