Skip to content

Commit

Permalink
rename classes with Akka in the name
Browse files Browse the repository at this point in the history
Rename to use Pekko for better consistency and making
it easier to automate the transition of other projects
that pull in these classes. Allows for easier search
and replace to migrate.
  • Loading branch information
brharrington committed Sep 13, 2023
1 parent fe2fa1a commit 51b37fa
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -24,12 +24,12 @@ import scala.concurrent.ExecutionContext
import scala.concurrent.Future

/**
* A wrapper used for simple unit testing of Akka HTTP calls.
* A wrapper used for simple unit testing of Pekko HTTP calls.
*/
trait AkkaHttpClient {
trait PekkoHttpClient {

/**
* See pekko.http.scaladsl.Http
* See org.apache.pekko.http.scaladsl.Http
*/
def singleRequest(request: HttpRequest): Future[HttpResponse]

Expand All @@ -41,9 +41,10 @@ trait AkkaHttpClient {
* @param name
* The name to use for access logging and metrics.
* @param system
* The Akka system.
* The actor system.
*/
class DefaultAkkaHttpClient(name: String)(implicit val system: ActorSystem) extends AkkaHttpClient {
class DefaultPekkoHttpClient(name: String)(implicit val system: ActorSystem)
extends PekkoHttpClient {

private implicit val ec: ExecutionContext = system.dispatcher

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ import com.typesafe.scalalogging.StrictLogging
import scala.concurrent.duration.FiniteDuration

/**
* Utility functions for commonly used operations on Akka streams. Most of these are for
* Utility functions for commonly used operations on Pekko streams. Most of these are for
* the purpose of getting additional instrumentation into the behavior of the stream.
*/
object StreamOps extends StrictLogging {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ import java.util.Optional
* are available for `com.typesafe.config.Config` and `com.netflix.spectator.api.Registry`.
*/
@Configuration
class AkkaConfiguration {
class PekkoConfiguration {

@Bean
def actorSystemService(config: Optional[Config]): ActorSystemService = {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ import org.springframework.context.annotation.AnnotationConfigApplicationContext

import scala.util.Using

class AkkaConfigurationSuite extends FunSuite {
class PekkoConfigurationSuite extends FunSuite {

private val testCfg = ConfigFactory.parseString("""
|atlas.pekko.name = test
Expand Down

0 comments on commit 51b37fa

Please sign in to comment.