Skip to content

Commit

Permalink
Revert some visibility changes (#699)
Browse files Browse the repository at this point in the history
- PersistentBinary should be public because PersistentJson is
- HeadInfo should be public because HeadCache interface is public, and
it can't be implemented because HeadInfo is currently private
  • Loading branch information
migesok authored Nov 27, 2024
1 parent e6366df commit 9bcd460
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -25,9 +25,9 @@ import com.evolutiongaming.skafka.Offset
* @see
* [[Journals]] for more details on how it is used.
*/
private[journal] sealed abstract class HeadInfo extends Product
sealed abstract class HeadInfo extends Product

private[journal] object HeadInfo {
object HeadInfo {

/** There are no non-replicated events in Kafka for specific journal.
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,9 +5,9 @@ import com.evolutiongaming.kafka.journal.{FromAttempt, FromBytes, ToBytes}
import com.evolutiongaming.serialization.SerializedMsg
import scodec.{Codec, HListCodecEnrichedWithHListSupport, TransformSyntax, ValueCodecEnrichedWithHListSupport, codecs}

private[journal] final case class PersistentBinary(manifest: Option[String], writerUuid: String, payload: SerializedMsg)
final case class PersistentBinary(manifest: Option[String], writerUuid: String, payload: SerializedMsg)

private[journal] object PersistentBinary {
object PersistentBinary {

implicit val codecPersistentBinary: Codec[PersistentBinary] = {
val codec = codecs.optional(codecs.bool, codecs.utf8_32) :: codecs.utf8_32 :: SerializedMsg.CodecSerializedMsg
Expand Down

0 comments on commit 9bcd460

Please sign in to comment.