added slice module

simerplaha · Nov 16, 2021 · baf5b76 · baf5b76
1 parent 0d8f6ee
commit baf5b76
Show file tree

Hide file tree

Showing 394 changed files with 1,953 additions and 1,939 deletions.
diff --git a/build.sbt b/build.sbt
@@ -195,6 +195,7 @@ lazy val core =
       data,
       effect,
       utils,
+      slice,
       cache,
       actor,
       compression,
@@ -217,6 +218,7 @@ lazy val data =
       effect,
       actor,
       utils,
+      slice,
       testkit % Test
     )
 
@@ -243,6 +245,16 @@ lazy val series =
       serializers % Test
     )
 
+lazy val slice =
+  project
+    .settings(commonSettings)
+    .settings(publishSettings)
+    .settings(libraryDependencies ++= commonDependencies(scalaVersion.value))
+    .dependsOn(
+      effect,
+      testkit % Test,
+    )
+
 lazy val `data-java` =
   project
     .settings(commonSettings)

diff --git a/compression/src/main/scala/swaydb/compression/CompressorInternal.scala b/compression/src/main/scala/swaydb/compression/CompressorInternal.scala
@@ -22,7 +22,7 @@ import org.xerial.snappy
 import swaydb.data.compression.LZ4Compressor.{Fast, High}
 import swaydb.data.compression.LZ4Instance
 import swaydb.data.compression.LZ4Instance._
-import swaydb.data.slice.Slice
+import swaydb.slice.Slice
 
 import java.nio.ByteBuffer
 

diff --git a/compression/src/main/scala/swaydb/compression/DecompressorInternal.scala b/compression/src/main/scala/swaydb/compression/DecompressorInternal.scala
@@ -19,7 +19,7 @@ package swaydb.compression
 import net.jpountz.lz4.{LZ4Factory, LZ4FastDecompressor, LZ4SafeDecompressor}
 import org.xerial.snappy
 import swaydb.data.compression.{DecompressorId, LZ4Decompressor, LZ4Instance}
