Switch from Akka to Pekko (#25)

Author: jrduncans

CHANGELOG.md

@@ -1,6 +1,13 @@
 Fleam release notes
 -------------------
 
+## Fleam 8.0.0
+
+* Switch from Akka to Pekko
+  * See [Pekko migration guide](https://pekko.apache.org/docs/pekko/current/project/migration-guides.html)
+* Updates dependency versions
+* Drops Java 8 support
+
 ## Fleam 7.1.0
 
 * Updates dependency versions

NOTICE

@@ -1,15 +1,15 @@
-Fleam
+# Fleam
 Copyright 2020-present, Nike, Inc. (http://nike.com)
 All rights reserved.
 The Nike Fleam software is licensed under the Apache-2.0 license found in the LICENSE.txt file included in the root directory of the project source tree.
 
 ** Free and Open-Source Software Notices:
 The Nike Fleam software incorporates, depends upon, interacts with, or was developed using the free and open-source software components listed below.  Please see the linked component sites for additional licensing, dependency, and use information and component source code:
 
-* Akka Streams
-project homepage/download site: https://akka.io/
-https://github.com/akka/akka
-project licensing notices: https://doc.akka.io/docs/akka/snapshot/project/licenses.html 
+* Pekko Streams
+project homepage/download site: https://pekko.apache.org
+https://github.com/apache/pekko
+project licensing notices: https://github.com/apache/pekko/blob/main/LICENSE
 /LICENSE.txt:
 Apache License
 Version 2.0, January 2004
@@ -48,20 +48,6 @@ Copyright [yyyy] [name of copyright owner]
 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.
 ---------------
-Licenses for dependency projects can be found here:
-[http://akka.io/docs/akka/snapshot/project/licenses.html]
----------------
-akka-protobuf contains the sources of Google protobuf 2.5.0 runtime support, moved into the source package `akka.protobuf` so as to avoid version conflicts. For license information see COPYING.protobuf 
-
-/COPYING.protobuf:
-Copyright 2008, Google Inc.
-All rights reserved.
-Redistribution and use in source and binary forms, with or without modification, are permitted provided that the following conditions are met:
-* Redistributions of source code must retain the above copyright notice, this list of conditions and the following disclaimer.
-* Redistributions in binary form must reproduce the above copyright notice, this list of conditions and the following disclaimer in the documentation and/or other materials provided with the distribution.
-* Neither the name of Google Inc. nor the names of its contributors may be used to endorse or promote products derived from this software without specific prior written permission.
-THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-Code generated by the Protocol Buffer compiler is owned by the owner of the input file used when generating it.  This code is not standalone and requires a support library to be linked with it.  This support library is itself covered by the above license.
 
 * AWS SDK for Java
 project homepage/download site: https://aws.amazon.com/sdk-for-java/

README.md

@@ -3,8 +3,8 @@
 ![Fleam logo][logo]
 
 Fleam is a library designed to help create disjunctive (Eithers) and more generally monadic streams using
-[Cats](https://github.com/typelevel/cats/tree/master/core/src/main/scala/cats) and [Akka
-Streams](https://doc.akka.io/docs/akka/2.6/stream/).
+[Cats](https://github.com/typelevel/cats/tree/master/core/src/main/scala/cats) and [Pekko
+Streams](https://pekko.apache.org/docs/pekko/current/stream/index.html).
 
 In the disjunctive case this means that as data flows through the stream if it becomes a `Left` it will no longer be
 processed by the disjunctive stages and will pass through continuing further down stream.
@@ -45,7 +45,7 @@ libraryDependencies ++= Seq(
 * `tickingGroupedWithin` - Like a normal `groupedWithin` except will emit an empty Seq after the elapsed `within`
   duration even if nothing has been received.
 * `SerializedByKeyBidi` - a
-  [BidiFlow](https://doc.akka.io/docs/akka/2.5.4/scala/stream/stream-graphs.html#bidirectional-flows) that limits items
+  [BidiFlow](https://pekko.apache.org/docs/pekko/current/stream/stream-graphs.html#bidirectional-flows) that limits items
   by a key to serial processing. For example an items of key `A` will while have to complete processing before another
   item of key `A` will be processed. This helps prevent concurrent operations for a key.
 * `Valve` - Slows processing during failed downstream services instead of failing fast.

aws/cloudwatch/src/main/scala/com/nike/fleam/cloudwatch/CloudWatch.scala

@@ -1,6 +1,6 @@
 package com.nike.fleam.cloudwatch
 
-import akka.stream.scaladsl.Flow
+import org.apache.pekko.stream.scaladsl.Flow
 import com.nike.fleam.configuration.GroupedWithinConfiguration
 import com.nike.fleam.logging.{Counter, Counters, MetricsLogger}
 import software.amazon.awssdk.services.cloudwatch.CloudWatchAsyncClient
@@ -82,7 +82,7 @@ object CloudWatch {
       List(CloudWatch.withInstanceId(Option(EC2MetadataUtils.getInstanceId).getOrElse("missing"))),
     filter: T => Boolean = (_: T) => true,
     now: () => Instant = () => Instant.now())(metricName: String)(implicit ec: ExecutionContext)
-    : Flow[T, T, akka.NotUsed] =
+    : Flow[T, T, org.apache.pekko.NotUsed] =
     CloudWatch
       .metricsLogger(send = wrapRequest(awsClient.putMetricData))
       .logCount(filter) { new Counter[T, PutMetricDataRequest] {

aws/cloudwatch/src/test/scala/com/nike/fleam/logging/CloudwatchTest.scala

@@ -2,7 +2,7 @@ package com.nike.fleam.cloudwatch
 
 import com.nike.fleam.configuration._
 import com.nike.fleam.logging.{Counter, Counters}
-import akka.stream.scaladsl._
+import org.apache.pekko.stream.scaladsl._
 
 import scala.concurrent.Promise
 import org.scalatest.flatspec.AnyFlatSpec

aws/sqs/src/main/scala/com/nike/fleam/sqs/SqsDelete.scala

@@ -5,7 +5,7 @@ import com.nike.fleam.configuration._
 import sqs.configuration._
 import software.amazon.awssdk.services.sqs.model._
 import software.amazon.awssdk.services.sqs.SqsAsyncClient
-import akka.stream.scaladsl._
+import org.apache.pekko.stream.scaladsl._
 import ContainsMessage.ops._
 import com.nike.fawcett.sqs._
 
@@ -113,7 +113,7 @@ class SqsDelete(
      *  @return Flow from T to BatchResult containing AWS DeleteMessageBatchResponse and results divided into successful and failed.
      */
     def toFlow[T: ContainsMessage](config: SqsProcessingConfiguration)(implicit ec: ExecutionContext):
-        Flow[T, BatchResult[T], akka.NotUsed] =
+        Flow[T, BatchResult[T], org.apache.pekko.NotUsed] =
       Flow[T]
         .via(config.groupedWithin.toFlow)
         .map(_.toList)

aws/sqs/src/main/scala/com/nike/fleam/sqs/SqsEnqueue.scala

@@ -1,7 +1,7 @@
 package com.nike.fleam
 package sqs
 
-import akka.stream.scaladsl.Flow
+import org.apache.pekko.stream.scaladsl.Flow
 import software.amazon.awssdk.services.sqs.SqsAsyncClient
 import software.amazon.awssdk.services.sqs.model._
 import com.nike.fleam.sqs.configuration.{Default, SqsProcessingConfiguration}
@@ -69,7 +69,7 @@ class SqsEnqueue(
       enqueueMessage(request)
     }
     def asFlow[T: ToMessage](sqsProcessing: SqsProcessingConfiguration = Default.Sqs.enqueueConfig)
-      (implicit ec: ExecutionContext): Flow[T, (List[T], SendMessageBatchResponse), akka.NotUsed] =
+      (implicit ec: ExecutionContext): Flow[T, (List[T], SendMessageBatchResponse), org.apache.pekko.NotUsed] =
       Flow[T]
         .via(sqsProcessing.groupedWithin.toFlow)
         .mapAsync(sqsProcessing.parallelism) { ts =>

aws/sqs/src/main/scala/com/nike/fleam/sqs/SqsReduce.scala

@@ -1,7 +1,7 @@
 package com.nike.fleam
 package sqs
 
-import akka.stream.scaladsl.{Flow, Source}
+import org.apache.pekko.stream.scaladsl.{Flow, Source}
 import sqs.configuration._
 import com.nike.fleam.configuration._
 import cats.{Order, Semigroup}
@@ -68,7 +68,7 @@ class SqsReduce(
    *  @return Flow from Item to either SqsReduceError or Items that had no duplicates
    */
   def flow[Item : Semigroup : ContainsMessage : ToMessage : Keyed[*, Either[MessageError, GroupingKey]], GroupingKey : Order]:
-      Flow[Item, Either[SqsReduceError[Item], Item], akka.NotUsed] = {
+      Flow[Item, Either[SqsReduceError[Item], Item], org.apache.pekko.NotUsed] = {
     config.grouping.toFlow[Item]
       .flatMapConcat { batch =>
 

aws/sqs/src/main/scala/com/nike/fleam/sqs/SqsRetry.scala

@@ -3,7 +3,7 @@ package sqs
 
 import java.time.Instant
 
-import akka.stream.scaladsl.Flow
+import org.apache.pekko.stream.scaladsl.Flow
 import cats.data._
 import cats.implicits._
 import software.amazon.awssdk.services.sqs.SqsAsyncClient
@@ -46,7 +46,7 @@ object SqsRetry {
   val emptyAttributes = Map.empty[String, MessageAttributeValue]
 
   type RetryResult[T] = Either[SqsRetryError[T], T]
-  type RetryFlow[T] = Flow[T, RetryResult[T], akka.NotUsed]
+  type RetryFlow[T] = Flow[T, RetryResult[T], org.apache.pekko.NotUsed]
 
   implicit val messageToMessage: ToMessage[Message] = ToMessage.lift(identity)
 
@@ -116,7 +116,7 @@ class SqsRetry(
       deadLetter: PartialFunction[In, Map[String, MessageAttributeValue]] = PartialFunction.empty,
       attributesModifier: Map[MessageSystemAttributeName, String] => Map[MessageSystemAttributeName, String] = identity,
       retryCountOverrides: PartialFunction[In, Int] = PartialFunction.empty)
-      (implicit ec: ExecutionContext): Flow[In, Either[SqsRetryError[In], In], akka.NotUsed] = {
+      (implicit ec: ExecutionContext): Flow[In, Either[SqsRetryError[In], In], org.apache.pekko.NotUsed] = {
 
     sealed trait Result
     case class Ok(in: In) extends Result

aws/sqs/src/main/scala/com/nike/fleam/sqs/SqsSource.scala

@@ -3,8 +3,8 @@ package sqs
 
 import com.nike.fleam.configuration._
 import sqs.configuration._
-import akka.stream.scaladsl._
-import akka.stream.{KillSwitches, ThrottleMode, UniqueKillSwitch}
+import org.apache.pekko.stream.scaladsl._
+import org.apache.pekko.stream.{KillSwitches, ThrottleMode, UniqueKillSwitch}
 import software.amazon.awssdk.services.sqs.SqsAsyncClient
 import software.amazon.awssdk.services.sqs.model._
 import com.nike.fawcett.sqs._