common/dev.restate.serde/SerdePipeline

SerdePipeline

@ApiStatus.Internal

Combines a SerdeFactory and a PayloadCodec: resolves the Serde from the TypeTag, then serializes and encodes, or decodes and deserializes, the values.

Constructors

SerdePipeline

constructor(serdeFactory: SerdeFactory, @Nullable payloadCodec: @Nullable PayloadCodec)

Functions

decode

open fun <T> decode(typeTag: TypeTag<T>, value: Slice): CompletableFuture<T>

Decode the value, then resolve the serde and deserialize it.

encode

open fun <T> encode(typeTag: TypeTag<T>, value: T): CompletableFuture<Slice>

Resolve the serde, serialize the value, then encode it.

payloadCodec

open fun payloadCodec(): PayloadCodec

serdeFactory

open fun serdeFactory(): SerdeFactory