未验证 提交 4d5eed50 编写于 作者: D Dejan Mijić 提交者: GitHub

Update Scala 2.12 and Rediculous (#634)

上级 7b08682d
......@@ -73,7 +73,7 @@ jobs:
fail-fast: false
matrix:
java: ['8', '11', '17']
scala: ['2.12.15', '2.13.8']
scala: ['2.12.16', '2.13.8']
steps:
- name: Checkout current branch
uses: actions/checkout@v3.0.2
......
......@@ -17,10 +17,9 @@ pull_request_rules:
- name: merge Scala Steward's PRs
conditions:
- author=scala-steward
- "body~=(labels: library-update, early-semver-minor)|(labels: library-update, early-semver-patch)|(labels: sbt-plugin-update, early-semver-minor)|(labels: sbt-plugin-update, early-semver-patch)|(labels: test-library-update)"
- "body~=(labels: library-update, early-semver-minor)|(labels: library-update, early-semver-patch)|(labels: sbt-plugin-update, early-semver-minor)|(labels: sbt-plugin-update, early-semver-patch)|(labels: scalafix-rule-update)|(labels: test-library-update)"
- "status-success=license/cla"
- "status-success=ci"
actions:
merge:
method: squash
......@@ -8,7 +8,6 @@ import dev.profunktor.redis4cats.codecs.splits._
import dev.profunktor.redis4cats.data.RedisCodec
import dev.profunktor.redis4cats.effect.Log.NoOp.instance
import dev.profunktor.redis4cats.{Redis, RedisCommands}
import fs2.io.net.Network
import io.chrisdavenport.rediculous.RedisConnection
import io.lettuce.core.ClientOptions
import laserdisc.auto.autoRefine
......@@ -27,10 +26,10 @@ object QueryRunner {
Laserdisc.use(f).unsafeRunSync()
}
implicit val redicoulusRunner: QueryRunner[RediculousClient] =
implicit val rediculousRunner: QueryRunner[RediculousClient] =
new QueryRunner[RediculousClient] {
def unsafeRunWith(f: RediculousClient => CIO[Unit]): Unit =
Redicoulus.use(f).unsafeRunSync()
Rediculous.use(f).unsafeRunSync()
}
implicit val redis4CatsStringRunner: QueryRunner[Redis4CatsClient[String]] =
......@@ -50,8 +49,14 @@ object QueryRunner {
private[this] final val Laserdisc: Resource[CIO, LaserDiscClient] = RedisClient[CIO].to(RedisHost, RedisPort)
private[this] final val Redicoulus: Resource[CIO, RediculousClient] =
RedisConnection.queued[CIO](Network[CIO], host"127.0.0.1", port"6379", maxQueued = 10000, workers = 2)
private[this] final val Rediculous: Resource[CIO, RediculousClient] =
RedisConnection
.queued[CIO]
.withHost(host"127.0.0.1")
.withPort(port"6379")
.withMaxQueued(10000)
.withWorkers(2)
.build
private[this] final val Redis4CatsLong: Resource[CIO, RedisCommands[CIO, String, Long]] = {
val longCodec = Codecs.derive(RedisCodec.Utf8, stringLongEpi)
......
......@@ -57,7 +57,7 @@ lazy val benchmarks =
publish / skip := true,
libraryDependencies ++= Seq(
"dev.profunktor" %% "redis4cats-effects" % "1.2.0",
"io.chrisdavenport" %% "rediculous" % "0.1.1",
"io.chrisdavenport" %% "rediculous" % "0.4.0",
"io.laserdisc" %% "laserdisc-fs2" % "0.5.0",
"dev.zio" %% "zio-schema-protobuf" % "0.1.11"
)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册