Skip to content

Commit

Permalink
akka to pekko naming (#348)
Browse files Browse the repository at this point in the history
  • Loading branch information
pjfanning authored Oct 30, 2023
1 parent 1242e18 commit 72221db
Show file tree
Hide file tree
Showing 9 changed files with 9 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ class ConnectionPoolBenchmark extends CommonBenchmark {
pekko.http.client.user-agent = pekko-http-bench
""")
.withFallback(ConfigFactory.load())
system = ActorSystem("AkkaHttpBenchmarkSystem", config)
system = ActorSystem("PekkoHttpBenchmarkSystem", config)
mat = ActorMaterializer()

val responseBytes = ByteString(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ class HttpEntityBenchmark extends CommonBenchmark {
pekko.actor.default-dispatcher.fork-join-executor.parallelism-max = 1
""")
.withFallback(ConfigFactory.load())
system = ActorSystem("AkkaHttpBenchmarkSystem", config)
system = ActorSystem("PekkoHttpBenchmarkSystem", config)
mat = ActorMaterializer()

entity = entityType match {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ class ServerProcessingBenchmark extends CommonBenchmark {
pekko.http.server.server-header = "pekko-http-bench"
""")
.withFallback(ConfigFactory.load())
system = ActorSystem("AkkaHttpBenchmarkSystem", config)
system = ActorSystem("PekkoHttpBenchmarkSystem", config)
mat = ActorMaterializer()
httpFlow =
Flow[HttpRequest].map(_ => response).join(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ class StreamServerProcessingBenchmark extends CommonBenchmark {
pekko.actor.default-dispatcher.fork-join-executor.parallelism-max = 1
""")
.withFallback(ConfigFactory.load())
system = ActorSystem("AkkaHttpBenchmarkSystem", config)
system = ActorSystem("PekkoHttpBenchmarkSystem", config)
mat = ActorMaterializer()

val bytesPerChunk = totalBytes.toInt / numChunks.toInt
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ class H2ClientServerBenchmark extends CommonBenchmark with H2RequestResponseBenc
def setup(): Unit = {
initRequestResponse()

system = ActorSystem("AkkaHttpBenchmarkSystem", config)
system = ActorSystem("PekkoHttpBenchmarkSystem", config)
mat = ActorMaterializer()
val settings = implicitly[ServerSettings]
val log = system.log
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ class H2ServerProcessingBenchmark extends CommonBenchmark with H2RequestResponse
def setup(): Unit = {
initRequestResponse()

system = ActorSystem("AkkaHttpBenchmarkSystem", config)
system = ActorSystem("PekkoHttpBenchmarkSystem", config)
mat = ActorMaterializer()
val settings = implicitly[ServerSettings]
val log = system.log
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ class HostConnectionPoolSpec extends PekkoSpecWithMaterializer(
testSet(clientServerImplementation = PassThrough)
testSet(clientServerImplementation = PekkoHttpEngineNoNetwork)
testSet(clientServerImplementation = PekkoHttpEngineTCP)
// testSet(poolImplementation = NewPoolImplementation, clientServerImplementation = AkkaHttpEngineTLS)
// testSet(poolImplementation = NewPoolImplementation, clientServerImplementation = PekkoHttpEngineTLS)

def testSet(clientServerImplementation: ClientServerImplementation) =
s"NewPoolImplementation on $clientServerImplementation" should {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@
import org.apache.pekko.Done;
import org.apache.pekko.actor.ActorSystem;
import org.apache.pekko.event.Logging;
import org.apache.pekko.http.javadsl.ConnectHttp;
import org.apache.pekko.http.javadsl.Http;
import org.apache.pekko.http.javadsl.ServerBinding;
import org.apache.pekko.http.javadsl.settings.ServerSettings;
Expand All @@ -33,7 +32,7 @@
/**
* DEPRECATED, consider https://github.com/theiterators/pekko-http-quickstart-java.g8 instead
*
* <p>Bootstrap trait for Http Server. It helps booting up an pekko-http server by only defining the
* <p>Bootstrap trait for Http Server. It helps booting up a pekko-http server by only defining the
* desired routes. It offers additional hooks to modify the default behavior.
*
* @deprecated HttpApp this doesn't reflect the latest APIs, since Akka HTTP 10.2.0
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ import scala.util.{ Failure, Success, Try }
/**
* DEPRECATED, consider https://github.com/theiterators/pekko-http-quickstart-scala.g8 instead
*
* Bootstrap trait for Http Server. It helps booting up an pekko-http server by only defining the desired routes.
* Bootstrap trait for Http Server. It helps booting up a pekko-http server by only defining the desired routes.
* It offers additional hooks to modify the default behavior.
*/
@deprecated("HttpApp this doesn't reflect the latest APIs", "Akka HTTP 10.2.0")
Expand Down

0 comments on commit 72221db

Please sign in to comment.