From 4543b246367cb8be408ade2a37bfc117facfaebf Mon Sep 17 00:00:00 2001 From: Denys Fakhritdinov Date: Mon, 30 Sep 2024 11:39:52 +0200 Subject: [PATCH] revert private[journal] for some classes --- .../kafka/journal/conversions/ConsRecordToActionRecord.scala | 4 ++-- .../com/evolutiongaming/kafka/journal/util/SkafkaHelper.scala | 3 ++- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/journal/src/main/scala/com/evolutiongaming/kafka/journal/conversions/ConsRecordToActionRecord.scala b/journal/src/main/scala/com/evolutiongaming/kafka/journal/conversions/ConsRecordToActionRecord.scala index 742025054..c4904e6f3 100644 --- a/journal/src/main/scala/com/evolutiongaming/kafka/journal/conversions/ConsRecordToActionRecord.scala +++ b/journal/src/main/scala/com/evolutiongaming/kafka/journal/conversions/ConsRecordToActionRecord.scala @@ -8,12 +8,12 @@ import com.evolutiongaming.kafka.journal.util.CatsHelper.* import java.time.Instant -private[journal] trait ConsRecordToActionRecord[F[_]] { +trait ConsRecordToActionRecord[F[_]] { def apply(consRecord: ConsRecord): F[Option[ActionRecord[Action]]] } -private[journal] object ConsRecordToActionRecord { +object ConsRecordToActionRecord { implicit def apply[F[_]: MonadThrowable]( implicit consRecordToActionHeader: ConsRecordToActionHeader[F], diff --git a/journal/src/main/scala/com/evolutiongaming/kafka/journal/util/SkafkaHelper.scala b/journal/src/main/scala/com/evolutiongaming/kafka/journal/util/SkafkaHelper.scala index 8a0bb4c86..2c2892e82 100644 --- a/journal/src/main/scala/com/evolutiongaming/kafka/journal/util/SkafkaHelper.scala +++ b/journal/src/main/scala/com/evolutiongaming/kafka/journal/util/SkafkaHelper.scala @@ -12,7 +12,8 @@ import scodec.bits.ByteVector import scala.util.Try -private[journal] object SkafkaHelper { +// TODO move to skafka & scassandra +object SkafkaHelper { implicit def skafkaFromBytes[F[_]: Applicative]: skafka.FromBytes[F, ByteVector] = { (a: Bytes, _: Topic) => ByteVector.view(a).pure[F]