Pekko (#257)

* migrate to Pekko
* update dep versions
* use jackson-module-guice7

Author: BrandonArp

README.md

@@ -54,7 +54,7 @@ The configuration specifies:
 * minConnectionTimeout - The minimum aggregation server client connection timeout in ISO-8601 period notation.
 * jvmMetricsCollectionInterval - The JVM metrics collection interval in ISO-8601 period notation.
 * rebalanceConfiguration - Configuration for aggregator shard rebalancing.
-* akkaConfiguration - Configuration of Akka.
+* pekkoConfiguration - Configuration of Pekko.
 
 For example:
 
@@ -74,38 +74,24 @@ For example:
     "maxParallel": 100,
     "threshold": 500
   },
-  "akkaConfiguration": {
-    "akka": {
-      "loggers": ["akka.event.slf4j.Slf4jLogger"],
+  "pekkoConfiguration": {
+    "pekko": {
+      "loggers": ["org.apache.pekko.event.slf4j.Slf4jLogger"],
       "loglevel": "DEBUG",
       "stdout-loglevel": "DEBUG",
-      "logging-filter": "akka.event.slf4j.Slf4jLoggingFilter",
+      "logging-filter": "org.apache.pekko.event.slf4j.Slf4jLoggingFilter",
       "actor": {
-        "provider": "akka.cluster.ClusterActorRefProvider",
+        "provider": "org.apache.pekko.cluster.ClusterActorRefProvider",
         "debug": {
           "unhandled": "on"
-        },
-        "serializers": {
-          "kryo": "com.romix.akka.serialization.kryo.KryoSerializer"
-        },
-        "serialization-bindings": {
-          "java.lang.Object": "kryo",
-          "java.io.Serializable": "none"
-        },
-        "kryo": {
-          "type": "graph",
-          "idstrategy": "default",
-          "buffer-size": 4096,
-          "max-buffer-size": -1,
-          "kryo-custom-serializer-init": "com.arpnetworking.clusteraggregator.kryo.KryoInitialization"
         }
       },
       "cluster": {
         "sharding": {
           "state-store-mode": "persistence"
         },
         "seed-nodes": [
-          "akka.tcp://[email protected]:2551"
+          "pekko.tcp://[email protected]:2551"
         ]
       },
       "remote": {

config/config.conf

@@ -53,22 +53,22 @@ reaggregationDimensions=["host"]
 #reaggregationInjectClusterAsHost=True
 #reaggregationTimeout="PT1M"
 
-# Akka
+# Pekko
 # ~~~~
 rebalanceConfiguration {
   maxParallel=100
   threshold=500
 }
-akkaConfiguration {
-  akka {
-    loggers=["akka.event.slf4j.Slf4jLogger"]
+pekkoConfiguration {
+  pekko {
+    loggers=["org.apache.pekko.event.slf4j.Slf4jLogger"]
     loglevel="DEBUG"
     stdout-loglevel="DEBUG"
-    logging-filter="akka.event.slf4j.Slf4jLoggingFilter"
+    logging-filter="org.apache.pekko.event.slf4j.Slf4jLoggingFilter"
     actor {
       provider="cluster"
       serializers {
-        proto="akka.remote.serialization.ProtobufSerializer"
+        proto="org.apache.pekko.remote.serialization.ProtobufSerializer"
       }
       serialization-bindings {
         "com.arpnetworking.metrics.aggregation.protocol.Messages$StatisticSetRecord"="proto"
@@ -78,8 +78,8 @@ akkaConfiguration {
       }
     }
     cluster {
-      seed-nodes=["akka://[email protected]:2551"]
-      downing-provider-class = "akka.cluster.sbr.SplitBrainResolverProvider"
+      seed-nodes=["pekko://[email protected]:2551"]
+      downing-provider-class = "org.apache.pekko.cluster.sbr.SplitBrainResolverProvider"
       sharding {
         state-store-mode="persistence"
         passivate-idle-entity-after="300s"
@@ -95,13 +95,23 @@ akkaConfiguration {
     }
     persistence {
       journal {
-        plugin = "akka.persistence.journal.leveldb"
-        leveldb.dir = "/opt/cluster-aggregator/data/journal"
+        plugin = "jdbc-journal"
       }
       snapshot-store {
-        plugin = "akka.persistence.snapshot-store.local"
-        local.dir = "/opt/cluster-aggregator/data/snapshots"
+        plugin = "jdbc-snapshot-store"
       }
     }
   }
+  slick {
+    profile = "slick.jdbc.H2Profile$"
+    db {
+      url = "jdbc:h2:mem:test-database;DATABASE_TO_UPPER=false;"
+      user = "root"
+      password = "root"
+      driver = "org.h2.Driver"
+      numThreads = 5
+      maxConnections = 5
+      minConnections = 1
+    }
+  }
 }

config/logback-docker.xml

@@ -0,0 +1,43 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~ Copyright 2014 Brandon Arp
+  ~
+  ~ Licensed under the Apache License, Version 2.0 (the "License");
+  ~ you may not use this file except in compliance with the License.
+  ~ You may obtain a copy of the License at
+  ~
+  ~     http://www.apache.org/licenses/LICENSE-2.0
+  ~
+  ~ Unless required by applicable law or agreed to in writing, software
+  ~ distributed under the License is distributed on an "AS IS" BASIS,
+  ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  ~ See the License for the specific language governing permissions and
+  ~ limitations under the License.
+  -->
+<configuration>
+    <import class="ch.qos.logback.core.ConsoleAppender"/>
+    <appender name="cagg-logger" class="ConsoleAppender">
+        <encoder class="com.arpnetworking.logback.StenoEncoder">
+            <injectContextLogger>true</injectContextLogger>
+            <compressLoggerName>true</compressLoggerName>
+            <jacksonModule class="com.fasterxml.jackson.datatype.guava.GuavaModule" />
+            <jacksonModule class="com.fasterxml.jackson.datatype.jdk8.Jdk8Module" />
+            <jacksonModule class="com.fasterxml.jackson.datatype.jsr310.JavaTimeModule" />
+            <jacksonModule class="com.arpnetworking.configuration.jackson.pekko.PekkoLoggingModule" />
+            <injectBeanIdentifier>true</injectBeanIdentifier>
+        </encoder>
+    </appender>
+
+
+    <appender name="cagg-async" class="ch.qos.logback.classic.AsyncAppender">
+        <appender-ref ref="cagg-logger"/>
+        <discardingThreshold>50</discardingThreshold>
+        <queueSize>500</queueSize>
+    </appender>
+
+    <logger name="org.reflections.Reflections" level="ERROR" />
+
+    <root level="INFO">
+        <appender-ref ref="cagg-async"/>
+    </root>
+</configuration>

config/logback.xml

@@ -32,7 +32,7 @@
             <jacksonModule class="com.fasterxml.jackson.datatype.guava.GuavaModule" />
             <jacksonModule class="com.fasterxml.jackson.datatype.jdk8.Jdk8Module" />
             <jacksonModule class="com.fasterxml.jackson.datatype.jsr310.JavaTimeModule" />
-            <jacksonModule class="com.arpnetworking.configuration.jackson.akka.AkkaLoggingModule" />
+            <jacksonModule class="com.arpnetworking.configuration.jackson.pekko.PekkoLoggingModule" />
             <injectBeanIdentifier>true</injectBeanIdentifier>
         </encoder>
     </appender>