RichSerde

interface RichSerde<T> : Serde<T>

Richer version of Serde containing schema information.

This API should be considered unstable to implement.

You can create one using withSchema.

Properties

Pass through Serde for ByteBuffer.

Pass through Serde for byte array.

val VOID: Serde<@Nullable Void>

Noop Serde for void.

@Nullable

open fun contentType(): @Nullable String

Content-type to use in request/responses.

abstract fun deserialize(value: Array<Byte>): T

open fun deserialize(byteBuffer: ByteBuffer): T

abstract fun jsonSchema(): Any

abstract fun serialize(value: T): Array<Byte>

open fun <T> using(serializer: ThrowingFunction<T, Array<Byte>>, deserializer: ThrowingFunction<Array<Byte>, T>): Serde<@NonNull T>

Like using, using content-type


application/octet-stream

open fun <T> using(contentType: String, serializer: ThrowingFunction<T, Array<Byte>>, deserializer: ThrowingFunction<Array<Byte>, T>): Serde<@NonNull T>

Create a Serde from serializer/deserializer lambdas, tagging with contentType.

open fun <T> withContentType(contentType: String, inner: Serde<T>): Serde<T>

open fun <T> withSchema(jsonSchema: Any, inner: Serde<T>): RichSerde<T>