defmodule(Kayrock.ApiVersions) do @moduledoc false _ = " THIS CODE IS GENERATED BY KAYROCK" defmodule(V0.Request) do @moduledoc false _ = " THIS CODE IS GENERATED BY KAYROCK" defstruct(correlation_id: nil, client_id: nil) @type t :: %__MODULE__{} def(api_key) do Kayrock.KafkaSchemaMetadata.api_key(:api_versions) end def(api_vsn) do 0 end def(response_deserializer) do &V0.Response.deserialize/1 end def(schema) do [] end def(serialize(%V0.Request{} = struct)) do [ <>, [] ] end end defimpl(Elixir.Kayrock.Request, for: V0.Request) do def(serialize(%V0.Request{} = struct)) do try do V0.Request.serialize(struct) rescue e -> reraise(Kayrock.InvalidRequestError, {e, struct}, System.stacktrace()) end end def(api_vsn(%V0.Request{})) do V0.Request.api_vsn() end def(response_deserializer(%V0.Request{})) do V0.Request.response_deserializer() end end defmodule(V1.Request) do @moduledoc false _ = " THIS CODE IS GENERATED BY KAYROCK" defstruct(correlation_id: nil, client_id: nil) @type t :: %__MODULE__{} def(api_key) do Kayrock.KafkaSchemaMetadata.api_key(:api_versions) end def(api_vsn) do 1 end def(response_deserializer) do &V1.Response.deserialize/1 end def(schema) do [] end def(serialize(%V1.Request{} = struct)) do [ <>, [] ] end end defimpl(Elixir.Kayrock.Request, for: V1.Request) do def(serialize(%V1.Request{} = struct)) do try do V1.Request.serialize(struct) rescue e -> reraise(Kayrock.InvalidRequestError, {e, struct}, System.stacktrace()) end end def(api_vsn(%V1.Request{})) do V1.Request.api_vsn() end def(response_deserializer(%V1.Request{})) do V1.Request.response_deserializer() end end def(get_request_struct(0)) do %V0.Request{} end def(get_request_struct(1)) do %V1.Request{} end defmodule(V0.Response) do @moduledoc false _ = " THIS CODE IS GENERATED BY KAYROCK" defstruct(error_code: nil, api_versions: [], correlation_id: nil) @type t :: %__MODULE__{} import(Elixir.Kayrock.Deserialize) def(api_key) do Kayrock.KafkaSchemaMetadata.api_key(:api_versions) end def(api_vsn) do 0 end def(schema) do [ error_code: :int16, api_versions: {:array, [api_key: :int16, min_version: :int16, max_version: :int16]} ] end def(deserialize(data)) do <> = data deserialize_field(:root, :error_code, %__MODULE__{correlation_id: correlation_id}, rest) end defp(deserialize_field(:root, :error_code, acc, data)) do {val, rest} = deserialize(:int16, data) deserialize_field(:root, :api_versions, Map.put(acc, :error_code, val), rest) end defp(deserialize_field(:api_versions, :api_key, acc, data)) do {val, rest} = deserialize(:int16, data) deserialize_field(:api_versions, :min_version, Map.put(acc, :api_key, val), rest) end defp(deserialize_field(:api_versions, :min_version, acc, data)) do {val, rest} = deserialize(:int16, data) deserialize_field(:api_versions, :max_version, Map.put(acc, :min_version, val), rest) end defp(deserialize_field(:api_versions, :max_version, acc, data)) do {val, rest} = deserialize(:int16, data) deserialize_field(:api_versions, nil, Map.put(acc, :max_version, val), rest) end defp(deserialize_field(:root, :api_versions, acc, data)) do <> = data {vals, rest} = if(num_elements > 0) do Enum.reduce(1..num_elements, {[], rest}, fn _ix, {acc, d} -> {val, r} = deserialize_field(:api_versions, :api_key, %{}, d) {[val | acc], r} end) else {[], rest} end deserialize_field(:root, nil, Map.put(acc, :api_versions, Enum.reverse(vals)), rest) end defp(deserialize_field(_, nil, acc, rest)) do {acc, rest} end end defmodule(V1.Response) do @moduledoc false _ = " THIS CODE IS GENERATED BY KAYROCK" defstruct(error_code: nil, api_versions: [], throttle_time_ms: nil, correlation_id: nil) @type t :: %__MODULE__{} import(Elixir.Kayrock.Deserialize) def(api_key) do Kayrock.KafkaSchemaMetadata.api_key(:api_versions) end def(api_vsn) do 1 end def(schema) do [ error_code: :int16, api_versions: {:array, [api_key: :int16, min_version: :int16, max_version: :int16]}, throttle_time_ms: :int32 ] end def(deserialize(data)) do <> = data deserialize_field(:root, :error_code, %__MODULE__{correlation_id: correlation_id}, rest) end defp(deserialize_field(:root, :error_code, acc, data)) do {val, rest} = deserialize(:int16, data) deserialize_field(:root, :api_versions, Map.put(acc, :error_code, val), rest) end defp(deserialize_field(:api_versions, :api_key, acc, data)) do {val, rest} = deserialize(:int16, data) deserialize_field(:api_versions, :min_version, Map.put(acc, :api_key, val), rest) end defp(deserialize_field(:api_versions, :min_version, acc, data)) do {val, rest} = deserialize(:int16, data) deserialize_field(:api_versions, :max_version, Map.put(acc, :min_version, val), rest) end defp(deserialize_field(:api_versions, :max_version, acc, data)) do {val, rest} = deserialize(:int16, data) deserialize_field(:api_versions, nil, Map.put(acc, :max_version, val), rest) end defp(deserialize_field(:root, :api_versions, acc, data)) do <> = data {vals, rest} = if(num_elements > 0) do Enum.reduce(1..num_elements, {[], rest}, fn _ix, {acc, d} -> {val, r} = deserialize_field(:api_versions, :api_key, %{}, d) {[val | acc], r} end) else {[], rest} end deserialize_field( :root, :throttle_time_ms, Map.put(acc, :api_versions, Enum.reverse(vals)), rest ) end defp(deserialize_field(:root, :throttle_time_ms, acc, data)) do {val, rest} = deserialize(:int32, data) deserialize_field(:root, nil, Map.put(acc, :throttle_time_ms, val), rest) end defp(deserialize_field(_, nil, acc, rest)) do {acc, rest} end end def(deserialize(0, data)) do V0.Response.deserialize(data) end def(deserialize(1, data)) do V1.Response.deserialize(data) end @type request_t :: Kayrock.ApiVersions.V1.Request.t() | Kayrock.ApiVersions.V0.Request.t() @type response_t :: Kayrock.ApiVersions.V1.Response.t() | Kayrock.ApiVersions.V0.Response.t() def(min_vsn) do 0 end def(max_vsn) do 1 end end