Update SerializingContext code.

Author: YoEight

src/main/java/io/kurrent/dbclient/v2/DeserializeFunction.java

@@ -0,0 +1,19 @@
+package io.kurrent.dbclient.v2;
+
+import java.nio.ByteBuffer;
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * Functional interface for deserializing bytes into an object.
+ */
+@FunctionalInterface
+public interface DeserializeFunction {
+    /**
+     * Deserializes the given bytes into an object according to the provided metadata.
+     *
+     * @param data The bytes to be deserialized.
+     * @param metadata The metadata providing additional information for the deserialization process.
+     * @return A CompletableFuture that resolves to the deserialized object.
+     */
+    CompletableFuture<Object> deserialize(ByteBuffer data, Metadata metadata);
+}

src/main/java/io/kurrent/dbclient/v2/SchemaSerializer.java

@@ -0,0 +1,43 @@
+package io.kurrent.dbclient.v2;
+
+import java.nio.ByteBuffer;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CancellationException;
+
+/**
+ * Defines the interface for a schema serializer.
+ */
+public interface SchemaSerializer {
+    /**
+     * The type of the schema.
+     *
+     * @return The data format of the schema.
+     */
+    SchemaDataFormat getDataFormat();
+
+    /**
+     * Serializes the given value into bytes according to the provided context.
+     *
+     * @param value The object to be serialized.
+     * @param context The context providing additional information for the serialization process.
+     * @return A CompletableFuture that resolves to a ByteBuffer containing the serialized data.
+     */
+    CompletableFuture<ByteBuffer> serialize(Object value, SerializationContext context);
+
+    /**
+     * Deserializes the given bytes into an object according to the provided context.
+     *
+     * @param data The bytes to be deserialized.
+     * @param context The context providing additional information for the deserialization process.
+     * @return A CompletableFuture that resolves to the deserialized object.
+     */
+    CompletableFuture<Object> deserialize(ByteBuffer data, SerializationContext context);
+
+    /**
+     * Serializes the given message.
+     *
+     * @param message The message to be serialized.
+     * @return A CompletableFuture that resolves to a ByteBuffer containing the serialized data.
+     */
+    CompletableFuture<ByteBuffer> serialize(Message message);
+}

src/main/java/io/kurrent/dbclient/v2/SerializationContext.java

@@ -0,0 +1,50 @@
+package io.kurrent.dbclient.v2;
+
+/**
+ * Allows the serialization operations to be autonomous.
+ */
+public final class SerializationContext {
+    private final Metadata metadata;
+    private final String stream;
+    private final SchemaInfo schemaInfo;
+
+    /**
+     * Initializes a new instance of the SerializationContext class with the specified metadata, stream, and cancellation flag.
+     *
+     * @param metadata The metadata providing additional information for the serialization process.
+     * @param stream The stream that the record belongs to.
+     */
+    public SerializationContext(Metadata metadata, String stream) {
+        this.metadata = metadata;
+        this.stream = stream;
+        this.schemaInfo = SchemaInfo.fromMetadata(this.metadata);
+    }
+
+    /**
+     * Gets the metadata providing additional information for the serialization process.
+     *
+     * @return The metadata.
+     */
+    public Metadata getMetadata() {
+        return metadata;
+    }
+
+    /**
+     * Gets the stream that the record belongs to.
+     *
+     * @return The stream.
+     */
+    public String getStream() {
+        return stream;
+    }
+
+    /**
+     * Gets the schema information extracted from the headers.
+     * If the headers do not contain schema information, it will return an undefined schema information.
+     *
+     * @return The schema information.
+     */
+    public SchemaInfo getSchemaInfo() {
+        return schemaInfo;
+    }
+}

src/main/java/io/kurrent/dbclient/v2/SerializeFunction.java

@@ -0,0 +1,19 @@
+package io.kurrent.dbclient.v2;
+
+import java.nio.ByteBuffer;
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * Functional interface for serializing an object into bytes.
+ */
+@FunctionalInterface
+public interface SerializeFunction {
+    /**
+     * Serializes the given value into bytes according to the provided metadata.
+     *
+     * @param value The object to be serialized.
+     * @param metadata The metadata providing additional information for the serialization process.
+     * @return A CompletableFuture that resolves to a ByteBuffer containing the serialized data.
+     */
+    CompletableFuture<ByteBuffer> serialize(Object value, Metadata metadata);
+}