projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 294fdfc) | patch
WIP:haproxy
authorKai Moritz <kai@juplo.de>
Sun, 17 Sep 2023 09:31:22 +0000 (11:31 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 27 Jan 2024 14:47:47 +0000 (15:47 +0100)
commitd49769418e0a340fee2ed1f1b6c7b4ab1faf8a37
treec008f3ec566e73477fadb4c2ea347942c90ac4f1tree | snapshot
parent294fdfc1fb506a5c486aab4b4ae0491c1bb0c92acommit | diff
WIP:haproxy
src/main/java/de/juplo/kafka/chat/backend/ChatBackendProperties.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/domain/ShardingPublisherStrategy.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/domain/exceptions/ShardNotOwnedException.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/haproxy/HaproxyShardingPublisherStrategy.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/implementation/inmemory/InMemoryServicesConfiguration.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/inmemory/ShardedChatHomeService.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java diff | blob | history
src/test/java/de/juplo/kafka/chat/backend/api/ChatBackendControllerTest.java diff | blob | history
src/test/java/de/juplo/kafka/chat/backend/implementation/inmemory/ShardedChatHomeServiceTest.java diff | blob | history
src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.