Revert "#112 Metrics for RateLimiter (#119)"

This reverts commit 4d38b43.
svroonland · May 24, 2021 · 3f6e184 · 3f6e184
1 parent 3b53426
commit 3f6e184
Show file tree

Hide file tree

Showing 8 changed files with 3 additions and 318 deletions.
diff --git a/build.sbt b/build.sbt
@@ -40,13 +40,7 @@ lazy val root = project
 
 lazy val rezilience = crossProject(JSPlatform, JVMPlatform)
   .in(file("rezilience"))
-  .jvmSettings(
-    commonJvmSettings ++ Seq(
-      libraryDependencies ++= Seq(
-        "org.hdrhistogram" % "HdrHistogram" % "2.1.12"
-      )
-    )
-  )
+  .jvmSettings(commonJvmSettings)
   .jsSettings(commonJsSettings)
   .settings(
     name := "rezilience",

diff --git a/docs/docs/docs/metrics.md b/docs/docs/docs/metrics.md
diff --git a/rezilience/js/src/main/scala/nl/vroste/rezilience/RateLimiterPlatformSpecific.scala b/rezilience/js/src/main/scala/nl/vroste/rezilience/RateLimiterPlatformSpecific.scala
diff --git a/rezilience/jvm/src/main/scala/nl/vroste/rezilience/HistogramSettings.scala b/rezilience/jvm/src/main/scala/nl/vroste/rezilience/HistogramSettings.scala
diff --git a/rezilience/jvm/src/main/scala/nl/vroste/rezilience/HistogramUtil.scala b/rezilience/jvm/src/main/scala/nl/vroste/rezilience/HistogramUtil.scala
diff --git a/rezilience/jvm/src/main/scala/nl/vroste/rezilience/RateLimiterPlatformSpecific.scala b/rezilience/jvm/src/main/scala/nl/vroste/rezilience/RateLimiterPlatformSpecific.scala
diff --git a/rezilience/jvm/src/test/scala/nl/vroste/rezilience/RateLimiterMetricsSpec.scala b/rezilience/jvm/src/test/scala/nl/vroste/rezilience/RateLimiterMetricsSpec.scala
diff --git a/rezilience/shared/src/main/scala/nl/vroste/rezilience/RateLimiter.scala b/rezilience/shared/src/main/scala/nl/vroste/rezilience/RateLimiter.scala
@@ -34,7 +34,7 @@ trait RateLimiter { self =>
   }
 }
 
-object RateLimiter extends RateLimiterPlatformSpecificObj {
+object RateLimiter {
 
   /**
    * Creates a RateLimiter as Managed resource
@@ -53,7 +53,7 @@ object RateLimiter extends RateLimiterPlatformSpecificObj {
              .bounded[(Ref[Boolean], UIO[Any])](zio.internal.RingBuffer.nextPow2(max))
              .toManaged_ // Power of two because it is a more efficient queue implementation
       _ <- ZStream
-             .fromQueue(q, 1) // Until https://github.com/zio/zio/issues/4190 is fixed
+             .fromQueue(q, maxChunkSize = max)
              .filterM { case (interrupted, effect @ _) => interrupted.get.map(!_) }
              .throttleShape(max.toLong, interval, max.toLong)(_.size.toLong)
              .mapMParUnordered(Int.MaxValue) { case (interrupted @ _, effect) => effect }