Skip to content

Commit

Permalink
Remove dependency on com.evolutiongaming:scache (#519)
Browse files Browse the repository at this point in the history
Co-authored-by: Ilya Surkov <isurkov@evolution.com>
  • Loading branch information
i-surkov and Ilya Surkov committed Aug 30, 2023
1 parent 9b58222 commit 79df14b
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 39 deletions.
10 changes: 6 additions & 4 deletions build.sbt
Original file line number Diff line number Diff line change
Expand Up @@ -69,8 +69,7 @@ lazy val journal = (project in file("journal")
hostname,
`cassandra-driver`,
scassandra,
scache0,
scache1,
scache,
`cassandra-sync`,
`scala-java8-compat`,
Pureconfig.pureconfig,
Expand Down Expand Up @@ -126,13 +125,16 @@ lazy val replicator = (Project("replicator", file("replicator"))
dependsOn (
journal % "test->test;compile->compile",
`eventual-cassandra`)
settings (libraryDependencies ++= Seq(`cats-helper`)))
settings (libraryDependencies ++= Seq(
`cats-helper`,
Logback.core % Test,
Logback.classic % Test)))

lazy val `eventual-cassandra` = (project in file("eventual-cassandra")
settings (name := "kafka-journal-eventual-cassandra")
settings commonSettings
dependsOn (journal % "test->test;compile->compile")
settings (libraryDependencies ++= Seq(scache0, scache1, scassandra)))
settings (libraryDependencies ++= Seq(scache, scassandra)))

lazy val `journal-circe` = (project in file("circe/core")
settings (name := "kafka-journal-circe")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,19 +5,12 @@ import cats.{Applicative, Monad}
import com.evolutiongaming.smetrics.CollectorRegistry
import com.evolution.scache.CacheMetrics

import scala.concurrent.duration.FiniteDuration

final case class HeadCacheMetrics[F[_]](headCache: HeadCache.Metrics[F], cache: CacheMetrics[F])

object HeadCacheMetrics {

def empty[F[_]: Applicative]: HeadCacheMetrics[F] = apply(HeadCache.Metrics.empty, CacheMetrics.empty)

@deprecated("use another `apply` instead", "2023-02-13")
def apply[F[_]](headCache: HeadCache.Metrics[F], cache: com.evolutiongaming.scache.CacheMetrics[F]): HeadCacheMetrics[F] = {
apply(headCache, cache.toCacheMetrics)
}

def of[F[_]: Monad](
registry: CollectorRegistry[F],
prefix: HeadCache.Metrics.Prefix = HeadCache.Metrics.Prefix.default
Expand All @@ -30,30 +23,4 @@ object HeadCacheMetrics {
}
}


private implicit class CacheMetrics0Ops[F[_]](val self: com.evolutiongaming.scache.CacheMetrics[F]) extends AnyVal {
def toCacheMetrics: CacheMetrics[F] = {
new CacheMetrics[F] {
def get(hit: Boolean) = self.get(hit)

def load(time: FiniteDuration, success: Boolean) = self.load(time, success)

def life(time: FiniteDuration) = self.life(time)

def put = self.put

def size(size: Int) = self.size(size)

def size(latency: FiniteDuration) = self.size(latency)

def values(latency: FiniteDuration) = self.values(latency)

def keys(latency: FiniteDuration) = self.keys(latency)

def clear(latency: FiniteDuration) = self.clear(latency)

def foldMap(latency: FiniteDuration) = self.foldMap(latency)
}
}
}
}
3 changes: 1 addition & 2 deletions project/Dependencies.scala
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,7 @@ object Dependencies {
val retry = "com.evolutiongaming" %% "retry" % "2.1.1"
val sstream = "com.evolutiongaming" %% "sstream" % "0.2.1"
val skafka = "com.evolutiongaming" %% "skafka" % "11.16.0"
val scache0 = "com.evolutiongaming" %% "scache" % "3.6.0"
val scache1 = "com.evolution" %% "scache" % "3.8.0"
val scache = "com.evolution" %% "scache" % "3.8.0"
val `akka-test-actor` = "com.evolutiongaming" %% "akka-test-actor" % "0.1.0"

object Cats {
Expand Down

0 comments on commit 79df14b

Please sign in to comment.