Commit Graph

244 Commits

Author SHA1 Message Date
Andrea Cavalli
a14f8e1f0e Allow the use of local sockets 2022-11-09 18:56:28 +01:00
Andrea Cavalli
e5712361e0 fix 2022-10-31 14:06:25 +01:00
Andrea Cavalli
88f68f96f3 Update logging 2022-10-17 15:30:22 +02:00
Andrea Cavalli
e27ffc8d92 Remove encryption key phase 2022-10-17 13:26:53 +02:00
Andrea Cavalli
dd70f2492c Fix missing serialized data 2022-10-13 12:40:30 +02:00
Andrea Cavalli
677ceb70a1 Fix some connection errors 2022-10-12 18:31:44 +02:00
Andrea Cavalli
58770ca649 Improve support for local cancellation 2022-10-12 14:31:41 +02:00
Andrea Cavalli
171f07ccec Code cleanup 2022-10-11 20:08:47 +02:00
Andrea Cavalli
24b4387b08 Accept multiple tdlib clients 2022-10-11 20:08:40 +02:00
Andrea Cavalli
a8510ed336 Use LMDB queues 2022-10-11 00:24:51 +02:00
Andrea Cavalli
abf9f28484 Improve queues 2022-10-10 20:30:32 +02:00
Andrea Cavalli
708fcbd1e4 Store resulting events and events into a disk queue 2022-10-10 01:05:53 +02:00
Andrea Cavalli
59027e8e62 Code cleanup 2022-10-08 13:44:32 +02:00
Andrea Cavalli
1eb1d7b95f Code cleanup 2022-10-08 03:12:50 +02:00
Andrea Cavalli
edb8cec873 Remove buffering 2022-10-07 17:50:34 +02:00
Andrea Cavalli
3bed3052d0 Remove required kafka dependency, zero-copy deserialization 2022-10-07 16:03:51 +02:00
Andrea Cavalli
705e5ca65e Sockets are working 2022-10-07 00:48:10 +02:00
Andrea Cavalli
0a74e1ab1a Fix sockets 2022-10-06 19:06:35 +02:00
Andrea Cavalli
5dc543f090 Improve tests 2022-10-06 00:36:00 +02:00
Andrea Cavalli
ba093e4c27 rsocket 2022-10-05 03:37:24 +02:00
Andrea Cavalli
03b8cfa579 Add RSocket 2022-10-05 02:26:30 +02:00
Andrea Cavalli
a93d6d4e24 Code cleanup 2022-10-04 12:43:24 +02:00
Andrea Cavalli
116e082d56 Fix resubscription failures 2022-09-30 15:25:06 +02:00
Andrea Cavalli
2b2e690da4 Code cleanup 2022-09-22 16:26:55 +02:00
Andrea Cavalli
b322400d87 Main lane 2022-09-22 16:05:56 +02:00
Andrea Cavalli
83c064220f Implement lanes 2022-09-22 15:46:31 +02:00
Andrea Cavalli
dfc393c953 Retries 2022-09-22 03:01:59 +02:00
Andrea Cavalli
41be43d711 Bugfixes 2022-09-22 02:26:22 +02:00
Andrea Cavalli
8651ce3e97 Fix performance problems 2022-09-13 22:15:18 +02:00
Andrea Cavalli
5e40530a20 Bugfixes 2022-09-11 17:36:15 +02:00
Andrea Cavalli
83613b2d01 Quick/Slow response mode, no acks, filtering instead of grouping 2022-09-10 23:12:35 +02:00
Andrea Cavalli
bd463a74d2 Single consumers and producers 2022-09-10 20:25:54 +02:00
Andrea Cavalli
aa12013479 Optimize consumer 2022-09-10 13:36:38 +02:00
Andrea Cavalli
202a90846b Update kafka producer 2022-09-07 15:29:46 +02:00
Andrea Cavalli
a77442bae5 More detailed logs 2022-09-05 23:31:39 +02:00
Andrea Cavalli
d2f74d7bbb Update commit batch size 2022-07-28 23:40:26 +02:00
Andrea Cavalli
fd658e5e6c Retry commit failures 2022-07-25 22:10:24 +02:00
Andrea Cavalli
d931217e81 Implement timeouts properly 2022-06-28 00:11:34 +02:00
Andrea Cavalli
07c22d39f2 Avoid possible leaks 2022-06-27 00:32:02 +02:00
Andrea Cavalli
6339f78db8 Migrate from Atomix to Kafka 2022-06-27 00:06:53 +02:00
Andrea Cavalli
84bee0da20 Load chats on boot 2022-05-26 16:21:56 +02:00
Andrea Cavalli
cc3bdc76c5 Include version 2022-05-05 20:25:00 +02:00
Andrea Cavalli
b44fb2b20c Update record builder 2022-04-13 19:48:36 +02:00
Andrea Cavalli
afa70c75d9 Fix syntax 2022-04-09 23:51:56 +02:00
Andrea Cavalli
7b25092fa8 Java modules 2022-04-09 02:48:01 +02:00
Andrea Cavalli
8645231031 Improve kafka logging, update tdlib 2022-03-21 01:08:12 +01:00
Andrea Cavalli
5cf00542da Initialize client, print errors 2022-03-19 01:36:24 +01:00
Andrea Cavalli
c92f0aa589 Update dependencies 2022-03-19 00:06:30 +01:00
Andrea Cavalli
d7ffd8bfa2 Use netty 5 alpha 2022-03-16 13:53:01 +01:00
Andrea Cavalli
958d04519b Fix event transformers 2022-03-06 13:27:29 +01:00