path # lines of code pekko-sample-cluster-client-grpc-java/src/main/java/sample/cluster/client/grpc/ClusterClient.java 198 pekko-sample-cluster-client-grpc-java/src/main/java/sample/cluster/client/grpc/CborSerializable.java 2 pekko-sample-cluster-client-grpc-java/src/main/java/sample/cluster/client/grpc/ClusterClientSettings.java 20 pekko-sample-cluster-client-grpc-java/src/main/java/sample/cluster/client/grpc/ClusterClientReceptionist.java 84 pekko-sample-cluster-client-grpc-java/src/main/java/sample/cluster/client/grpc/ClusterReceptionistSettings.java 43 pekko-sample-cluster-client-grpc-java/src/main/java/sample/cluster/client/grpc/ClusterClientReceptionistGrpcImpl.java 92 pekko-sample-cluster-client-grpc-java/src/main/java/sample/cluster/client/grpc/ClusterClientSerialization.java 31 pekko-sample-cluster-client-grpc-java/src/main/protobuf/clusterclient.proto 36 pekko-sample-persistence-java/src/main/java/sample/persistence/CborSerializable.java 3 pekko-sample-persistence-java/src/main/java/sample/persistence/ShoppingCart.java 278 pekko-sample-persistence-java/src/main/resources/logback.xml 15 pekko-sample-cluster-docker-compose-scala/src/main/scala/com/example/ClusterListener.scala 32 pekko-sample-cluster-docker-compose-scala/src/main/scala/com/example/ClusteringApp.scala 8 pekko-sample-cluster-docker-compose-scala/src/main/resources/logback.xml 16 pekko-sample-cluster-docker-compose-scala/project/plugins.sbt 1 pekko-sample-cluster-docker-compose-scala/build.sbt 19 pekko-sample-cluster-java/src/main/java/sample/cluster/CborSerializable.java 2 pekko-sample-cluster-java/src/main/java/sample/cluster/transformation/App.java 51 pekko-sample-cluster-java/src/main/java/sample/cluster/transformation/Worker.java 39 pekko-sample-cluster-java/src/main/java/sample/cluster/transformation/Frontend.java 102 pekko-sample-cluster-java/src/main/java/sample/cluster/simple/App.java 32 pekko-sample-cluster-java/src/main/java/sample/cluster/simple/ClusterListener.java 64 pekko-sample-cluster-java/src/main/java/sample/cluster/stats/AppOneMaster.java 78 pekko-sample-cluster-java/src/main/java/sample/cluster/stats/App.java 64 pekko-sample-cluster-java/src/main/java/sample/cluster/stats/StatsService.java 75 pekko-sample-cluster-java/src/main/java/sample/cluster/stats/StatsAggregator.java 63 pekko-sample-cluster-java/src/main/java/sample/cluster/stats/StatsClient.java 36 pekko-sample-cluster-java/src/main/java/sample/cluster/stats/StatsWorker.java 66 pekko-sample-cluster-java/src/main/resources/logback.xml 16 pekko-sample-cluster-java/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSingleMasterSpec.scala 69 pekko-sample-cluster-java/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala 78 pekko-sample-cluster-java/project/plugins.sbt 2 pekko-sample-cluster-java/build.sbt 26 pekko-sample-kafka-to-sharding-scala/project/plugins.sbt 4 pekko-sample-kafka-to-sharding-scala/kafka/src/main/scala/sample/sharding/embeddedkafka/KafkaBroker.scala 15 pekko-sample-kafka-to-sharding-scala/kafka/src/main/resources/logback.xml 20 pekko-sample-kafka-to-sharding-scala/client/src/main/scala/client/ClientApp.scala 29 pekko-sample-kafka-to-sharding-scala/client/src/main/protobuf/users.proto 15 pekko-sample-kafka-to-sharding-scala/processor/src/main/scala/sample/sharding/kafka/ProcessorSettings.scala 31 pekko-sample-kafka-to-sharding-scala/processor/src/main/scala/sample/sharding/kafka/UserEventsKafkaProcessor.scala 70 pekko-sample-kafka-to-sharding-scala/processor/src/main/scala/sample/sharding/kafka/Main.scala 103 pekko-sample-kafka-to-sharding-scala/processor/src/main/scala/sample/sharding/kafka/UserEvents.scala 50 pekko-sample-kafka-to-sharding-scala/processor/src/main/scala/sample/sharding/kafka/UserGrpcService.scala 17 pekko-sample-kafka-to-sharding-scala/processor/src/main/scala/sample/sharding/kafka/CborSerializable.scala 2 pekko-sample-kafka-to-sharding-scala/processor/src/main/resources/logback.xml 13 pekko-sample-kafka-to-sharding-scala/processor/src/main/protobuf/users.proto 15 pekko-sample-kafka-to-sharding-scala/processor/src/main/protobuf/user-events.proto 15 pekko-sample-kafka-to-sharding-scala/build.sbt 61 pekko-sample-kafka-to-sharding-scala/producer/src/main/scala/sharding/kafka/producer/UserEventProducer.scala 44 pekko-sample-kafka-to-sharding-scala/producer/src/main/scala/sharding/kafka/producer/ProducerConfig.scala 11 pekko-sample-kafka-to-sharding-scala/producer/src/main/resources/logback.xml 15 pekko-sample-kafka-to-sharding-scala/producer/src/main/protobuf/user-events.proto 15 pekko-sample-persistence-dc-scala/src/main/scala/sample/persistence/res/movielist/MovieWatchList.scala 39 pekko-sample-persistence-dc-scala/src/main/scala/sample/persistence/res/auction/Auction.scala 197 pekko-sample-persistence-dc-scala/src/main/scala/sample/persistence/res/bank/BankAccount.scala 75 pekko-sample-persistence-dc-scala/src/main/scala/sample/persistence/res/CborSerializable.scala 2 pekko-sample-persistence-dc-scala/src/main/scala/sample/persistence/res/MainApp.scala 73 pekko-sample-persistence-dc-scala/src/main/scala/sample/persistence/res/counter/ThumbsUpHttp.scala 46 pekko-sample-persistence-dc-scala/src/main/scala/sample/persistence/res/counter/ThumbsUpCounter.scala 53 pekko-sample-persistence-dc-scala/src/main/resources/logback.xml 20 pekko-sample-persistence-dc-scala/project/plugins.sbt 1 pekko-sample-persistence-dc-scala/build.sbt 28 pekko-sample-cluster-kubernetes-scala/src/main/scala/pekko/sample/cluster/kubernetes/DemoApp.scala 29 pekko-sample-cluster-kubernetes-scala/src/main/scala/pekko/sample/cluster/kubernetes/DemoHealthCheck.scala 11 pekko-sample-cluster-kubernetes-scala/src/main/resources/logback.xml 17 pekko-sample-cluster-kubernetes-scala/project/plugins.sbt 2 pekko-sample-cluster-kubernetes-scala/build.sbt 37 pekko-sample-distributed-workers-scala/src/main/scala/worker/WorkManager.scala 103 pekko-sample-distributed-workers-scala/src/main/scala/worker/Worker.scala 63 pekko-sample-distributed-workers-scala/src/main/scala/worker/Main.scala 82 pekko-sample-distributed-workers-scala/src/main/scala/worker/Work.scala 3 pekko-sample-distributed-workers-scala/src/main/scala/worker/WorkState.scala 45 pekko-sample-distributed-workers-scala/src/main/scala/worker/FrontEnd.scala 67 pekko-sample-distributed-workers-scala/src/main/scala/worker/WorkResultConsumerActor.scala 29 pekko-sample-distributed-workers-scala/src/main/scala/worker/WorkExecutor.scala 26 pekko-sample-distributed-workers-scala/src/main/scala/worker/WorkManagerSingleton.scala 17 pekko-sample-distributed-workers-scala/src/main/scala/worker/CborSerializable.scala 2 pekko-sample-distributed-workers-scala/src/main/resources/logback.xml 11 pekko-sample-distributed-workers-scala/build.sbt 18 pekko-sample-distributed-data-scala/src/main/scala/sample/distributeddata/ReplicatedCache.scala 56 pekko-sample-distributed-data-scala/src/main/scala/sample/distributeddata/ReplicatedMetrics.scala 116 pekko-sample-distributed-data-scala/src/main/scala/sample/distributeddata/VotingService.scala 89 pekko-sample-distributed-data-scala/src/main/scala/sample/distributeddata/ShoppingCart.scala 106 pekko-sample-distributed-data-scala/src/main/resources/logback.xml 15 pekko-sample-distributed-data-scala/src/multi-jvm/scala/sample/distributeddata/STMultiNodeSpec.scala 10 pekko-sample-distributed-data-scala/src/multi-jvm/scala/sample/distributeddata/ShoppingCartSpec.scala 88 pekko-sample-distributed-data-scala/src/multi-jvm/scala/sample/distributeddata/ReplicatedMetricsSpec.scala 81 pekko-sample-distributed-data-scala/src/multi-jvm/scala/sample/distributeddata/VotingServiceSpec.scala 84 pekko-sample-distributed-data-scala/src/multi-jvm/scala/sample/distributeddata/ReplicatedCacheSpec.scala 111 pekko-sample-distributed-data-scala/project/plugins.sbt 1 pekko-sample-distributed-data-scala/build.sbt 28 pekko-sample-cluster-kubernetes-java/src/main/resources/logback.xml 17 pekko-sample-cluster-docker-compose-java/src/main/java/com/example/ClusteringApp.java 11 pekko-sample-cluster-docker-compose-java/src/main/java/com/example/ClusterListener.java 37 pekko-sample-cluster-docker-compose-java/src/main/resources/logback.xml 16 pekko-sample-cluster-docker-compose-java/project/plugins.sbt 1 pekko-sample-cluster-docker-compose-java/build.sbt 19 pekko-sample-cluster-client-grpc-scala/src/main/scala/sample/cluster/client/grpc/ClusterClientReceptionist.scala 86 pekko-sample-cluster-client-grpc-scala/src/main/scala/sample/cluster/client/grpc/ClusterClientReceptionistGrpcImpl.scala 83 pekko-sample-cluster-client-grpc-scala/src/main/scala/sample/cluster/client/grpc/ClusterClient.scala 141 pekko-sample-cluster-client-grpc-scala/src/main/scala/sample/cluster/client/grpc/CborSerializable.scala 2 pekko-sample-cluster-client-grpc-scala/src/main/scala/sample/cluster/client/grpc/ClusterClientSerialization.scala 18 pekko-sample-cluster-client-grpc-scala/src/main/protobuf/clusterclient.proto 36 pekko-sample-cluster-client-grpc-scala/src/multi-jvm/scala/sample/cluster/client/grpc/ClusterClientSpec.scala 195 pekko-sample-cluster-client-grpc-scala/project/plugins.sbt 3 pekko-sample-cluster-client-grpc-scala/build.sbt 26 pekko-sample-persistence-scala/src/main/scala/sample/persistence/ShoppingCart.scala 136 pekko-sample-persistence-scala/src/main/scala/sample/persistence/CborSerializable.scala 2 pekko-sample-persistence-scala/src/main/resources/logback.xml 15 pekko-sample-persistence-scala/project/plugins.sbt 1 pekko-sample-persistence-scala/build.sbt 15 pekko-sample-fsm-java/src/main/java/sample/Hakker.java 108 pekko-sample-fsm-java/src/main/java/sample/Chopstick.java 78 pekko-sample-fsm-java/src/main/java/sample/DiningHakkers.java 35 pekko-sample-fsm-java/src/main/resources/logback.xml 15 docs-gen/project/PekkoSamplePlugin.scala 56 docs-gen/project/plugins.sbt 1 docs-gen/build.sbt 75 pekko-sample-grpc-kubernetes-scala/project/plugins.sbt 3 pekko-sample-grpc-kubernetes-scala/http-to-grpc/src/main/scala/com/example/helloworld/HttpToGrpc.scala 48 pekko-sample-grpc-kubernetes-scala/http-to-grpc/src/main/resources/logback.xml 17 pekko-sample-grpc-kubernetes-scala/http-to-grpc/src/main/protobuf/helloworld.proto 14 pekko-sample-grpc-kubernetes-scala/build.sbt 36 pekko-sample-grpc-kubernetes-scala/grpc-service/src/main/scala/com/example/helloworld/GreeterServiceImpl.scala 27 pekko-sample-grpc-kubernetes-scala/grpc-service/src/main/scala/com/example/helloworld/GreeterServer.scala 26 pekko-sample-grpc-kubernetes-scala/grpc-service/src/main/protobuf/helloworld.proto 14 pekko-sample-sharding-scala/killrweather-fog/src/main/scala/sample/killrweather/fog/Fog.scala 49 pekko-sample-sharding-scala/killrweather-fog/src/main/scala/sample/killrweather/fog/WeatherStation.scala 76 pekko-sample-sharding-scala/killrweather-fog/src/main/resources/logback.xml 18 pekko-sample-sharding-scala/killrweather/src/main/scala/sample/killrweather/JsonFormats.scala 33 pekko-sample-sharding-scala/killrweather/src/main/scala/sample/killrweather/JacksonSerializers.scala 43 pekko-sample-sharding-scala/killrweather/src/main/scala/sample/killrweather/WeatherHttpServer.scala 38 pekko-sample-sharding-scala/killrweather/src/main/scala/sample/killrweather/Guardian.scala 11 pekko-sample-sharding-scala/killrweather/src/main/scala/sample/killrweather/WeatherRoutes.scala 51 pekko-sample-sharding-scala/killrweather/src/main/scala/sample/killrweather/WeatherStation.scala 96 pekko-sample-sharding-scala/killrweather/src/main/scala/sample/killrweather/KillrWeather.scala 28 pekko-sample-sharding-scala/killrweather/src/main/scala/sample/killrweather/CborSerializable.scala 2 pekko-sample-sharding-scala/killrweather/src/main/resources/logback.xml 18 pekko-sample-sharding-scala/build.sbt 55 pekko-sample-cluster-scala/src/main/scala/sample/cluster/transformation/Frontend.scala 57 pekko-sample-cluster-scala/src/main/scala/sample/cluster/transformation/Worker.scala 23 pekko-sample-cluster-scala/src/main/scala/sample/cluster/transformation/App.scala 44 pekko-sample-cluster-scala/src/main/scala/sample/cluster/simple/App.scala 27 pekko-sample-cluster-scala/src/main/scala/sample/cluster/simple/ClusterListener.scala 44 pekko-sample-cluster-scala/src/main/scala/sample/cluster/CborSerializable.scala 2 pekko-sample-cluster-scala/src/main/scala/sample/cluster/stats/StatsClient.scala 26 pekko-sample-cluster-scala/src/main/scala/sample/cluster/stats/App.scala 56 pekko-sample-cluster-scala/src/main/scala/sample/cluster/stats/StatsService.scala 61 pekko-sample-cluster-scala/src/main/scala/sample/cluster/stats/AppOneMaster.scala 69 pekko-sample-cluster-scala/src/main/scala/sample/cluster/stats/StatsWorker.scala 40 pekko-sample-cluster-scala/src/main/resources/logback.xml 16 pekko-sample-cluster-scala/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSingleMasterSpec.scala 82 pekko-sample-cluster-scala/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala 85 pekko-sample-cluster-scala/project/plugins.sbt 2 pekko-sample-cluster-scala/build.sbt 26 pekko-sample-fsm-scala/src/main/scala/sample/DiningHakkers.scala 148 pekko-sample-fsm-scala/src/main/resources/logback.xml 15 pekko-sample-fsm-scala/project/plugins.sbt 1 pekko-sample-fsm-scala/build.sbt 10 pekko-sample-persistence-dc-java/src/main/java/sample/persistence/res/MainApp.java 72 pekko-sample-persistence-dc-java/src/main/java/sample/persistence/res/CborSerializable.java 3 pekko-sample-persistence-dc-java/src/main/java/sample/persistence/res/movielist/MovieWatchList.java 74 pekko-sample-persistence-dc-java/src/main/java/sample/persistence/res/auction/AuctionEntity.java 303 pekko-sample-persistence-dc-java/src/main/java/sample/persistence/res/bank/BankAccount.java 128 pekko-sample-persistence-dc-java/src/main/java/sample/persistence/res/counter/ThumbsUpHttp.java 55 pekko-sample-persistence-dc-java/src/main/java/sample/persistence/res/counter/ThumbsUpCounter.java 104 pekko-sample-persistence-dc-java/src/main/resources/logback.xml 20 pekko-sample-sharding-java/killrweather-fog/src/main/java/sample/killrweather/fog/WeatherStation.java 101 pekko-sample-sharding-java/killrweather-fog/src/main/java/sample/killrweather/fog/FogSettings.java 24 pekko-sample-sharding-java/killrweather-fog/src/main/java/sample/killrweather/fog/Guardian.java 26 pekko-sample-sharding-java/killrweather-fog/src/main/java/sample/killrweather/fog/Data.java 11 pekko-sample-sharding-java/killrweather-fog/src/main/java/sample/killrweather/fog/Fog.java 16 pekko-sample-sharding-java/killrweather-fog/src/main/resources/logback.xml 18 pekko-sample-sharding-java/project/plugins.sbt 1 pekko-sample-sharding-java/killrweather/src/main/java/sample/killrweather/KillrWeather.java 39 pekko-sample-sharding-java/killrweather/src/main/java/sample/killrweather/WeatherRoutes.java 75 pekko-sample-sharding-java/killrweather/src/main/java/sample/killrweather/WeatherStation.java 187 pekko-sample-sharding-java/killrweather/src/main/java/sample/killrweather/CborSerializable.java 3 pekko-sample-sharding-java/killrweather/src/main/java/sample/killrweather/Guardian.java 13 pekko-sample-sharding-java/killrweather/src/main/java/sample/killrweather/WeatherHttpServer.java 46 pekko-sample-sharding-java/killrweather/src/main/resources/logback.xml 18 pekko-sample-sharding-java/build.sbt 46 pekko-sample-distributed-data-java/src/main/java/sample/distributeddata/ShoppingCart.java 237 pekko-sample-distributed-data-java/src/main/java/sample/distributeddata/VotingService.java 177 pekko-sample-distributed-data-java/src/main/java/sample/distributeddata/ReplicatedMetrics.java 200 pekko-sample-distributed-data-java/src/main/java/sample/distributeddata/ReplicatedCache.java 176 pekko-sample-distributed-data-java/src/main/resources/logback.xml 15 pekko-sample-distributed-data-java/src/multi-jvm/scala/sample/distributeddata/STMultiNodeSpec.scala 10 pekko-sample-distributed-data-java/src/multi-jvm/scala/sample/distributeddata/ShoppingCartSpec.scala 91 pekko-sample-distributed-data-java/src/multi-jvm/scala/sample/distributeddata/ReplicatedMetricsSpec.scala 83 pekko-sample-distributed-data-java/src/multi-jvm/scala/sample/distributeddata/VotingServiceSpec.scala 87 pekko-sample-distributed-data-java/src/multi-jvm/scala/sample/distributeddata/ReplicatedCacheSpec.scala 111 pekko-sample-distributed-data-java/project/plugins.sbt 1 pekko-sample-distributed-data-java/build.sbt 28