Andrea Cavalli a14f8e1f0e Allow the use of local sockets		2022-11-09 18:56:28 +01:00
..
kafka	Remove required kafka dependency, zero-copy deserialization	2022-10-07 16:03:51 +02:00
rsocket	Allow the use of local sockets	2022-11-09 18:56:28 +01:00
transformer	Remove encryption key phase	2022-10-17 13:26:53 +02:00
AtomixReactiveApi.java	Fix some connection errors	2022-10-12 18:31:44 +02:00
AuthPhase.java	Remove encryption key phase	2022-10-17 13:26:53 +02:00
BaseAtomixReactiveApiClient.java	Fix missing serialized data	2022-10-13 12:40:30 +02:00
Channel.java	Add RSocket	2022-10-05 02:26:30 +02:00
ChannelCodec.java	Remove required kafka dependency, zero-copy deserialization	2022-10-07 16:03:51 +02:00
ChannelConsumerClientBoundEvent.java	Improve tests	2022-10-06 00:36:00 +02:00
ChannelConsumerTdlibRequest.java	Improve tests	2022-10-06 00:36:00 +02:00
ChannelConsumerTdlibResponse.java	Improve tests	2022-10-06 00:36:00 +02:00
ChannelFactory.java	Allow the use of local sockets	2022-11-09 18:56:28 +01:00
ChannelProducerClientBoundEvent.java	Improve tests	2022-10-06 00:36:00 +02:00
ChannelProducerTdlibRequest.java	Improve tests	2022-10-06 00:36:00 +02:00
ChannelProducerTdlibResponse.java	Improve tests	2022-10-06 00:36:00 +02:00
ChannelsParameters.java	Add RSocket	2022-10-05 02:26:30 +02:00
Cli.java	Store resulting events and events into a disk queue	2022-10-10 01:05:53 +02:00
ClientBoundEventDeserializer.java	Remove required kafka dependency, zero-copy deserialization	2022-10-07 16:03:51 +02:00
ClientBoundEventSerializer.java	Remove required kafka dependency, zero-copy deserialization	2022-10-07 16:03:51 +02:00
ClientBoundResultingEventSerializer.java	Store resulting events and events into a disk queue	2022-10-10 01:05:53 +02:00
ClusterBoundResultingEventDeserializer.java	Improve queues	2022-10-10 20:30:32 +02:00
ClusterBoundResultingEventSerializer.java	Improve queues	2022-10-10 20:30:32 +02:00
ClusterSettings.java	Improve tests	2022-10-06 00:36:00 +02:00
CreateSessionRequest.java	Implement lanes	2022-09-22 15:46:31 +02:00
CreateSessionResponse.java	Migrate from Atomix to Kafka	2022-06-27 00:06:53 +02:00
Deserializer.java	Remove required kafka dependency, zero-copy deserialization	2022-10-07 16:03:51 +02:00
DiskSession.java	Main lane	2022-09-22 16:05:56 +02:00
DiskSessions.java	Rewrite local sessions management	2021-12-05 23:47:54 +01:00
DiskSessionsManager.java	Rewrite using atomix	2021-12-05 15:15:28 +01:00
Entrypoint.java	Store resulting events and events into a disk queue	2022-10-10 01:05:53 +02:00
Event.java	Single consumers and producers	2022-09-10 20:25:54 +02:00
EventConsumer.java	Fix sockets	2022-10-06 19:06:35 +02:00
EventProducer.java	Fix sockets	2022-10-06 19:06:35 +02:00
InstanceSettings.java	Add RSocket	2022-10-05 02:26:30 +02:00
InstanceType.java	Add RSocket	2022-10-05 02:26:30 +02:00
KafkaParameters.java	Add RSocket	2022-10-05 02:26:30 +02:00
Lanes.java	Main lane	2022-09-22 16:05:56 +02:00
LiveAtomixReactiveApiClient.java	Improve tests	2022-10-06 00:36:00 +02:00
RSocketParameters.java	Allow the use of local sockets	2022-11-09 18:56:28 +01:00
ReactiveApi.java	Fix performance problems	2022-09-13 22:15:18 +02:00
ReactiveApiClient.java	Fix performance problems	2022-09-13 22:15:18 +02:00
ReactiveApiMultiClient.java	Implement lanes	2022-09-22 15:46:31 +02:00
ReactiveApiPublisher.java	fix	2022-10-31 14:06:25 +01:00
ReactiveApiThinClient.java	Fix performance problems	2022-09-13 22:15:18 +02:00
ReactorUtils.java	Fix some connection errors	2022-10-12 18:31:44 +02:00
ResultingEvent.java	Migrate from Atomix to Kafka	2022-06-27 00:06:53 +02:00
ResultingEventTransformer.java	Implement event transformers	2022-01-09 18:27:14 +01:00
SchedulerExecutor.java	Create sessions using reactor core	2021-12-09 18:48:06 +01:00
SerializationException.java	Remove required kafka dependency, zero-copy deserialization	2022-10-07 16:03:51 +02:00
Serializer.java	Remove required kafka dependency, zero-copy deserialization	2022-10-07 16:03:51 +02:00
SignalUtils.java	Store resulting events and events into a disk queue	2022-10-10 01:05:53 +02:00
SimpleEventProducer.java	Sockets are working	2022-10-07 00:48:10 +02:00
State.java	Remove encryption key phase	2022-10-17 13:26:53 +02:00
Stats.java	Fix some connection errors	2022-10-12 18:31:44 +02:00
TdError.java	Implement live and dynamic clients	2022-01-07 23:54:18 +01:00
TdlibBoundResultingEventDeserializer.java	Improve queues	2022-10-10 20:30:32 +02:00
TdlibBoundResultingEventSerializer.java	Improve queues	2022-10-10 20:30:32 +02:00
TdlibChannelsClients.java	Code cleanup	2022-10-04 12:43:24 +02:00
TdlibChannelsServers.java	Code cleanup	2022-10-04 12:43:24 +02:00
TdlibChannelsSharedHost.java	Fix some connection errors	2022-10-12 18:31:44 +02:00
TdlibChannelsSharedReceive.java	Code cleanup	2022-10-08 13:44:32 +02:00
TdlibDeserializer.java	Remove required kafka dependency, zero-copy deserialization	2022-10-07 16:03:51 +02:00
TdlibRequestDeserializer.java	Remove required kafka dependency, zero-copy deserialization	2022-10-07 16:03:51 +02:00
TdlibRequestSerializer.java	Remove required kafka dependency, zero-copy deserialization	2022-10-07 16:03:51 +02:00
TdlibResponseDeserializer.java	Remove required kafka dependency, zero-copy deserialization	2022-10-07 16:03:51 +02:00
TdlibResponseSerializer.java	Remove required kafka dependency, zero-copy deserialization	2022-10-07 16:03:51 +02:00
TdlibSerializer.java	Remove required kafka dependency, zero-copy deserialization	2022-10-07 16:03:51 +02:00
Timestamped.java	Migrate from Atomix to Kafka	2022-06-27 00:06:53 +02:00
TransportFactory.java	Allow the use of local sockets	2022-11-09 18:56:28 +01:00
TransportFactoryLocal.java	Allow the use of local sockets	2022-11-09 18:56:28 +01:00
TransportFactoryTcp.java	Allow the use of local sockets	2022-11-09 18:56:28 +01:00
UserIdAndLiveId.java	Implement periodic restarter	2022-01-09 20:20:20 +01:00
UtfCodec.java	Remove required kafka dependency, zero-copy deserialization	2022-10-07 16:03:51 +02:00