Release 0.0.2 (#9)

Author: nryanov

README.md

@@ -22,8 +22,6 @@ libraryDependencies ++= Seq(
 )
 ```
 
-The only dependencies are [zio](https://github.com/zio/zio) and [scodec](https://github.com/scodec/scodec).
-
 ## Getting started
 ```scala
 import zio._
@@ -127,33 +125,28 @@ But you always can create your own `TupleEncoder[_]`:
 final case class TestTuple(f1: String, f2: Int, f3: Long)
 
   implicit val tupleEncoder: TupleEncoder[TestTuple] = new TupleEncoder[TestTuple] {
-    override def encode(v: TestTuple): Attempt[MpArray] =
-      for {
-        f1Mp <- Encoder[String].encode(v.f1)
-        f2Mp <- Encoder[Int].encode(v.f2)
-        f3Mp <- Encoder[Long].encode(v.f3)
-
-        tupleMp <- Encoder[Vector[MessagePack]].encode(Vector(f1Mp, f2Mp, f3Mp))
-      } yield tupleMp.asInstanceOf[MpArray]
-
-    override def decode(v: MpArray, idx: Int): Attempt[TestTuple] = {
-      val vector = v.value
-
-      val f1Mp = Encoder[String].decode(vector(idx)) // decode the first field
-      val f2Mp = Encoder[Int].decode(vector(idx + 1)) // second
-      val f3Mp = Encoder[Long].decode(vector(idx + 2)) // third
-
-      for {
-        f1 <- f1Mp
-        f2 <- f2Mp
-        f3 <- f3Mp
-      } yield TestTuple(f1, f2, f3)
+
+    override def decode(v: ArrayValue, idx: Int): TestTuple = {
+      val f1Mp = Encoder[String].decode(v.get(idx))
+      val f2Mp = Encoder[Int].decode(v.get(idx + 1))
+      val f3Mp = Encoder[Long].decode(v.get(idx + 2))
+      TestTuple(f1Mp, f2Mp, f3Mp)
+    }
+
+    override def encode(v: TestTuple): Vector[Value] = {
+      val f1Mp = Encoder[String].encode(v.f1)
+      val f2Mp = Encoder[Int].encode(v.f2)
+      val f3Mp = Encoder[Long].encode(v.f3)
+
+      Vector(f1Mp, f2Mp, f3Mp)
     }
   }
 ``` 
 
 ## Update operations
-There is also an implicit update operation builder for any case class:
+**EXPERIMENTAL**
+
+Instead of manual construction of update operation you can generate it from special implicit builder:
 
 ```scala
 import zio.tarantool.codec.auto._

benchmarks/src/main/scala/zio/tarantool/BenchmarkBase.scala

@@ -0,0 +1,26 @@
+package zio.tarantool
+
+import zio.{BootstrapRuntime, ZIO, ZLayer}
+import zio.tarantool.TarantoolClient.TarantoolClient
+import zio.clock.Clock
+import zio.internal.Platform
+
+trait BenchmarkBase extends BootstrapRuntime {
+
+  override val platform: Platform = Platform.benchmark
+
+  def zioUnsafeRun[A](fa: ZIO[TarantoolClient, TarantoolError, A]): A = unsafeRun(
+    fa.provideLayer(BenchmarkBase.layer)
+  )
+}
+
+object BenchmarkBase {
+  private final val layer: ZLayer[Any, TarantoolError, TarantoolClient] =
+    (Clock.live ++ ZLayer.succeed(
+      TarantoolConfig(
+        connectionConfig = ConnectionConfig(host = "localhost", port = 3301),
+        clientConfig = ClientConfig(useSchemaMetaCache = false),
+        authInfo = None
+      )
+    )) >>> TarantoolClient.live
+}

benchmarks/src/main/scala/zio/tarantool/TarantoolClientBenchmark.scala

@@ -0,0 +1,87 @@
+package zio.tarantool
+
+import java.util.concurrent.TimeUnit
+
+import org.msgpack.value._
+import org.msgpack.value.impl._
+import org.openjdk.jmh.annotations._
+import zio.ZIO
+import zio.tarantool.TarantoolClient.TarantoolClient
+import zio.tarantool.TarantoolClientBenchmark.A
+
+@Fork(1)
+@State(Scope.Thread)
+@Warmup(iterations = 5)
+@Measurement(iterations = 5)
+@OutputTimeUnit(TimeUnit.SECONDS)
+@BenchmarkMode(Array(Mode.Throughput))
+class TarantoolClientBenchmark extends BenchmarkBase {
+  @Param(Array("1000"))
+  var count: Int = _
+
+  private var msgpackValues: List[Value] = _
+
+  private var notEncodedValues: List[A] = _
+
+  private var spaceId: Int = _
+
+  @Setup(Level.Trial)
+  def setup(): Unit = {
+    val init: ZIO[TarantoolClient, TarantoolError, Int] = for {
+      space <- TarantoolClient.eval("box.schema.create_space('A', {if_not_exists = true})")
+      ids <- TarantoolClient.eval("box.schema.sequence.create('ids', {if_not_exists = true})")
+      index <- TarantoolClient.eval(
+        "box.space.A:create_index('primary', {if_not_exists = true, sequence='ids'})"
+      )
+
+      spaceIdReq <- TarantoolClient.eval("return box.space.A.id")
+      spaceId <- spaceIdReq.await.flatMap(_.head[Int])
+      _ <- space.await
+      _ <- ids.await
+      _ <- index.await
+    } yield spaceId
+
+    spaceId = zioUnsafeRun(init)
+
+    msgpackValues = (0 to count).map { i =>
+      new ImmutableArrayValueImpl(
+        Array(
+          ImmutableNilValueImpl.get(),
+          new ImmutableLongValueImpl(i.toLong),
+          new ImmutableStringValueImpl(s"value: $i")
+        )
+      )
+    }.toList
+
+    notEncodedValues = (0 to count).map(i => A(None, i.toLong, s"value: $i")).toList
+  }
+
+  @TearDown
+  def tearDown(): Unit =
+    zioUnsafeRun(
+      TarantoolClient.eval("box.space.A:truncate()").flatMap(_.await.unit)
+    )
+
+  @Benchmark
+  def insertMsgpackValues(): Unit =
+    zioUnsafeRun(
+      ZIO
+        .foreach(msgpackValues)(v => TarantoolClient.insert(spaceId, v))
+        .flatMap(promises => ZIO.foreach_(promises)(_.await))
+    )
+
+  @Benchmark
+  def insertNotEncodedValues(): Unit = {
+    import zio.tarantool.codec.auto._
+
+    zioUnsafeRun(
+      ZIO
+        .foreach(notEncodedValues)(v => TarantoolClient.insert(spaceId, v))
+        .flatMap(promises => ZIO.foreach_(promises)(_.await))
+    )
+  }
+}
+
+object TarantoolClientBenchmark {
+  final case class A(id: Option[Long], f1: Long, f3: String)
+}

build.sbt

@@ -1,5 +1,6 @@
 val zioVersion = "1.0.3"
-val scodecVersion = "1.11.7"
+val shapelessVersion = "2.3.7"
+val msgpackVersion = "0.9.0"
 val testContainersVersion = "0.39.5"
 val logbackVersion = "1.2.3"
 
@@ -111,7 +112,8 @@ lazy val core = project
   .settings(
     moduleName := "zio-tarantool-core",
     libraryDependencies ++= Seq(
-      "org.scodec" %% "scodec-core" % scodecVersion,
+      "org.msgpack" % "msgpack-core" % msgpackVersion,
+      "com.chuusai" %% "shapeless" % shapelessVersion,
       "dev.zio" %% "zio-streams" % zioVersion,
       "dev.zio" %% "zio-test" % zioVersion % Test,
       "dev.zio" %% "zio-test-sbt" % zioVersion % Test,
@@ -123,3 +125,11 @@ lazy val core = project
 
 lazy val examples =
   project.in(file("examples")).settings(allSettings).settings(noPublish).dependsOn(core)
+
+lazy val benchmarks =
+  project
+    .in(file("benchmarks"))
+    .enablePlugins(JmhPlugin)
+    .settings(allSettings)
+    .settings(noPublish)
+    .dependsOn(core)