This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-persistence-dynamodb.git
The following commit(s) were added to refs/heads/main by this push:
new 1541d2d Update PekkoCoreDependency version to 2.0.0-M1 (#254)
1541d2d is described below
commit 1541d2d112a11b4542b3ff68bdd5fe3dbf685326
Author: PJ Fanning <[email protected]>
AuthorDate: Wed Dec 10 11:53:36 2025 +0100
Update PekkoCoreDependency version to 2.0.0-M1 (#254)
* Update PekkoCoreDependency version to 2.0.0-M1
* Update WriteThroughputBench.scala
---
project/PekkoCoreDependency.scala | 2 +-
.../dynamodb/journal/WriteThroughputBench.scala | 27 +++++++++++++++-------
2 files changed, 20 insertions(+), 9 deletions(-)
diff --git a/project/PekkoCoreDependency.scala
b/project/PekkoCoreDependency.scala
index 61d5bd7..c127cb6 100644
--- a/project/PekkoCoreDependency.scala
+++ b/project/PekkoCoreDependency.scala
@@ -20,5 +20,5 @@ import com.github.pjfanning.pekkobuild.PekkoDependency
object PekkoCoreDependency extends PekkoDependency {
override val checkProject: String = "pekko-cluster-sharding-typed"
override val module: Option[String] = None
- override val currentVersion: String = "1.3.0"
+ override val currentVersion: String = "2.0.0-M1"
}
diff --git
a/src/test/scala-2/org/apache/pekko/persistence/dynamodb/journal/WriteThroughputBench.scala
b/src/test/scala-2/org/apache/pekko/persistence/dynamodb/journal/WriteThroughputBench.scala
index aabadfd..2b3b804 100644
---
a/src/test/scala-2/org/apache/pekko/persistence/dynamodb/journal/WriteThroughputBench.scala
+++
b/src/test/scala-2/org/apache/pekko/persistence/dynamodb/journal/WriteThroughputBench.scala
@@ -13,11 +13,12 @@
package org.apache.pekko.persistence.dynamodb.journal
-import org.apache.pekko.actor._
-import org.apache.pekko.persistence._
-import org.apache.pekko.stream._
-import org.apache.pekko.stream.scaladsl.GraphDSL.Implicits._
-import org.apache.pekko.stream.scaladsl._
+import org.apache.pekko
+import pekko.actor._
+import pekko.persistence._
+import pekko.stream._
+import pekko.stream.scaladsl.GraphDSL.Implicits._
+import pekko.stream.scaladsl._
import com.typesafe.config.ConfigFactory
import org.HdrHistogram.Histogram
@@ -127,7 +128,7 @@ writer-dispatcher {
.withFallback(ConfigFactory.load())
implicit val system: ActorSystem = ActorSystem("WriteThroughputBench",
config)
- implicit val materializer: ActorMaterializer =
+ implicit val materializer: Materializer =
ActorMaterializer(ActorMaterializerSettings(system).withInputBuffer(1, 1))
/*
@@ -139,15 +140,25 @@ writer-dispatcher {
val writers = system.settings.config.getInt("writers")
+ val completionMatcher: PartialFunction[Any, CompletionStrategy] = {
+ case pekko.actor.Status.Success(s: CompletionStrategy) => s
+ case pekko.actor.Status.Success(_) =>
CompletionStrategy.Draining
+ case pekko.actor.Status.Success =>
CompletionStrategy.Draining
+ }
+
+ val failureMatcher: PartialFunction[Any, Throwable] = {
+ case pekko.actor.Status.Failure(cause) => cause
+ }
+
val endToEnd = Source
- .actorRef[Report](3 * writers, OverflowStrategy.dropHead)
+ .actorRef[Report](completionMatcher, failureMatcher, 3 * writers,
OverflowStrategy.dropHead)
.conflate(_ + _)
.prepend(Source.single(Report()))
.expand(Iterator.continually(_))
.withAttributes(Attributes.asyncBoundary)
val calls = Source
- .actorRef[LatencyReport](1000, OverflowStrategy.dropNew)
+ .actorRef[LatencyReport](completionMatcher, failureMatcher, 1000,
OverflowStrategy.dropHead)
.conflateWithSeed(r => ({ val h = new Histogram(3);
h.recordValue(r.nanos); h }, new H(r.retries))) {
case ((hist, h), LatencyReport(nanos, retries)) =>
hist.recordValue(nanos)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
