object Serializer

Source
Serializer.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Serializer
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def apply[F[_]](implicit F: Sync[F]): Serializer[F, Array[Byte]]

    Alias for Serializer#identity.

  5. def apply[F[_], A](implicit serializer: Serializer[F, A]): Serializer[F, A]
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def asNull[F[_], A](implicit F: Sync[F]): Serializer[F, A]

    Creates a new Serializer which serializes all values of type A as null.

  8. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  9. def const[F[_], A](bytes: Array[Byte])(implicit F: Sync[F]): Serializer[F, A]

    Creates a new Serializer which serializes all values of type A to the specified bytes.

  10. implicit def contravariant[F[_]]: Contravariant[[β$0$]Serializer[F, β$0$]]
  11. def delegate[F[_], A](serializer: KafkaSerializer[A])(implicit F: Sync[F]): Serializer[F, A]

    Creates a new Serializer which delegates serialization to the specified Kafka Serializer.

    Creates a new Serializer which delegates serialization to the specified Kafka Serializer. Note the close and configure functions won't be called for the delegate.

    It is assumed the delegate serialize function is pure. If it's not pure, then use suspend after delegate, so the impure behaviours can be captured properly.

  12. implicit def double[F[_]](implicit F: Sync[F]): Serializer[F, Double]
  13. def empty[F[_], A](implicit F: Sync[F]): Serializer[F, A]

    Creates a new Serializer which serializes all values of type A as the empty Array[Byte].

  14. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  16. def fail[F[_], A](e: Throwable)(implicit F: Sync[F]): Serializer[F, A]

    Creates a new Serializer which always fails serialization with the specified exception e.

  17. def failWith[F[_], A](message: String)(implicit F: Sync[F]): Serializer[F, A]

    Creates a new Serializer which always fails serialization with a SerializationException using the specified message.

  18. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  19. implicit def float[F[_]](implicit F: Sync[F]): Serializer[F, Float]
  20. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  21. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  22. def headers[F[_], A](f: (Headers) => Serializer[F, A])(implicit F: Sync[F]): Serializer[F, A]

    Creates a new Serializer which can use different Serializers depending on the record headers.

  23. implicit def identity[F[_]](implicit F: Sync[F]): Serializer[F, Array[Byte]]

    The identity Serializer, which does not perform any kind of serialization, simply using the input bytes as the output.

  24. def instance[F[_], A](f: (String, Headers, A) => F[Array[Byte]])(implicit F: Sync[F]): Serializer[F, A]

    Creates a new Serializer from the specified function.

    Creates a new Serializer from the specified function. Use lift instead if the serializer doesn't need access to the Kafka topic name or record headers.

  25. implicit def int[F[_]](implicit F: Sync[F]): Serializer[F, Int]
  26. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  27. def lift[F[_], A](f: (A) => F[Array[Byte]])(implicit F: Sync[F]): Serializer[F, A]

    Creates a new Serializer from the specified function, ignoring to which Kafka topic the bytes are going to be sent and any record headers.

    Creates a new Serializer from the specified function, ignoring to which Kafka topic the bytes are going to be sent and any record headers. Use instance instead if the serializer needs access to the Kafka topic name or the record headers.

  28. implicit def long[F[_]](implicit F: Sync[F]): Serializer[F, Long]
  29. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  30. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  31. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  32. implicit def option[F[_], A](implicit serializer: Serializer[F, A]): Serializer[F, Option[A]]

    The option Serializer serializes None as null, and serializes Some values using the serializer for type A.

  33. implicit def short[F[_]](implicit F: Sync[F]): Serializer[F, Short]
  34. implicit def string[F[_]](implicit F: Sync[F]): Serializer[F, String]
  35. def string[F[_]](charset: Charset)(implicit F: Sync[F]): Serializer[F, String]

    Creates a new Serializer which serializes String values using the specified Charset.

    Creates a new Serializer which serializes String values using the specified Charset. Note that the default String serializer uses UTF-8.

  36. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  37. def toString(): String
    Definition Classes
    AnyRef → Any
  38. def topic[F[_], A](f: PartialFunction[String, Serializer[F, A]])(implicit F: Sync[F]): Serializer[F, A]

    Creates a new Serializer which can use different Serializers depending on the Kafka topic name to which the bytes are going to be sent.

  39. implicit def unit[F[_]](implicit F: Sync[F]): Serializer[F, Unit]
  40. implicit def uuid[F[_]](implicit F: Sync[F]): Serializer[F, UUID]
  41. def uuid[F[_]](charset: Charset)(implicit F: Sync[F]): Serializer[F, UUID]

    Creates a new Serializer which serializes UUID values as Strings with the specified Charset.

    Creates a new Serializer which serializes UUID values as Strings with the specified Charset. Note that the default UUID serializer uses UTF-8.

  42. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  43. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  44. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped