defmodule(Kayrock.DescribeConfigs) do @moduledoc false _ = " THIS CODE IS GENERATED BY KAYROCK" defmodule(V0.Request) do @moduledoc false _ = " THIS CODE IS GENERATED BY KAYROCK" defstruct(resources: [], correlation_id: nil, client_id: nil) import(Elixir.Kayrock.Serialize) @type t :: %__MODULE__{} def(api_key) do Kayrock.KafkaSchemaMetadata.api_key(:describe_configs) end def(api_vsn) do 0 end def(response_deserializer) do &V0.Response.deserialize/1 end def(schema) do [ resources: {:array, [resource_type: :int8, resource_name: :string, config_names: {:array, :string}]} ] end def(serialize(%V0.Request{} = struct)) do [ <>, [ case(Map.fetch!(struct, :resources)) do nil -> <<-1::32-signed>> [] -> <<0::32-signed>> vals when is_list(vals) -> [ <>, for(v <- vals) do [ serialize(:int8, Map.fetch!(v, :resource_type)), serialize(:string, Map.fetch!(v, :resource_name)), serialize_array(:string, Map.fetch!(v, :config_names)) ] end ] end ] ] end end defimpl(Elixir.Kayrock.Request, for: V0.Request) do def(serialize(%V0.Request{} = struct)) do V0.Request.serialize(struct) 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(resources: [], include_synonyms: nil, correlation_id: nil, client_id: nil) import(Elixir.Kayrock.Serialize) @type t :: %__MODULE__{} def(api_key) do Kayrock.KafkaSchemaMetadata.api_key(:describe_configs) end def(api_vsn) do 1 end def(response_deserializer) do &V1.Response.deserialize/1 end def(schema) do [ resources: {:array, [resource_type: :int8, resource_name: :string, config_names: {:array, :string}]}, include_synonyms: :boolean ] end def(serialize(%V1.Request{} = struct)) do [ <>, [ case(Map.fetch!(struct, :resources)) do nil -> <<-1::32-signed>> [] -> <<0::32-signed>> vals when is_list(vals) -> [ <>, for(v <- vals) do [ serialize(:int8, Map.fetch!(v, :resource_type)), serialize(:string, Map.fetch!(v, :resource_name)), serialize_array(:string, Map.fetch!(v, :config_names)) ] end ] end, serialize(:boolean, Map.fetch!(struct, :include_synonyms)) ] ] end end defimpl(Elixir.Kayrock.Request, for: V1.Request) do def(serialize(%V1.Request{} = struct)) do V1.Request.serialize(struct) 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(throttle_time_ms: nil, resources: [], correlation_id: nil) @type t :: %__MODULE__{} import(Elixir.Kayrock.Deserialize) def(api_key) do Kayrock.KafkaSchemaMetadata.api_key(:describe_configs) end def(api_vsn) do 0 end def(schema) do [ throttle_time_ms: :int32, resources: {:array, [ error_code: :int16, error_message: :nullable_string, resource_type: :int8, resource_name: :string, config_entries: {:array, [ config_name: :string, config_value: :nullable_string, read_only: :boolean, is_default: :boolean, is_sensitive: :boolean ]} ]} ] end def(deserialize(data)) do <> = data deserialize_field( :root, :throttle_time_ms, %__MODULE__{correlation_id: correlation_id}, rest ) end defp(deserialize_field(:root, :throttle_time_ms, acc, data)) do {val, rest} = deserialize(:int32, data) deserialize_field(:root, :resources, Map.put(acc, :throttle_time_ms, val), rest) end defp(deserialize_field(:resources, :error_code, acc, data)) do {val, rest} = deserialize(:int16, data) deserialize_field(:resources, :error_message, Map.put(acc, :error_code, val), rest) end defp(deserialize_field(:resources, :error_message, acc, data)) do {val, rest} = deserialize(:nullable_string, data) deserialize_field(:resources, :resource_type, Map.put(acc, :error_message, val), rest) end defp(deserialize_field(:resources, :resource_type, acc, data)) do {val, rest} = deserialize(:int8, data) deserialize_field(:resources, :resource_name, Map.put(acc, :resource_type, val), rest) end defp(deserialize_field(:resources, :resource_name, acc, data)) do {val, rest} = deserialize(:string, data) deserialize_field(:resources, :config_entries, Map.put(acc, :resource_name, val), rest) end defp(deserialize_field(:config_entries, :config_name, acc, data)) do {val, rest} = deserialize(:string, data) deserialize_field(:config_entries, :config_value, Map.put(acc, :config_name, val), rest) end defp(deserialize_field(:config_entries, :config_value, acc, data)) do {val, rest} = deserialize(:nullable_string, data) deserialize_field(:config_entries, :read_only, Map.put(acc, :config_value, val), rest) end defp(deserialize_field(:config_entries, :read_only, acc, data)) do {val, rest} = deserialize(:boolean, data) deserialize_field(:config_entries, :is_default, Map.put(acc, :read_only, val), rest) end defp(deserialize_field(:config_entries, :is_default, acc, data)) do {val, rest} = deserialize(:boolean, data) deserialize_field(:config_entries, :is_sensitive, Map.put(acc, :is_default, val), rest) end defp(deserialize_field(:config_entries, :is_sensitive, acc, data)) do {val, rest} = deserialize(:boolean, data) deserialize_field(:config_entries, nil, Map.put(acc, :is_sensitive, val), rest) end defp(deserialize_field(:resources, :config_entries, 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(:config_entries, :config_name, %{}, d) {[val | acc], r} end) else {[], rest} end deserialize_field(:resources, nil, Map.put(acc, :config_entries, Enum.reverse(vals)), rest) end defp(deserialize_field(:root, :resources, 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(:resources, :error_code, %{}, d) {[val | acc], r} end) else {[], rest} end deserialize_field(:root, nil, Map.put(acc, :resources, 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(throttle_time_ms: nil, resources: [], correlation_id: nil) @type t :: %__MODULE__{} import(Elixir.Kayrock.Deserialize) def(api_key) do Kayrock.KafkaSchemaMetadata.api_key(:describe_configs) end def(api_vsn) do 1 end def(schema) do [ throttle_time_ms: :int32, resources: {:array, [ error_code: :int16, error_message: :nullable_string, resource_type: :int8, resource_name: :string, config_entries: {:array, [ config_name: :string, config_value: :nullable_string, read_only: :boolean, config_source: :int8, is_sensitive: :boolean, config_synonyms: {:array, [config_name: :string, config_value: :nullable_string, config_source: :int8]} ]} ]} ] end def(deserialize(data)) do <> = data deserialize_field( :root, :throttle_time_ms, %__MODULE__{correlation_id: correlation_id}, rest ) end defp(deserialize_field(:root, :throttle_time_ms, acc, data)) do {val, rest} = deserialize(:int32, data) deserialize_field(:root, :resources, Map.put(acc, :throttle_time_ms, val), rest) end defp(deserialize_field(:resources, :error_code, acc, data)) do {val, rest} = deserialize(:int16, data) deserialize_field(:resources, :error_message, Map.put(acc, :error_code, val), rest) end defp(deserialize_field(:resources, :error_message, acc, data)) do {val, rest} = deserialize(:nullable_string, data) deserialize_field(:resources, :resource_type, Map.put(acc, :error_message, val), rest) end defp(deserialize_field(:resources, :resource_type, acc, data)) do {val, rest} = deserialize(:int8, data) deserialize_field(:resources, :resource_name, Map.put(acc, :resource_type, val), rest) end defp(deserialize_field(:resources, :resource_name, acc, data)) do {val, rest} = deserialize(:string, data) deserialize_field(:resources, :config_entries, Map.put(acc, :resource_name, val), rest) end defp(deserialize_field(:config_entries, :config_name, acc, data)) do {val, rest} = deserialize(:string, data) deserialize_field(:config_entries, :config_value, Map.put(acc, :config_name, val), rest) end defp(deserialize_field(:config_entries, :config_value, acc, data)) do {val, rest} = deserialize(:nullable_string, data) deserialize_field(:config_entries, :read_only, Map.put(acc, :config_value, val), rest) end defp(deserialize_field(:config_entries, :read_only, acc, data)) do {val, rest} = deserialize(:boolean, data) deserialize_field(:config_entries, :config_source, Map.put(acc, :read_only, val), rest) end defp(deserialize_field(:config_entries, :config_source, acc, data)) do {val, rest} = deserialize(:int8, data) deserialize_field(:config_entries, :is_sensitive, Map.put(acc, :config_source, val), rest) end defp(deserialize_field(:config_entries, :is_sensitive, acc, data)) do {val, rest} = deserialize(:boolean, data) deserialize_field(:config_entries, :config_synonyms, Map.put(acc, :is_sensitive, val), rest) end defp(deserialize_field(:config_synonyms, :config_name, acc, data)) do {val, rest} = deserialize(:string, data) deserialize_field(:config_synonyms, :config_value, Map.put(acc, :config_name, val), rest) end defp(deserialize_field(:config_synonyms, :config_value, acc, data)) do {val, rest} = deserialize(:nullable_string, data) deserialize_field(:config_synonyms, :config_source, Map.put(acc, :config_value, val), rest) end defp(deserialize_field(:config_synonyms, :config_source, acc, data)) do {val, rest} = deserialize(:int8, data) deserialize_field(:config_synonyms, nil, Map.put(acc, :config_source, val), rest) end defp(deserialize_field(:config_entries, :config_synonyms, 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(:config_synonyms, :config_name, %{}, d) {[val | acc], r} end) else {[], rest} end deserialize_field( :config_entries, nil, Map.put(acc, :config_synonyms, Enum.reverse(vals)), rest ) end defp(deserialize_field(:resources, :config_entries, 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(:config_entries, :config_name, %{}, d) {[val | acc], r} end) else {[], rest} end deserialize_field(:resources, nil, Map.put(acc, :config_entries, Enum.reverse(vals)), rest) end defp(deserialize_field(:root, :resources, 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(:resources, :error_code, %{}, d) {[val | acc], r} end) else {[], rest} end deserialize_field(:root, nil, Map.put(acc, :resources, Enum.reverse(vals)), 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 def(min_vsn) do 0 end def(max_vsn) do 1 end end