Serde

interface Serde<T>

Interface defining serialization and deserialization of concrete types.

Serde implementations are provided in JsonSerdes in sdk-api, KtSerdes in sdk-api-kotlin, JacksonSerdes in sdk-serde-jackson, ProtobufSerdes in sdk-serde-protobuf.

You can create a custom one using using.

Properties

BYTE_BUFFER

val BYTE_BUFFER: Serde<ByteBuffer>

Pass through Serde for ByteBuffer.

RAW

val RAW: Serde<Array<Byte>>

Pass through Serde for byte array.

VOID

val VOID: Serde<Void>

Noop Serde for void.

Functions

contentType

@Nullable

open fun contentType(): @Nullable String

Content-type to use in request/responses.

deserialize

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

open fun deserialize(byteBuffer: ByteBuffer): T

serialize

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

serializeToByteBuffer

open fun serializeToByteBuffer(@Nullable value: @Nullable T): ByteBuffer

using

open fun <T> using(serializer: ThrowingFunction<T, Array<Byte>>, deserializer: ThrowingFunction<Array<Byte>, T>): Serde<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<T>

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

withContentType

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