splitting core packages to dedicated modules

build.sbt

@@ -194,12 +194,12 @@ lazy val core =
       `core-interop`,
       effect,
       utils,
-      queue,
+      `core-queue`,
       slice,
       cache,
       actor,
       compression,
-      skiplist,
+      `core-skiplist`,
       testkit % Test,
       macros % "test->test;compile-internal",
       compression % Test,
@@ -221,20 +221,20 @@ lazy val `core-interop` =
       testkit % Test
     )
 
-lazy val skiplist =
+lazy val `core-skiplist` =
   project
     .settings(commonSettings)
     .settings(publishSettings)
     .settings(libraryDependencies ++= commonDependencies(scalaVersion.value))
     .dependsOn(
-      series,
+      `core-series`,
       effect,
       slice,
       testkit % Test,
       serializers % Test
     )
 
-lazy val series =
+lazy val `core-series` =
   project
     .settings(commonSettings)
     .settings(publishSettings)
@@ -244,7 +244,7 @@ lazy val series =
       serializers % Test
     )
 
-lazy val queue =
+lazy val `core-queue` =
   project
     .settings(commonSettings)
     .settings(publishSettings)

queue/src/main/scala/swaydb/queue/Node.scala → core-queue/src/main/scala/swaydb/core/queue/Node.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.queue
+package swaydb.core.queue
 
 protected sealed trait Node[+A] {
   def isEmpty: Boolean

queue/src/main/scala/swaydb/queue/VolatileQueue.scala → core-queue/src/main/scala/swaydb/core/queue/VolatileQueue.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.queue
+package swaydb.core.queue
 
 import swaydb.utils.DropIterator
 

queue/src/test/scala/swaydb/queue/VolatileQueueSpec.scala → core-queue/src/test/scala/swaydb/core/queue/VolatileQueueSpec.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.queue
+package swaydb.core.queue
 
 import org.scalatest.matchers.should.Matchers
 import org.scalatest.wordspec.AnyWordSpec

series/src/main/scala/swaydb/series/Series.scala → core-series/src/main/scala/swaydb/core/series/Series.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.series
+package swaydb.core.series
 
 private[swaydb] trait Series[T] extends Iterable[T] {
   def getOrNull(index: Int): T

series/src/main/scala/swaydb/series/SeriesAtomic.scala → core-series/src/main/scala/swaydb/core/series/SeriesAtomic.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.series
+package swaydb.core.series
 
 import java.util.concurrent.atomic.AtomicReferenceArray
 

series/src/main/scala/swaydb/series/SeriesBasic.scala → core-series/src/main/scala/swaydb/core/series/SeriesBasic.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.series
+package swaydb.core.series
 
 import scala.reflect.ClassTag
 

series/src/main/scala/swaydb/series/SeriesVolatile.scala → core-series/src/main/scala/swaydb/core/series/SeriesVolatile.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.series
+package swaydb.core.series
 
 object SeriesVolatile {
 

series/src/main/scala/swaydb/series/VolatileValue.scala → core-series/src/main/scala/swaydb/core/series/VolatileValue.scala

@@ -14,6 +14,6 @@
  * limitations under the License.
  */
 
-package swaydb.series
+package swaydb.core.series
 
 final private class VolatileValue[T](@volatile var value: T)

series/src/main/scala/swaydb/series/appendable/SeriesAppendable.scala → core-series/src/main/scala/swaydb/core/series/appendable/SeriesAppendable.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.series.appendable
+package swaydb.core.series.appendable
 
 trait SeriesAppendable[T >: Null] {
 

series/src/main/scala/swaydb/series/appendable/SeriesAppendableVolatile.scala → core-series/src/main/scala/swaydb/core/series/appendable/SeriesAppendableVolatile.scala

@@ -14,9 +14,9 @@
  * limitations under the License.
  */
 
-package swaydb.series.appendable
+package swaydb.core.series.appendable
 
-import swaydb.series.VolatileValue
+import swaydb.core.series.VolatileValue
 
 private[series] object SeriesAppendableVolatile {
 

series/src/main/scala/swaydb/series/growable/SeriesGrowableList.scala → core-series/src/main/scala/swaydb/core/series/growable/SeriesGrowableList.scala

@@ -14,9 +14,9 @@
  * limitations under the License.
  */
 
-package swaydb.series.growable
+package swaydb.core.series.growable
 
-import swaydb.series.appendable.SeriesAppendableVolatile
+import swaydb.core.series.appendable.SeriesAppendableVolatile
 
 import scala.reflect.ClassTag
 

series/src/main/scala/swaydb/series/map/LimitHashMap.scala → core-series/src/main/scala/swaydb/core/series/map/LimitHashMap.scala

@@ -14,9 +14,9 @@
  * limitations under the License.
  */
 
-package swaydb.series.map
+package swaydb.core.series.map
 
-import swaydb.series._
+import swaydb.core.series._
 
 import java.util.concurrent.atomic.AtomicInteger
 import scala.annotation.tailrec

series/src/test/scala/swaydb/series/SeriesAppendableSpec.scala → core-series/src/test/scala/swaydb/core/series/SeriesAppendableSpec.scala

@@ -14,11 +14,11 @@
  * limitations under the License.
  */
 
-package swaydb.series
+package swaydb.core.series
 
 import org.scalatest.matchers.should.Matchers
 import org.scalatest.wordspec.AnyWordSpec
-import swaydb.series.appendable.{SeriesAppendable, SeriesAppendableVolatile}
+import swaydb.core.series.appendable.{SeriesAppendable, SeriesAppendableVolatile}
 
 import scala.reflect.ClassTag
 

series/src/test/scala/swaydb/series/SeriesGrowableListSpec.scala → core-series/src/test/scala/swaydb/core/series/SeriesGrowableListSpec.scala

@@ -14,11 +14,11 @@
  * limitations under the License.
  */
 
-package swaydb.series
+package swaydb.core.series
 
 import org.scalatest.matchers.should.Matchers
 import org.scalatest.wordspec.AnyWordSpec
-import swaydb.series.growable.SeriesGrowableList
+import swaydb.core.series.growable.SeriesGrowableList
 
 import scala.collection.mutable.ListBuffer
 import scala.reflect.ClassTag

series/src/test/scala/swaydb/series/map/LimitHashMapPerformanceSpec.scala → core-series/src/test/scala/swaydb/core/series/map/LimitHashMapPerformanceSpec.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.series.map
+package swaydb.core.series.map
 
 import org.scalatest.flatspec.AnyFlatSpec
 import org.scalatest.matchers.should.Matchers

series/src/test/scala/swaydb/series/map/LimitHashMapSpec.scala → core-series/src/test/scala/swaydb/core/series/map/LimitHashMapSpec.scala

@@ -1,4 +1,4 @@
-package swaydb.series.map
+package swaydb.core.series.map
 
 import org.scalatest.flatspec.AnyFlatSpec
 import org.scalatest.matchers.should.Matchers

skiplist/src/main/scala/swaydb/skiplist/AtomicRanges.scala → core-skiplist/src/main/scala/swaydb/core/skiplist/AtomicRanges.scala

@@ -14,14 +14,14 @@
  * limitations under the License.
  */
 
-package swaydb.skiplist
+package swaydb.core.skiplist
 
 import com.typesafe.scalalogging.LazyLogging
 import swaydb.Bag
 import swaydb.Bag.Implicits._
 import swaydb.slice.MaxKey
 import swaydb.effect.Reserve
-import swaydb.skiplist.AtomicRanges.{Action, Value}
+import swaydb.core.skiplist.AtomicRanges.{Action, Value}
 import swaydb.slice.Slice
 
 import java.util.concurrent.ConcurrentSkipListMap

skiplist/src/main/scala/swaydb/skiplist/SkipList.scala → core-skiplist/src/main/scala/swaydb/core/skiplist/SkipList.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.skiplist
+package swaydb.core.skiplist
 
 import swaydb.Bag
 import swaydb.slice.order.KeyOrder

skiplist/src/main/scala/swaydb/skiplist/SkipListBatchable.scala → core-skiplist/src/main/scala/swaydb/core/skiplist/SkipListBatchable.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.skiplist
+package swaydb.core.skiplist
 
 trait SkipListBatchable[OK, OV, K <: OK, V <: OV] extends SkipList[OK, OV, K, V] {
 

skiplist/src/main/scala/swaydb/skiplist/SkipListConcurrent.scala → core-skiplist/src/main/scala/swaydb/core/skiplist/SkipListConcurrent.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.skiplist
+package swaydb.core.skiplist
 
 import swaydb.slice.order.KeyOrder
 

skiplist/src/main/scala/swaydb/skiplist/SkipListConcurrentLimit.scala → core-skiplist/src/main/scala/swaydb/core/skiplist/SkipListConcurrentLimit.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.skiplist
+package swaydb.core.skiplist
 
 import swaydb.slice.order.KeyOrder
 import swaydb.slice.Slice

skiplist/src/main/scala/swaydb/skiplist/SkipListNavigable.scala → core-skiplist/src/main/scala/swaydb/core/skiplist/SkipListNavigable.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.skiplist
+package swaydb.core.skiplist
 
 import swaydb.utils.NullOps
 import swaydb.slice.order.KeyOrder

skiplist/src/main/scala/swaydb/skiplist/SkipListSeries.scala → core-skiplist/src/main/scala/swaydb/core/skiplist/SkipListSeries.scala

@@ -14,10 +14,10 @@
  * limitations under the License.
  */
 
-package swaydb.skiplist
+package swaydb.core.skiplist
 
 import com.typesafe.scalalogging.LazyLogging
-import swaydb.series.growable.SeriesGrowableList
+import swaydb.core.series.growable.SeriesGrowableList
 import swaydb.slice.Slice
 import swaydb.slice.order.KeyOrder
 import swaydb.utils.{English, WhenOccurs}

skiplist/src/main/scala/swaydb/skiplist/SkipListTreeMap.scala → core-skiplist/src/main/scala/swaydb/core/skiplist/SkipListTreeMap.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.skiplist
+package swaydb.core.skiplist
 
 import swaydb.slice.order.KeyOrder
 

skiplist/src/test/scala/swaydb/skiplist/SkipListSeriesSpec.scala → core-skiplist/src/test/scala/swaydb/core/skiplist/SkipListSeriesSpec.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.skiplist
+package swaydb.core.skiplist
 
 import org.scalatest.matchers.should.Matchers
 import org.scalatest.wordspec.AnyWordSpec

skiplist/src/test/scala/swaydb/skiplist/SkipListSpec.scala → core-skiplist/src/test/scala/swaydb/core/skiplist/SkipListSpec.scala

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package swaydb.skiplist
+package swaydb.core.skiplist
 
 import org.scalatest.matchers.should.Matchers
 import org.scalatest.wordspec.AnyWordSpec

core/src/main/scala/swaydb/core/level/AppendixLogCache.scala

@@ -19,7 +19,7 @@ package swaydb.core.level
 import swaydb.Glass
 import swaydb.core.log.{LogCache, LogCacheBuilder, LogEntry}
 import swaydb.core.segment.{Segment, SegmentOption}
-import swaydb.skiplist.SkipListConcurrent
+import swaydb.core.skiplist.SkipListConcurrent
 import swaydb.slice.order.KeyOrder
 import swaydb.slice.{Slice, SliceOption}
 
@@ -41,7 +41,7 @@ object AppendixLogCache {
 
 /**
  * In history of this file's commit at revision "992965da26cba711c7b42a9a555d04de46b9fa37 - backup atomicSkipList for AppendixMapCache"
- * uses [[swaydb.skiplist.SkipList.atomicRead]] and [[swaydb.skiplist.SkipList.atomicRead]] but
+ * uses [[swaydb.core.skiplist.SkipList.atomicRead]] and [[swaydb.core.skiplist.SkipList.atomicRead]] but
  * for Appendix file batch is more efficient because millions of concurrent reads will require concurrent writes to the atomic SkipList
  * whereas batch only requires a single copy of the SkipList which is more efficient.
  */

core/src/main/scala/swaydb/core/level/zero/LevelZero.scala

@@ -44,7 +44,7 @@ import swaydb.core.sweeper.FileSweeper
 import swaydb.core.util.MinMax
 import swaydb.core.{CoreState, MemoryPathGenerator}
 import swaydb.effect.{Effect, FileLocker}
-import swaydb.skiplist.SkipList
+import swaydb.core.skiplist.SkipList
 import swaydb.slice.order.{KeyOrder, TimeOrder}
 import swaydb.slice.{Slice, SliceOption}
 import swaydb.utils.{DropIterator, Options}

core/src/main/scala/swaydb/core/level/zero/LevelZeroLogCache.scala

@@ -21,7 +21,7 @@ import swaydb.core.data.{Memory, MemoryOption}
 import swaydb.core.function.FunctionStore
 import swaydb.core.log.{LogCache, LogCacheBuilder, LogEntry}
 import swaydb.config.{Atomic, OptimiseWrites}
-import swaydb.skiplist.{SkipList, SkipListConcurrent, SkipListSeries}
+import swaydb.core.skiplist.{SkipList, SkipListConcurrent, SkipListSeries}
 import swaydb.slice.order.{KeyOrder, TimeOrder}
 import swaydb.slice.{MaxKey, MaxKeyOption, Slice, SliceOption}
 

core/src/main/scala/swaydb/core/log/LogCache.scala

@@ -27,7 +27,7 @@ trait LogCache[K, V] {
   def isEmpty: Boolean
 
   /**
-   * Max and not exact but [[swaydb.skiplist.SkipListSeries]] could've nulled key-values.
+   * Max and not exact but [[swaydb.core.skiplist.SkipListSeries]] could've nulled key-values.
    */
   def maxKeyValueCount: Int
 

core/src/main/scala/swaydb/core/log/LogEntry.scala

@@ -20,7 +20,7 @@ import swaydb.core.data.Memory
 import swaydb.core.log.LogEntry.{Put, Remove}
 import swaydb.core.log.serializer.{LogEntrySerialiser, LogEntryWriter}
 import swaydb.core.segment.Segment
-import swaydb.skiplist.{SkipList, SkipListBatchable, SkipListConcurrent}
+import swaydb.core.skiplist.{SkipList, SkipListBatchable, SkipListConcurrent}
 import swaydb.slice.order.KeyOrder
 import swaydb.slice.{Slice, SliceMut}
 

core/src/main/scala/swaydb/core/log/Logs.scala

@@ -25,7 +25,7 @@ import swaydb.core.log.timer.Timer
 import swaydb.core.sweeper.ByteBufferSweeper.ByteBufferSweeperActor
 import swaydb.core.sweeper.FileSweeper
 import swaydb.utils.DropIterator
-import swaydb.queue.VolatileQueue
+import swaydb.core.queue.VolatileQueue
 import swaydb.config.accelerate.{Accelerator, LevelZeroMeter}
 import swaydb.config.{MMAP, RecoveryMode}
 import swaydb.slice.order.KeyOrder

core/src/main/scala/swaydb/core/log/applied/AppliedFunctionsLogCache.scala

@@ -17,7 +17,7 @@
 package swaydb.core.log.applied
 
 import swaydb.core.log.{LogCache, LogCacheBuilder, LogEntry}
-import swaydb.skiplist.SkipListConcurrent
+import swaydb.core.skiplist.SkipListConcurrent
 import swaydb.slice.order.KeyOrder
 import swaydb.slice.{Slice, SliceOption}
 

core/src/main/scala/swaydb/core/segment/MemorySegment.scala

@@ -27,7 +27,7 @@ import swaydb.core.segment.defrag.DefragMemorySegment
 import swaydb.core.segment.ref.search.ThreadReadState
 import swaydb.core.sweeper.FileSweeper
 import swaydb.core.util._
-import swaydb.skiplist.SkipListTreeMap
+import swaydb.core.skiplist.SkipListTreeMap
 import swaydb.slice.MaxKey
 import swaydb.config.compaction.CompactionConfig.CompactionParallelism
 import swaydb.slice.order.{KeyOrder, TimeOrder}

core/src/main/scala/swaydb/core/segment/PersistentSegmentMany.scala

@@ -44,7 +44,7 @@ import swaydb.core.segment.ref.{SegmentRef, SegmentRefOption, SegmentRefReader}
 import swaydb.core.sweeper.ByteBufferSweeper.ByteBufferSweeperActor
 import swaydb.core.sweeper.{FileSweeper, MemorySweeper}
 import swaydb.core.util._
-import swaydb.skiplist.SkipListTreeMap
+import swaydb.core.skiplist.SkipListTreeMap
 import swaydb.slice.MaxKey
 import swaydb.config.compaction.CompactionConfig.CompactionParallelism
 import swaydb.config.{MMAP, SegmentRefCacheLife}