rename ReplicatedCassandra.segmentSize to segmentSizeDefault

evolution-gaming · Dec 13, 2023 · 1d406ce · 1d406ce
1 parent a318cbe
commit 1d406ce
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...main/scala/com/evolutiongaming/kafka/journal/eventual/cassandra/ReplicatedCassandra.scala b/...main/scala/com/evolutiongaming/kafka/journal/eventual/cassandra/ReplicatedCassandra.scala
@@ -54,7 +54,7 @@ object ReplicatedCassandra {
   }
 
   def apply[F[_]: Sync: Parallel: Fail](
-    segmentSize: SegmentSize,
+    segmentSizeDefault: SegmentSize,
     segmentNrsOf: SegmentNrsOf[F],
     statements: Statements[F],
     expiryService: ExpiryService[F],
@@ -254,7 +254,7 @@ object ReplicatedCassandra {
                                     .map { expiry =>
                                       val journalHead = JournalHead(
                                         partitionOffset = partitionOffset,
-                                        segmentSize = segmentSize,
+                                        segmentSize = segmentSizeDefault,
                                         seqNr = seqNrLast,
                                         deleteTo = deleteTo,
                                         expiry = expiry)
@@ -343,7 +343,7 @@ object ReplicatedCassandra {
                               journalHead <- journalHead.fold {
                                 val journalHead = JournalHead(
                                   partitionOffset = partitionOffset,
-                                  segmentSize = segmentSize,
+                                  segmentSize = segmentSizeDefault,
                                   seqNr = deleteTo.value,
                                   deleteTo = deleteTo.some)
                                 metaJournal