wip: New commands format definition

VictorGaiva · Jan 2, 2024 · 2dbbaee · 2dbbaee
1 parent bec8dbe
commit 2dbbaee
Showing 1 changed file with 34 additions and 0 deletions.
diff --git 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]