Skip to content

Commit

Permalink
revert private[journal] for some classes
Browse files Browse the repository at this point in the history
  • Loading branch information
Denys Fakhritdinov committed Sep 30, 2024
1 parent e9c73c2 commit 4543b24
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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],
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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]
Expand Down

0 comments on commit 4543b24

Please sign in to comment.