From 2dbbaeed1041aa5de69da63ab0a42ea2e3ac879c Mon Sep 17 00:00:00 2001
From: Victor Gaiva <13839490+VictorGaiva@users.noreply.github.com>
Date: Tue, 2 Jan 2024 18:32:34 -0300
Subject: [PATCH] wip: New commands format definition

---
 lib/message/data.ex | 34 ++++++++++++++++++++++++++++++++++
 1 file changed, 34 insertions(+)

diff --git a/lib/message/data.ex b/lib/message/data.ex
index 06d502e..2db3efd 100644
--- a/lib/message/data.ex
+++ b/lib/message/data.ex
@@ -265,6 +265,40 @@ defmodule RabbitMQStream.Message.Data do
     defstruct []
   end
 
+  defmodule RouteRequestData do
+    @moduledoc false
+    @enforce_keys [:routing_key, :super_stream]
+    @type t :: %{
+            routing_key: String.t(),
+            super_stream: String.t()
+          }
+    defstruct [
+      :routing_key,
+      :super_stream
+    ]
+  end
+
+  defmodule RouteResponseData do
+    @moduledoc false
+    @enforce_keys [:stream]
+    @type t :: %{stream: String.t()}
+    defstruct [:stream]
+  end
+
+  defmodule PartitionsQueryRequestData do
+    @moduledoc false
+    @enforce_keys [:super_stream]
+    @type t :: %{super_stream: String.t()}
+    defstruct [:super_stream]
+  end
+
+  defmodule PartitionsQueryRequestData do
+    @moduledoc false
+    @enforce_keys [:stream]
+    @type t :: %{stream: String.t()}
+    defstruct [:stream]
+  end
+
   defmodule DeliverData do
     @moduledoc false
     @enforce_keys [:subscription_id, :osiris_chunk]