scalafmt

evolution-gaming · Sep 25, 2024 · c41e88e · c41e88e
1 parent 8f051c8
commit c41e88e
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 10 deletions.
diff --git a/...ra/src/test/scala/com/evolutiongaming/kafka/journal/cassandra/SettingsCassandraSpec.scala b/...ra/src/test/scala/com/evolutiongaming/kafka/journal/cassandra/SettingsCassandraSpec.scala
@@ -87,10 +87,10 @@ class SettingsCassandraSpec extends AnyFunSuite {
   private val settings = {
 
     val statements = SettingsCassandra.Statements(
-      select        = Database.select(_),
-      insert        = Database.insert(_),
-      all           = Database.all,
-      delete        = Database.delete(_),
+      select = Database.select(_),
+      insert = Database.insert(_),
+      all    = Database.all,
+      delete = Database.delete(_),
     )
 
     implicit val clock: Clock[F] = Clock.const[F](nanos = 0, millis = timestamp.toEpochMilli)

diff --git a/...st/scala/com/evolutiongaming/kafka/journal/eventual/cassandra/EventualCassandraTest.scala b/...st/scala/com/evolutiongaming/kafka/journal/eventual/cassandra/EventualCassandraTest.scala
@@ -55,15 +55,15 @@ class EventualCassandraTest extends AnyFunSuite with Matchers {
   } {
     implicit val log = Log.empty[StateT]
 
-    val config = DataIntegrityConfig(
+  val config = DataIntegrityConfig(
       seqNrUniqueness         = true,
       correlateEventsWithMeta = true,
     )
 
     val segmentOf    = SegmentOf[Id](segments)
     val segmentNrsOf = SegmentNrsOf[StateT](first = segments, Segments.default)
     val statements   = statementsOf(segmentNrsOf, Segments.default)
-    val journal      = EventualCassandra(statements, DataIntegrityConfig.Default)
+    val journal      = EventualCassandra(statements, config)
 
     val suffix = s"segmentSize: $segmentSize, segments: $segments"
 

diff --git a/journal/src/test/scala/com/evolutiongaming/kafka/journal/HeadCacheSpec.scala b/journal/src/test/scala/com/evolutiongaming/kafka/journal/HeadCacheSpec.scala
@@ -285,7 +285,8 @@ object HeadCacheSpec {
 
     for {
       metrics <- HeadCacheMetrics.make[IO](CollectorRegistry.empty)
-      headCache <- HeadCache.make[IO](log = LogIO, config = config, eventual = eventual, consumer = consumer, metrics = metrics.some)
+      headCache <- HeadCache
+        .make[IO](log = LogIO, config = config, eventual = eventual, consumer = consumer, metrics = metrics.some)
     } yield headCache
   }
 

diff --git a/tests/src/test/scala/com/evolutiongaming/kafka/journal/IntegrationSuite.scala b/tests/src/test/scala/com/evolutiongaming/kafka/journal/IntegrationSuite.scala
@@ -25,7 +25,7 @@ object IntegrationSuite {
       // To ensure all default '127.0.0.1:9042' configurations work, we need to bind to the host's 9042 port manually
       Resource.make {
         Sync[F].delay {
-          val cassandra =  CassandraContainer
+          val cassandra = CassandraContainer
             .apply()
             .configure { container =>
               container.withCreateContainerCmdModifier { cmd =>
@@ -73,8 +73,7 @@ object IntegrationSuite {
         metrics  <- Replicator.Metrics.make[F](CollectorRegistry.empty[F], "clientId")
         config   <- config.toResource
         hostName <- HostName.of[F]().toResource
-        result   <- Replicator.make
-        [F](config, cassandraClusterOf, hostName, metrics.some)
+        result   <- Replicator.make[F](config, cassandraClusterOf, hostName, metrics.some)
         _        <- result.onError { case e => log.error(s"failed to release replicator with $e", e) }.background
       } yield {}
     }