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

Integrate scalafix (#556)

上级 11cea94b
......@@ -30,7 +30,7 @@ jobs:
- name: Cache scala dependencies
uses: coursier/cache-action@v6
- name: Check code formatting
run: ./sbt fmtCheck
run: ./sbt check
publishLocal:
runs-on: ubuntu-20.04
......
rules = [
DisableSyntax
ExplicitResultTypes
LeakingImplicitClassVal
NoAutoTupling
NoValInForComprehension
OrganizeImports
ProcedureSyntax
RemoveUnused
]
OrganizeImports {
# Allign with IntelliJ IDEA so that they don't fight each other
groupedImports = Merge
}
RemoveUnused {
imports = false // handled by OrganizeImports
}
......@@ -16,13 +16,13 @@
package zio.redis.benchmarks
import zio.internal.Platform
import cats.effect.{IO => CIO}
import zio.{BootstrapRuntime, Has, ZIO, ZLayer}
import zio.internal.Platform
import zio.logging.Logging
import zio.redis._
import zio.redis.codec.StringUtf8Codec
import zio.schema.codec.Codec
import zio.{BootstrapRuntime, Has, ZIO, ZLayer}
trait BenchmarkRuntime extends BootstrapRuntime {
override val platform: Platform = Platform.benchmark
......
package zio.redis.benchmarks
import cats.effect.{IO => CIO, Resource}
import cats.effect.unsafe.implicits.global
import cats.effect.{IO => CIO, Resource}
import com.comcast.ip4s._
import dev.profunktor.redis4cats.RedisCommands
import dev.profunktor.redis4cats.codecs.Codecs
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.fs2.RedisClient
import laserdisc.auto.autoRefine
import dev.profunktor.redis4cats.Redis
import dev.profunktor.redis4cats.effect.Log.NoOp.instance
import dev.profunktor.redis4cats.codecs.Codecs
import dev.profunktor.redis4cats.codecs.splits._
import laserdisc.fs2.RedisClient
trait QueryRunner[Client] {
def unsafeRunWith(query: Client => CIO[Unit]): Unit
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.hash
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.hash
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.hash
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.hash
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.hash
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.hash
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.hash
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.hash
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.hash
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.hash
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.hash
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.hash
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.hash
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.hash
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,15 +16,14 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.duration._
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,15 +16,14 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.duration._
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,15 +16,14 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.duration._
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,15 +16,14 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.duration._
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.lists
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
package zio.redis
import cats.effect.{IO => CIO}
import dev.profunktor.redis4cats.RedisCommands
import io.chrisdavenport.rediculous.RedisConnection
import laserdisc.fs2.RedisClient
import cats.effect.{IO => CIO}
package object benchmarks {
type Redis4CatsClient[A] = RedisCommands[CIO, String, A]
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.sets
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.sets
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.sets
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.sets
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.sets
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.sets
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.sets
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.sets
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.sets
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.sets
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.sets
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.sets
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.sets
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.sets
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,17 +16,16 @@
package zio.redis.benchmarks.strings
import java.util.concurrent.TimeUnit
import cats.instances.list._
import cats.syntax.foldable._
import io.chrisdavenport.rediculous.{RedisCommands, RedisIO}
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,17 +16,16 @@
package zio.redis.benchmarks.strings
import java.util.concurrent.TimeUnit
import cats.instances.list._
import cats.syntax.foldable._
import io.chrisdavenport.rediculous.{RedisCommands, RedisIO}
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,17 +16,16 @@
package zio.redis.benchmarks.strings
import java.util.concurrent.TimeUnit
import cats.instances.list._
import cats.syntax.foldable._
import io.chrisdavenport.rediculous.{RedisCommands, RedisIO}
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,17 +16,16 @@
package zio.redis.benchmarks.strings
import java.util.concurrent.TimeUnit
import cats.instances.list._
import cats.syntax.foldable._
import io.chrisdavenport.rediculous.{RedisCommands, RedisIO}
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,17 +16,16 @@
package zio.redis.benchmarks.strings
import java.util.concurrent.TimeUnit
import cats.instances.list._
import cats.syntax.foldable._
import io.chrisdavenport.rediculous.{RedisCommands, RedisIO}
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.strings
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,14 +16,13 @@
package zio.redis.benchmarks.strings
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import zio.ZIO
import zio.redis._
import zio.redis.benchmarks._
import java.util.concurrent.TimeUnit
@State(Scope.Thread)
@BenchmarkMode(Array(Mode.Throughput))
@OutputTimeUnit(TimeUnit.SECONDS)
......
......@@ -16,8 +16,12 @@ inThisBuild(
)
)
addCommandAlias("check", "fixCheck; fmtCheck")
addCommandAlias("fix", "scalafixAll")
addCommandAlias("fixCheck", "scalafixAll --check")
addCommandAlias("fmt", "all scalafmtSbt scalafmtAll")
addCommandAlias("fmtCheck", "all scalafmtSbtCheck scalafmtCheckAll")
addCommandAlias("prepare", "fix; fmt")
lazy val root =
project
......
......@@ -16,10 +16,10 @@
package example
import scala.util.control.NoStackTrace
import zhttp.http._
import scala.util.control.NoStackTrace
sealed trait ApiError extends NoStackTrace { self =>
import ApiError._
......
......@@ -21,7 +21,6 @@ import sttp.client3.asynchttpclient.zio.{SttpClient, send}
import sttp.client3.ziojson.asJson
import sttp.client3.{UriContext, basicRequest}
import sttp.model.Uri
import zio._
import zio.duration._
import zio.json._
......
......@@ -20,8 +20,8 @@ import com.typesafe.config.ConfigFactory
import example.api.Api
import example.config.{AppConfig, ServerConfig}
import sttp.client3.asynchttpclient.zio.AsyncHttpClientZioBackend
import zhttp.service.{EventLoopGroup, Server}
import zhttp.service.server.ServerChannelFactory
import zhttp.service.{EventLoopGroup, Server}
import zio._
import zio.config.getConfig
import zio.config.syntax._
......@@ -29,8 +29,8 @@ import zio.config.typesafe.TypesafeConfig
import zio.console._
import zio.logging.Logging
import zio.magic._
import zio.redis.{Redis, RedisExecutor}
import zio.redis.codec.StringUtf8Codec
import zio.redis.{Redis, RedisExecutor}
import zio.schema.codec.Codec
object Main extends App {
......
......@@ -19,7 +19,6 @@ package example.api
import example._
import zhttp.http._
import zhttp.service.Server
import zio._
import zio.json._
......
......@@ -2,6 +2,7 @@ import sbt._
import Keys._
import sbtbuildinfo._
import BuildInfoKeys._
import scalafix.sbt.ScalafixPlugin.autoImport._
object BuildHelper {
private val versions: Map[String, String] = {
......@@ -48,7 +49,12 @@ object BuildHelper {
crossScalaVersions := List(Scala212, Scala213),
ThisBuild / scalaVersion := Scala213,
scalacOptions := stdOptions ++ extraOptions(scalaVersion.value, optimize = !isSnapshot.value),
Test / parallelExecution := true,
semanticdbEnabled := true,
semanticdbOptions += "-P:semanticdb:synthetics:on",
semanticdbVersion := scalafixSemanticdb.revision,
ThisBuild / scalafixScalaBinaryVersion := CrossVersion.binaryScalaVersion(scalaVersion.value),
ThisBuild / scalafixDependencies += "com.github.liancheng" %% "organize-imports" % "0.6.0",
Test / parallelExecution := true,
incOptions ~= (_.withLogRecompileOnMacro(false)),
autoAPIMappings := true
)
......
addSbtPlugin("ch.epfl.scala" % "sbt-bloop" % "1.4.13")
addSbtPlugin("ch.epfl.scala" % "sbt-scalafix" % "0.9.34")
addSbtPlugin("com.eed3si9n" % "sbt-buildinfo" % "0.11.0")
addSbtPlugin("com.github.sbt" % "sbt-ci-release" % "1.5.10")
addSbtPlugin("com.github.sbt" % "sbt-unidoc" % "0.5.0")
......
......@@ -16,15 +16,15 @@
package zio.redis
import zio._
import zio.logging._
import zio.stream.Stream
import java.io.{EOFException, IOException}
import java.net.{InetSocketAddress, SocketAddress, StandardSocketOptions}
import java.nio.ByteBuffer
import java.nio.channels.{AsynchronousSocketChannel, Channel, CompletionHandler}
import zio._
import zio.logging._
import zio.stream.Stream
private[redis] object ByteStream {
trait Service {
def read: Stream[IOException, Byte]
......
......@@ -16,15 +16,15 @@
package zio.redis
import java.time.Instant
import java.util.concurrent.TimeUnit
import zio.Chunk
import zio.duration.Duration
import zio.redis.RespValue.BulkString
import zio.schema.Schema
import zio.schema.codec.Codec
import java.time.Instant
import java.util.concurrent.TimeUnit
sealed trait Input[-A] {
self =>
......
......@@ -16,8 +16,8 @@
package zio.redis
import zio.{Has, URLayer, ZIO, ZLayer}
import zio.schema.codec.Codec
import zio.{Has, URLayer, ZIO, ZLayer}
trait Redis {
def codec: Codec
......
......@@ -17,7 +17,6 @@
package zio.redis
import java.io.IOException
import scala.util.control.NoStackTrace
sealed trait RedisError extends NoStackTrace
......
......@@ -16,11 +16,11 @@
package zio.redis
import java.nio.charset.StandardCharsets
import zio._
import zio.stream._
import java.nio.charset.StandardCharsets
sealed trait RespValue extends Product with Serializable { self =>
import RespValue._
import RespValue.internal.{Headers, NullStrEncoded, NullArrEncoded, CrLf}
......
......@@ -16,9 +16,9 @@
package zio.redis
import zio.{Has, ZIO}
import zio.redis.ResultBuilder.NeedsReturnType
import zio.schema.Schema
import zio.{Has, ZIO}
sealed trait ResultBuilder {
......
......@@ -16,17 +16,16 @@
package zio.redis
import java.nio.file.{FileSystems, Paths}
import java.time.Instant
import zio._
import zio.clock.Clock
import zio.duration._
import zio.redis.RedisError.ProtocolError
import zio.redis.RespValue.{bulkString, BulkString}
import zio.redis.RespValue.{BulkString, bulkString}
import zio.redis.TestExecutor.{KeyInfo, KeyType}
import zio.stm.{random => _, _}
import java.nio.file.{FileSystems, Paths}
import java.time.Instant
import scala.annotation.tailrec
import scala.collection.compat.immutable.LazyList
import scala.util.Try
......
......@@ -16,12 +16,12 @@
package zio.redis.api
import zio.{Chunk, Has, ZIO}
import zio.redis._
import zio.redis.Input._
import zio.redis.Output._
import zio.redis.ResultBuilder._
import zio.redis._
import zio.schema.Schema
import zio.{Chunk, Has, ZIO}
trait Hashes {
import Hashes._
......
......@@ -16,11 +16,11 @@
package zio.redis.api
import zio.{Has, ZIO}
import zio.redis.Input._
import zio.redis.Output._
import zio.redis._
import zio.schema.Schema
import zio.{Has, ZIO}
trait HyperLogLog {
import HyperLogLog._
......
......@@ -16,15 +16,15 @@
package zio.redis.api
import java.time.Instant
import zio.{Chunk, Has, ZIO}
import zio.duration._
import zio.redis._
import zio.redis.Input._
import zio.redis.Output._
import zio.redis.ResultBuilder._
import zio.redis._
import zio.schema.Schema
import zio.{Chunk, Has, ZIO}
import java.time.Instant
trait Keys {
import Keys.{Keys => _, _}
......
......@@ -16,13 +16,13 @@
package zio.redis.api
import zio.{Chunk, Has, ZIO}
import zio.duration._
import zio.redis._
import zio.redis.Input._
import zio.redis.Output._
import zio.redis.ResultBuilder._
import zio.redis._
import zio.schema.Schema
import zio.{Chunk, Has, ZIO}
trait Lists {
import Lists._
......
......@@ -16,11 +16,11 @@
package zio.redis.api
import zio.{Chunk, Has, ZIO}
import zio.redis._
import zio.redis.Input._
import zio.redis.Output._
import zio.redis.ResultBuilder.ResultOutputBuilder
import zio.redis._
import zio.{Chunk, Has, ZIO}
trait Scripting {
import Scripting._
......
......@@ -16,12 +16,12 @@
package zio.redis.api
import zio.{Chunk, Has, ZIO}
import zio.redis._
import zio.redis.Input._
import zio.redis.Output._
import zio.redis.ResultBuilder._
import zio.redis._
import zio.schema.Schema
import zio.{Chunk, Has, ZIO}
trait Sets {
import Sets._
......
......@@ -16,13 +16,13 @@
package zio.redis.api
import zio.{Chunk, Has, ZIO}
import zio.duration._
import zio.redis._
import zio.redis.Input._
import zio.redis.Output._
import zio.redis.ResultBuilder._
import zio.redis._
import zio.schema.Schema
import zio.{Chunk, Has, ZIO}
trait SortedSets {
import SortedSets._
......
......@@ -16,13 +16,13 @@
package zio.redis.api
import zio.{Chunk, Has, ZIO}
import zio.duration._
import zio.redis._
import zio.redis.Input._
import zio.redis.Output._
import zio.redis.ResultBuilder._
import zio.redis._
import zio.schema.Schema
import zio.{Chunk, Has, ZIO}
trait Streams {
import StreamInfoWithFull._
......
......@@ -16,15 +16,15 @@
package zio.redis.api
import java.time.Instant
import zio.{Chunk, Has, ZIO}
import zio.duration._
import zio.redis._
import zio.redis.Input._
import zio.redis.Output._
import zio.redis.ResultBuilder._
import zio.redis._
import zio.schema.Schema
import zio.{Chunk, Has, ZIO}
import java.time.Instant
trait Strings {
import Strings._
......
......@@ -16,8 +16,6 @@
package zio.redis.codec
import java.nio.charset.StandardCharsets
import zio.redis.RedisError.CodecError
import zio.schema.Schema
import zio.schema.StandardType.{DoubleType, IntType, LongType}
......@@ -25,6 +23,8 @@ import zio.schema.codec.Codec
import zio.stream.ZTransducer
import zio.{Chunk, ZIO}
import java.nio.charset.StandardCharsets
object StringUtf8Codec extends Codec {
def encoder[A](schema: Schema[A]): ZTransducer[Any, Nothing, A, Byte] =
ZTransducer.fromPush { (opt: Option[Chunk[A]]) =>
......
......@@ -16,10 +16,10 @@
package zio.redis.options
import java.net.InetAddress
import zio.duration.Duration
import java.net.InetAddress
trait Connection {
sealed case class Address(ip: InetAddress, port: Int) {
private[redis] final def stringify: String = s"${ip.getHostAddress}:$port"
......
package zio.redis
import java.time.Instant
import java.util.UUID
import zio.UIO
import zio.duration._
import zio.random.Random
......@@ -12,6 +9,9 @@ import zio.test.TestAspect.tag
import zio.test._
import zio.test.environment.Live
import java.time.Instant
import java.util.UUID
trait BaseSpec extends DefaultRunnableSpec {
override def aspects: List[TestAspectAtLeastR[Live]] = List(TestAspect.timeout(60.seconds))
......
package zio.redis
import java.nio.charset.StandardCharsets
import zio.logging.Logging
import zio.test.Assertion._
import zio.test._
import zio.{Chunk, ZIO}
import java.nio.charset.StandardCharsets
object ByteStreamSpec extends BaseSpec {
override def spec: ZSpec[Environment, Failure] =
suite("Byte stream")(
......
package zio.redis
import java.net.InetAddress
import zio.Has
import zio.duration._
import zio.test.Assertion._
import zio.test.TestAspect._
import zio.test._
import zio.Has
import java.net.InetAddress
trait ConnectionSpec extends BaseSpec {
......
package zio.redis
import zio.{Chunk, Has}
import zio.test.Assertion._
import zio.test._
import zio.{Chunk, Has}
trait GeoSpec extends BaseSpec {
......
package zio.redis
import zio.{Chunk, Has}
import zio.random.Random
import zio.test.Assertion._
import zio.test._
import zio.{Chunk, Has}
trait HashSpec extends BaseSpec {
......
package zio.redis
import zio.Has
import zio.test.Assertion._
import zio.test._
import zio.Has
trait HyperLogLogSpec extends BaseSpec {
......
package zio.redis
import java.net.InetAddress
import java.time.Instant
import zio.duration._
import zio.redis.Input._
import zio.test.Assertion._
import zio.test._
import zio.{Chunk, Task, UIO}
import java.net.InetAddress
import java.time.Instant
object InputSpec extends BaseSpec {
import StrAlgoLcsQueryType._
import BitFieldCommand._
......
package zio.redis
import zio.{clock, Chunk, Has, Layer, ZIO, ZLayer}
import zio.clock.Clock
import zio.duration._
import zio.logging.Logging
......@@ -8,10 +7,11 @@ import zio.random.Random
import zio.redis.RedisError.ProtocolError
import zio.redis.codec.StringUtf8Codec
import zio.schema.codec.Codec
import zio.test._
import zio.test.Assertion._
import zio.test.TestAspect._
import zio.test._
import zio.test.environment.TestClock
import zio.{Chunk, Has, Layer, ZIO, ZLayer, clock}
trait KeysSpec extends BaseSpec {
......
package zio.redis
import java.util.concurrent.TimeUnit
import zio.{Chunk, Has}
import zio.clock.{currentTime, Clock}
import zio.clock.{Clock, currentTime}
import zio.duration._
import zio.redis.RedisError.WrongType
import zio.test.Assertion._
import zio.test._
import zio.test.environment.TestClock
import zio.{Chunk, Has}
import java.util.concurrent.TimeUnit
trait ListSpec extends BaseSpec {
val listSuite: Spec[Has[Redis] with Clock with TestClock, TestFailure[java.io.Serializable], TestSuccess] =
......
package zio.redis
import java.nio.charset.StandardCharsets
import zio.Chunk
import zio.stream.Stream
import zio.test.Assertion._
import zio.test._
import java.nio.charset.StandardCharsets
object RespValueSpec extends BaseSpec {
def spec: Spec[Any, TestFailure[RedisError.ProtocolError], TestSuccess] =
......
......@@ -5,8 +5,8 @@ import zio.redis.Input.{BoolInput, ByteInput, LongInput, StringInput}
import zio.redis.Output._
import zio.redis.RedisError._
import zio.redis.ScriptingSpec._
import zio.test._
import zio.test.Assertion._
import zio.test._
import scala.util.Random
......
......@@ -2,9 +2,9 @@ package zio.redis
import zio.duration._
import zio.redis.RedisError._
import zio.test._
import zio.test.Assertion._
import zio.test.TestAspect.ignore
import zio.test._
import zio.{Chunk, Has}
trait StreamsSpec extends BaseSpec {
......
package zio.redis
import zio.{clock, Chunk, Has, ZIO}
import zio.clock.Clock
import zio.duration._
import zio.redis.RedisError.{ProtocolError, WrongType}
import zio.test._
import zio.test.Assertion._
import zio.test.TestAspect.{eventually, ignore}
import zio.test._
import zio.test.environment.{TestClock, TestConsole, TestRandom, TestSystem}
import zio.{Chunk, Has, ZIO, clock}
trait StringsSpec extends BaseSpec {
val stringsSuite: Spec[
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册