juplo.de Git - demos/kafka/chat/blob

   1 package de.juplo.kafka.chat.backend.implementation.haproxy;
   2
   3 import de.juplo.kafka.chat.backend.domain.ShardingPublisherStrategy;
   4 import lombok.RequiredArgsConstructor;
   5 import lombok.extern.slf4j.Slf4j;
   6 import reactor.core.publisher.Mono;
   7
   8
   9 @RequiredArgsConstructor
  10 @Slf4j
  11 public class HaproxyShardingPublisherStrategy implements ShardingPublisherStrategy
  12 {
  13   private final String host;
  14   private final int port;
  15   private final String instanceId;
  16
  17
  18   @Override
  19   public Mono<String> publishOwnership(int shard)
  20   {
  21     return Mono.error(new RuntimeException("TODO"));
  22   }
  23 }