-import swaydb.data.slice.Slice
+import swaydb.slice.Slice
 
 /**
  * Internal types that have 1 to 1 mapping with the more configurable swaydb.Decompressor types.

diff --git a/compression/src/test/scala/swaydb/compression/CompressionSpec.scala b/compression/src/test/scala/swaydb/compression/CompressionSpec.scala
@@ -19,7 +19,7 @@ package swaydb.compression
 import org.scalatest.matchers.should.Matchers
 import org.scalatest.wordspec.AnyWordSpec
 import swaydb.compression.CompressionTestGen._
-import swaydb.data.slice.Slice
+import swaydb.slice.Slice
 import swaydb.serializers.Default._
 import swaydb.serializers._
 import swaydb.utils.ByteSizeOf

diff --git a/core-performance/src/test/scala/swaydb/core/level/LevelPerformanceSpec.scala b/core-performance/src/test/scala/swaydb/core/level/LevelPerformanceSpec.scala
@@ -28,7 +28,7 @@
 //import swaydb.core.util.Benchmark
 //import swaydb.data.config.{IOAction, IOStrategy}
 //import swaydb.data.order.KeyOrder
-//import swaydb.data.slice.Slice
+//import swaydb.slice.Slice
 //import swaydb.data.util.StorageUnits._
 //import swaydb.core.CommonAssertions._
 //import scala.util.Random

diff --git a/core-performance/src/test/scala/swaydb/core/level/zero/LevelPerformanceSpec.scala b/core-performance/src/test/scala/swaydb/core/level/zero/LevelPerformanceSpec.scala
@@ -23,7 +23,7 @@
 //import swaydb.core.util.{Benchmark, SkipList}
 //import swaydb.core.{TestBase, TestSweeper}
 //import swaydb.data.order.KeyOrder
-//import swaydb.data.slice.Slice
+//import swaydb.slice.Slice
 //import swaydb.data.util.StorageUnits._
 //
 //import scala.util.Random

diff --git a/core-performance/src/test/scala/swaydb/core/map/MapsPerformanceSpec.scala b/core-performance/src/test/scala/swaydb/core/map/MapsPerformanceSpec.scala
@@ -28,7 +28,7 @@
 //import swaydb.data.accelerate.Accelerator
 //import swaydb.data.config.RecoveryMode
 //import swaydb.data.order.{KeyOrder, TimeOrder}
-//import swaydb.data.slice.Slice
+//import swaydb.slice.Slice
 
 
 //import swaydb.data.util.StorageUnits._

diff --git a/core-performance/src/test/scala/swaydb/core/merge/SegmentMerge_Performance_Spec.scala b/core-performance/src/test/scala/swaydb/core/merge/SegmentMerge_Performance_Spec.scala
@@ -20,7 +20,7 @@ import swaydb.core.data.{Memory, Time}
 import swaydb.core.util.Benchmark
 import swaydb.core.{TestBase, TestTimer}
 import swaydb.data.order.{KeyOrder, TimeOrder}
-import swaydb.data.slice.Slice
+import swaydb.slice.Slice
 import swaydb.testkit.RunThis._
 
 class SegmentMerge_Performance_Spec extends TestBase {

diff --git a/core-performance/src/test/scala/swaydb/core/segment/SegmentReadPerformanceSpec.scala b/core-performance/src/test/scala/swaydb/core/segment/SegmentReadPerformanceSpec.scala
@@ -37,7 +37,7 @@ import swaydb.core.{TestBase, TestCaseSweeper, TestExecutionContext, TestSweeper
 import swaydb.data.compaction.CompactionConfig.CompactionParallelism
 import swaydb.data.config.SegmentRefCacheLife
 import swaydb.data.order.{KeyOrder, TimeOrder}
-import swaydb.data.slice.Slice
+import swaydb.slice.Slice
 import swaydb.effect.{Dir, IOAction, IOStrategy}
 import swaydb.testkit.RunThis.FutureImplicits
 import swaydb.utils.StorageUnits._

diff --git a/...performance/src/test/scala/swaydb/core/segment/block/SegmentSearcherPerformanceSpec.scala b/...performance/src/test/scala/swaydb/core/segment/block/SegmentSearcherPerformanceSpec.scala
@@ -23,7 +23,7 @@
 //import swaydb.core.util.Benchmark
 //import swaydb.data.config.IOStrategy
 //import swaydb.data.order.KeyOrder
-//import swaydb.data.slice.Slice
+//import swaydb.slice.Slice
 //import swaydb.serializers.Default._
 //import swaydb.serializers._
 //

diff --git a/core-stress/src/test/scala/swaydb/core/level/zero/LevelZeroStressSpec.scala b/core-stress/src/test/scala/swaydb/core/level/zero/LevelZeroStressSpec.scala
@@ -18,7 +18,7 @@
 //
 //import swaydb.core.TestBase
 //import swaydb.core.util.{Benchmark, Delay}
-//import swaydb.data.slice.Slice
+//import swaydb.slice.Slice
 //import swaydb.data.order.KeyOrder
 //import swaydb.serializers.Default._
 //import swaydb.core.IOAssert._

diff --git a/core-stress/src/test/scala/swaydb/core/map/MapStressSpec.scala b/core-stress/src/test/scala/swaydb/core/map/MapStressSpec.scala
@@ -26,7 +26,7 @@
 //import swaydb.core.log.serializer.LevelZeroLogEntryWriter.Level0PutWriter
 //import swaydb.core.{TestBase, TestSweeper, TestTimer}
 //import swaydb.data.order.{KeyOrder, TimeOrder}
-//import swaydb.data.slice.Slice
+//import swaydb.slice.Slice
 //import swaydb.data.util.StorageUnits._
 //
 //class MapStressSpec extends TestBase {

diff --git a/core-stress/src/test/scala/swaydb/core/map/MapsStressSpec.scala b/core-stress/src/test/scala/swaydb/core/map/MapsStressSpec.scala
@@ -29,7 +29,7 @@
 //import swaydb.data.accelerate.{Accelerator, LevelZeroMeter}
 //import swaydb.data.config.RecoveryMode
 //import swaydb.data.order.{KeyOrder, TimeOrder}
-//import swaydb.data.slice.Slice
+//import swaydb.slice.Slice
 //import swaydb.data.util.StorageUnits._
 //
 //class MapsStressSpec extends TestBase {

diff --git a/core-stress/src/test/scala/swaydb/core/segment/merge/MergeListStressSpec.scala b/core-stress/src/test/scala/swaydb/core/segment/merge/MergeListStressSpec.scala
@@ -22,7 +22,7 @@
 //import swaydb.core.TestData._
 //import swaydb.core.TestTimer
 //import swaydb.core.data.{KeyValue, Memory, Value}
-//import swaydb.data.slice.Slice
+//import swaydb.slice.Slice
 //import swaydb.serializers.Default._
 //import swaydb.serializers._
 //

diff --git a/core-stress/src/test/scala/swaydb/core/segment/merge/SegmentMergeStressSpec.scala b/core-stress/src/test/scala/swaydb/core/segment/merge/SegmentMergeStressSpec.scala
@@ -24,7 +24,7 @@
 //import swaydb.core.segment.block.hashindex.HashIndexBlock
 //import swaydb.core.util.Benchmark
 //import swaydb.data.order.{KeyOrder, TimeOrder}
-//import swaydb.data.slice.Slice
+//import swaydb.slice.Slice
 //import swaydb.data.util.StorageUnits._
 //
 //class SegmentMergeStressSpec extends TestBase {

diff --git a/core/src/main/scala/swaydb/core/Core.scala b/core/src/main/scala/swaydb/core/Core.scala
@@ -34,7 +34,7 @@ import swaydb.data.compaction.{CompactionConfig, LevelMeter}
 import swaydb.data.config._
 import swaydb.data.order.{KeyOrder, TimeOrder}
 import swaydb.data.sequencer.Sequencer
-import swaydb.data.slice.{Slice, SliceOption}
+import swaydb.slice.{Slice, SliceOption}
 import swaydb.utils.TupleOrNone
 
 import java.nio.file.Path

diff --git a/core/src/main/scala/swaydb/core/CoreInitializer.scala b/core/src/main/scala/swaydb/core/CoreInitializer.scala
@@ -38,7 +38,7 @@ import swaydb.data.compaction.CompactionConfig
 import swaydb.data.config._
 import swaydb.data.order.{KeyOrder, TimeOrder}
 import swaydb.data.sequencer.Sequencer
-import swaydb.data.slice.Slice
+import swaydb.slice.Slice
 import swaydb.data.storage.{Level0Storage, LevelStorage}
 import swaydb.data.{Atomic, OptimiseWrites}
 import swaydb.effect.Effect._

diff --git a/core/src/main/scala/swaydb/core/build/Build.scala b/core/src/main/scala/swaydb/core/build/Build.scala
@@ -19,7 +19,7 @@ package swaydb.core.build
 import com.typesafe.scalalogging.LazyLogging
 import swaydb.IO
 import swaydb.data.DataType
-import swaydb.data.slice.Slice
+import swaydb.slice.Slice
 import swaydb.effect.Effect
 import swaydb.macros.VersionReader
 

diff --git a/core/src/main/scala/swaydb/core/build/BuildSerialiser.scala b/core/src/main/scala/swaydb/core/build/BuildSerialiser.scala
@@ -18,7 +18,7 @@ package swaydb.core.build
 
 import swaydb.core.util.CRC32
 import swaydb.data.DataType
-import swaydb.data.slice.Slice
+import swaydb.slice.Slice
 import swaydb.utils.ByteSizeOf
 
 import java.nio.file.Path

diff --git a/core/src/main/scala/swaydb/core/data/KeyValue.scala b/core/src/main/scala/swaydb/core/data/KeyValue.scala
@@ -26,7 +26,7 @@ import swaydb.core.segment.ref.search.KeyMatcher
 import swaydb.core.util.Bytes
 import swaydb.data.MaxKey
 import swaydb.data.order.KeyOrder
-import swaydb.data.slice.{Slice, SliceOption}
+import swaydb.slice.{Slice, SliceOption}
 import swaydb.utils.{SomeOrNone, SomeOrNoneCovariant, TupleOrNone}
 
 import scala.concurrent.duration.{Deadline, FiniteDuration}

diff --git a/core/src/main/scala/swaydb/core/data/SwayFunction.scala b/core/src/main/scala/swaydb/core/data/SwayFunction.scala
@@ -16,7 +16,7 @@
 
 package swaydb.core.data
 
-import swaydb.data.slice.{Slice, SliceOption}
+import swaydb.slice.{Slice, SliceOption}
 
 import scala.concurrent.duration.Deadline
 

diff --git a/core/src/main/scala/swaydb/core/data/Time.scala b/core/src/main/scala/swaydb/core/data/Time.scala
@@ -18,8 +18,8 @@ package swaydb.core.data
 
 import swaydb.IO
 import swaydb.data.order.TimeOrder
-import swaydb.data.slice.Slice
-import swaydb.data.utils.ScalaByteOps
+import swaydb.slice.Slice
+import swaydb.slice.utils.ScalaByteOps
 import swaydb.utils.ByteSizeOf
 
 private[core] object Time {

diff --git a/core/src/main/scala/swaydb/core/data/Value.scala b/core/src/main/scala/swaydb/core/data/Value.scala
@@ -16,7 +16,7 @@
 
 package swaydb.core.data
 
-import swaydb.data.slice.{Slice, SliceOption}
+import swaydb.slice.{Slice, SliceOption}
 import swaydb.utils.SomeOrNone
 
 import scala.concurrent.duration.Deadline

diff --git a/core/src/main/scala/swaydb/core/function/FunctionStore.scala b/core/src/main/scala/swaydb/core/function/FunctionStore.scala
@@ -19,7 +19,7 @@ package swaydb.core.function
 import swaydb.OK
 import swaydb.core.data.{SwayFunction, Value}
 import swaydb.data.order.KeyOrder
-import swaydb.data.slice.Slice
+import swaydb.slice.Slice
 
 import java.util.concurrent.ConcurrentHashMap
 import scala.annotation.tailrec

diff --git a/core/src/main/scala/swaydb/core/io/file/DBFile.scala b/core/src/main/scala/swaydb/core/io/file/DBFile.scala
@@ -22,7 +22,7 @@ import swaydb.cache.Cache
 import swaydb.core.sweeper.ByteBufferSweeper.ByteBufferSweeperActor
 import swaydb.core.sweeper.{ByteBufferSweeper, FileSweeper, FileSweeperItem}
 import swaydb.data.config.ForceSave
-import swaydb.data.slice.{Slice, SliceRO}
+import swaydb.slice.{Slice, SliceRO}
 import swaydb.effect.{Effect, IOStrategy, Reserve}
 import swaydb.{Error, IO}
 

diff --git a/core/src/main/scala/swaydb/core/io/file/DBFileType.scala b/core/src/main/scala/swaydb/core/io/file/DBFileType.scala
@@ -17,7 +17,7 @@
 package swaydb.core.io.file
 
 import swaydb.core.sweeper.FileSweeperItem
-import swaydb.data.slice.{Slice, SliceRO}
+import swaydb.slice.{Slice, SliceRO}
 
 import java.nio.channels.WritableByteChannel
 import java.nio.file.Path

diff --git a/core/src/main/scala/swaydb/core/io/file/MMAPFile.scala b/core/src/main/scala/swaydb/core/io/file/MMAPFile.scala
@@ -20,7 +20,7 @@ import com.typesafe.scalalogging.LazyLogging
 import swaydb.core.sweeper.ByteBufferSweeper
 import swaydb.core.sweeper.ByteBufferSweeper.ByteBufferSweeperActor
 import swaydb.data.config.ForceSave
-import swaydb.data.slice.{Slice, SliceRO, Slices}
+import swaydb.slice.{Slice, SliceRO, Slices}
 import swaydb.effect.{Effect, Reserve}
 
 import java.nio.channels.FileChannel.MapMode

diff --git a/core/src/main/scala/swaydb/core/io/file/StandardFile.scala b/core/src/main/scala/swaydb/core/io/file/StandardFile.scala
@@ -19,7 +19,7 @@ package swaydb.core.io.file
 import com.typesafe.scalalogging.LazyLogging
 import swaydb.core.util.Collections
 import swaydb.data.config.ForceSave
-import swaydb.data.slice.{Slice, SliceRO, Slices}
+import swaydb.slice.{Slice, SliceRO, Slices}
 import swaydb.effect.Effect
 
 import java.nio.ByteBuffer

diff --git a/core/src/main/scala/swaydb/core/io/reader/FileReader.scala b/core/src/main/scala/swaydb/core/io/reader/FileReader.scala
@@ -18,8 +18,8 @@ package swaydb.core.io.reader
 
 import com.typesafe.scalalogging.LazyLogging
 import swaydb.core.io.file.DBFile
-import swaydb.data.slice.{Reader, Slice, SliceRO}
-import swaydb.data.utils.ByteOps
+import swaydb.slice.{Reader, Slice, SliceRO}
+import swaydb.slice.utils.ByteOps
 
 import java.nio.file.Path
 

diff --git a/core/src/main/scala/swaydb/core/io/reader/Reader.scala b/core/src/main/scala/swaydb/core/io/reader/Reader.scala
@@ -17,7 +17,7 @@
 package swaydb.core.io.reader
 
 import swaydb.core.io.file.DBFile
-import swaydb.data.slice.{Slice, SliceReader}
+import swaydb.slice.{Slice, SliceReader}
 
 private[swaydb] object Reader {
 

diff --git a/core/src/main/scala/swaydb/core/level/AppendixLogCache.scala b/core/src/main/scala/swaydb/core/level/AppendixLogCache.scala
@@ -21,7 +21,7 @@ import swaydb.core.log.{LogCache, LogCacheBuilder, LogEntry}
 import swaydb.core.segment.{Segment, SegmentOption}
 import swaydb.skiplist.SkipListConcurrent
 import swaydb.data.order.KeyOrder
-import swaydb.data.slice.{Slice, SliceOption}
+import swaydb.slice.{Slice, SliceOption}
 
 import scala.reflect.ClassTag
 

diff --git a/core/src/main/scala/swaydb/core/level/Level.scala b/core/src/main/scala/swaydb/core/level/Level.scala
@@ -48,13 +48,13 @@ import swaydb.core.util._
 import swaydb.data.compaction.CompactionConfig.CompactionParallelism
 import swaydb.data.compaction.{LevelMeter, LevelThrottle}
 import swaydb.data.order.{KeyOrder, TimeOrder}
-import swaydb.data.slice.SliceIOImplicits._
-import swaydb.data.slice.{Slice, SliceOption}
+import swaydb.slice.SliceIOImplicits._
+import swaydb.slice.{Slice, SliceOption}
 import swaydb.data.storage.LevelStorage
 import swaydb.effect.Effect._
 import swaydb.effect.{Dir, Effect, Extension, FileLocker}
-import swaydb.utils.Futures
-import swaydb.{Aggregator, Bag, Error, IO}
+import swaydb.utils.{Aggregator, Futures}
+import swaydb.{Bag, Error, IO}
 
 import java.nio.channels.FileChannel
 import java.nio.file.{Path, StandardOpenOption}

diff --git a/core/src/main/scala/swaydb/core/level/LevelRef.scala b/core/src/main/scala/swaydb/core/level/LevelRef.scala
@@ -22,7 +22,7 @@ import swaydb.core.segment.ref.search.ThreadReadState
 import swaydb.core.segment.{Segment, SegmentOption}
 import swaydb.data.compaction.LevelMeter
 import swaydb.data.config.{ForceSave, MMAP}
-import swaydb.data.slice.{Slice, SliceOption}
+import swaydb.slice.{Slice, SliceOption}
 import swaydb.{Bag, IO}
 
 import java.nio.file.Path

diff --git a/core/src/main/scala/swaydb/core/level/NextLevel.scala b/core/src/main/scala/swaydb/core/level/NextLevel.scala
@@ -25,7 +25,7 @@ import swaydb.core.segment.block.segment.transient.TransientSegment
 import swaydb.core.segment.{Segment, SegmentOption}
 import swaydb.data.compaction.CompactionConfig.CompactionParallelism
 import swaydb.data.compaction.{LevelMeter, LevelThrottle}
-import swaydb.data.slice.Slice
+import swaydb.slice.Slice
 import swaydb.effect.Dir
 import swaydb.{Error, IO}
 

diff --git a/core/src/main/scala/swaydb/core/level/compaction/io/CompactionIO.scala b/core/src/main/scala/swaydb/core/level/compaction/io/CompactionIO.scala
@@ -28,7 +28,7 @@ import swaydb.core.sweeper.{FileSweeper, MemorySweeper}
 import swaydb.core.util.IDGenerator
 import swaydb.data.config.{MMAP, SegmentRefCacheLife}
 import swaydb.data.order.{KeyOrder, TimeOrder}
-import swaydb.data.slice.Slice
+import swaydb.slice.Slice
 import swaydb.{Actor, DefActor}
 
 import java.util.concurrent.ConcurrentHashMap

diff --git a/core/src/main/scala/swaydb/core/level/compaction/task/assigner/LevelTaskAssigner.scala b/core/src/main/scala/swaydb/core/level/compaction/task/assigner/LevelTaskAssigner.scala
@@ -23,7 +23,7 @@ import swaydb.core.segment.Segment
 import swaydb.data.NonEmptyList
 import swaydb.data.compaction.PushStrategy
 import swaydb.data.order.KeyOrder
-import swaydb.data.slice.Slice
+import swaydb.slice.Slice
 
 case object LevelTaskAssigner {
 

diff --git a/core/src/main/scala/swaydb/core/level/compaction/task/assigner/LevelZeroTaskAssigner.scala b/core/src/main/scala/swaydb/core/level/compaction/task/assigner/LevelZeroTaskAssigner.scala
@@ -16,7 +16,7 @@
 
 package swaydb.core.level.compaction.task.assigner
 
-import swaydb.Aggregator
+import swaydb.utils.Aggregator
 import swaydb.core.data.{KeyValue, Memory}
 import swaydb.core.function.FunctionStore
 import swaydb.core.level.Level
@@ -30,7 +30,7 @@ import swaydb.core.segment.assigner.Assignable
 import swaydb.data.compaction.CompactionConfig.CompactionParallelism
 import swaydb.data.compaction.PushStrategy
 import swaydb.data.order.{KeyOrder, TimeOrder}
-import swaydb.data.slice.Slice
+import swaydb.slice.Slice
 import swaydb.data.{MaxKey, NonEmptyList}
 import swaydb.utils.Futures
 

diff --git a/core/src/main/scala/swaydb/core/level/compaction/task/assigner/TaskAssigner.scala b/core/src/main/scala/swaydb/core/level/compaction/task/assigner/TaskAssigner.scala
@@ -16,7 +16,7 @@
 
 package swaydb.core.level.compaction.task.assigner
 
-import swaydb.Aggregator
+import swaydb.utils.Aggregator
 import swaydb.core.data.Value.FromValue
 import swaydb.core.data.{Memory, Time, Value}
 import swaydb.core.level.Level
@@ -26,7 +26,7 @@ import swaydb.core.segment.Segment
 import swaydb.core.segment.assigner.{Assignable, Assigner, Assignment, AssignmentResult}
 import swaydb.data.compaction.PushStrategy
 import swaydb.data.order.KeyOrder
-import swaydb.data.slice.Slice
+import swaydb.slice.Slice
 import swaydb.data.{MaxKey, NonEmptyList}
 
 import scala.annotation.tailrec