# Code generated by protox. Don't edit. # credo:disable-for-this-file defmodule PgQuery.Var do @moduledoc false if function_exported?(Protox, :check_generator_version, 1) do Protox.check_generator_version(1) else raise "This code was generated with protox 2 but the runtime is using an older version of protox." end @type t :: %__MODULE__{ location: integer(), varlevelsup: non_neg_integer(), varnullingrels: [non_neg_integer()], varcollid: non_neg_integer(), vartypmod: integer(), vartype: non_neg_integer(), varattno: integer(), varno: integer(), xpr: PgQuery.Node.t() | nil, __uf__: [{non_neg_integer(), Protox.Types.tag(), binary()}] } defstruct location: 0, varlevelsup: 0, varnullingrels: [], varcollid: 0, vartypmod: 0, vartype: 0, varattno: 0, varno: 0, xpr: nil, __uf__: [] ( ( @spec encode(t()) :: {:ok, iodata(), non_neg_integer()} | {:error, any()} def encode(msg) do msg |> encode!() |> Tuple.insert_at(0, :ok) rescue e in [Protox.EncodingError, Protox.RequiredFieldsError] -> {:error, e} end @spec encode!(t()) :: {iodata(), non_neg_integer()} | no_return() def encode!(msg) do {_acc = [], _acc_size = 0} |> encode_location(msg) |> encode_varlevelsup(msg) |> encode_varnullingrels(msg) |> encode_varcollid(msg) |> encode_vartypmod(msg) |> encode_vartype(msg) |> encode_varattno(msg) |> encode_varno(msg) |> encode_xpr(msg) |> encode_unknown_fields(msg) end ) defp encode_location({acc, acc_size}, msg) do if msg.location == 0 do {acc, acc_size} else {value_bytes, value_bytes_size} = Protox.Encode.encode_int32(msg.location) {["H", value_bytes | acc], acc_size + 1 + value_bytes_size} end rescue ArgumentError -> reraise Protox.EncodingError.new(:location, "invalid field value"), __STACKTRACE__ end defp encode_varlevelsup({acc, acc_size}, msg) do if msg.varlevelsup == 0 do {acc, acc_size} else {value_bytes, value_bytes_size} = Protox.Encode.encode_uint32(msg.varlevelsup) {["@", value_bytes | acc], acc_size + 1 + value_bytes_size} end rescue ArgumentError -> reraise Protox.EncodingError.new(:varlevelsup, "invalid field value"), __STACKTRACE__ end defp encode_varnullingrels({acc, acc_size}, msg) do case msg.varnullingrels do [] -> {acc, acc_size} values -> {packed_bytes, packed_size} = ( {value_bytes, value_size} = Enum.reduce(values, {_local_acc = [], _local_acc_size = 0}, fn value, {local_acc, local_acc_size} -> {value_bytes, value_bytes_size} = Protox.Encode.encode_uint64(value) {[value_bytes | local_acc], local_acc_size + value_bytes_size} end) {value_size_bytes, value_size_size} = Protox.Varint.encode(value_size) {[value_size_bytes, Enum.reverse(value_bytes)], value_size + value_size_size} ) {[":", packed_bytes | acc], acc_size + 1 + packed_size} end rescue ArgumentError -> reraise Protox.EncodingError.new(:varnullingrels, "invalid field value"), __STACKTRACE__ end defp encode_varcollid({acc, acc_size}, msg) do if msg.varcollid == 0 do {acc, acc_size} else {value_bytes, value_bytes_size} = Protox.Encode.encode_uint32(msg.varcollid) {["0", value_bytes | acc], acc_size + 1 + value_bytes_size} end rescue ArgumentError -> reraise Protox.EncodingError.new(:varcollid, "invalid field value"), __STACKTRACE__ end defp encode_vartypmod({acc, acc_size}, msg) do if msg.vartypmod == 0 do {acc, acc_size} else {value_bytes, value_bytes_size} = Protox.Encode.encode_int32(msg.vartypmod) {["(", value_bytes | acc], acc_size + 1 + value_bytes_size} end rescue ArgumentError -> reraise Protox.EncodingError.new(:vartypmod, "invalid field value"), __STACKTRACE__ end defp encode_vartype({acc, acc_size}, msg) do if msg.vartype == 0 do {acc, acc_size} else {value_bytes, value_bytes_size} = Protox.Encode.encode_uint32(msg.vartype) {[" ", value_bytes | acc], acc_size + 1 + value_bytes_size} end rescue ArgumentError -> reraise Protox.EncodingError.new(:vartype, "invalid field value"), __STACKTRACE__ end defp encode_varattno({acc, acc_size}, msg) do if msg.varattno == 0 do {acc, acc_size} else {value_bytes, value_bytes_size} = Protox.Encode.encode_int32(msg.varattno) {["\x18", value_bytes | acc], acc_size + 1 + value_bytes_size} end rescue ArgumentError -> reraise Protox.EncodingError.new(:varattno, "invalid field value"), __STACKTRACE__ end defp encode_varno({acc, acc_size}, msg) do if msg.varno == 0 do {acc, acc_size} else {value_bytes, value_bytes_size} = Protox.Encode.encode_int32(msg.varno) {["\x10", value_bytes | acc], acc_size + 1 + value_bytes_size} end rescue ArgumentError -> reraise Protox.EncodingError.new(:varno, "invalid field value"), __STACKTRACE__ end defp encode_xpr({acc, acc_size}, msg) do if msg.xpr == nil do {acc, acc_size} else {value_bytes, value_bytes_size} = Protox.Encode.encode_message(msg.xpr) {["\n", value_bytes | acc], acc_size + 1 + value_bytes_size} end rescue ArgumentError -> reraise Protox.EncodingError.new(:xpr, "invalid field value"), __STACKTRACE__ end defp encode_unknown_fields({acc, acc_size}, msg) do Enum.reduce(msg.__uf__, {acc, acc_size}, fn {tag, wire_type, bytes}, {acc, acc_size} -> case wire_type do 0 -> {key_bytes, key_size} = Protox.Encode.make_key_bytes(tag, :int32) {[acc, <>], acc_size + key_size + byte_size(bytes)} 1 -> {key_bytes, key_size} = Protox.Encode.make_key_bytes(tag, :double) {[acc, <>], acc_size + key_size + byte_size(bytes)} 2 -> {len_bytes, len_size} = bytes |> byte_size() |> Protox.Varint.encode() {key_bytes, key_size} = Protox.Encode.make_key_bytes(tag, :packed) {[acc, <>], acc_size + key_size + len_size + byte_size(bytes)} 5 -> {key_bytes, key_size} = Protox.Encode.make_key_bytes(tag, :float) {[acc, <>], acc_size + key_size + byte_size(bytes)} end end) end ) ( ( @spec decode(binary()) :: {:ok, t()} | {:error, any()} def decode(bytes) do {:ok, decode!(bytes)} rescue e in [Protox.DecodingError, Protox.IllegalTagError, Protox.RequiredFieldsError] -> {:error, e} end ( @spec decode!(binary()) :: t() | no_return() def decode!(bytes) do parse_key_value(bytes, struct(PgQuery.Var)) end ) ) ( @spec parse_key_value(binary(), struct()) :: struct() defp parse_key_value(<<>>, msg) do msg end defp parse_key_value(bytes, msg) do {field, rest} = case bytes do <<_::5, 3::3, _rest::binary>> -> raise Protox.DecodingError.new(bytes, "invalid wire type 3") <<_::5, 4::3, _rest::binary>> -> raise Protox.DecodingError.new(bytes, "invalid wire type 4") <<_::5, 6::3, _rest::binary>> -> raise Protox.DecodingError.new(bytes, "invalid wire type 6") <<_::5, 7::3, _rest::binary>> -> raise Protox.DecodingError.new(bytes, "invalid wire type 7") <<0::5, _::3, _rest::binary>> -> raise %Protox.IllegalTagError{} <<9::5, _wire_type::3, bytes::binary>> -> {value, rest} = Protox.Decode.parse_int32(bytes) {[location: value], rest} <<8::5, _wire_type::3, bytes::binary>> -> {value, rest} = Protox.Decode.parse_uint32(bytes) {[varlevelsup: value], rest} <<":", bytes::binary>> -> {len, bytes} = Protox.Varint.decode(bytes) {delimited, rest} = Protox.Decode.parse_delimited(bytes, len) {[ varnullingrels: msg.varnullingrels ++ Protox.Decode.parse_repeated_uint64([], delimited) ], rest} <<7::5, _wire_type::3, bytes::binary>> -> {value, rest} = Protox.Decode.parse_uint64(bytes) {[varnullingrels: msg.varnullingrels ++ [value]], rest} <<6::5, _wire_type::3, bytes::binary>> -> {value, rest} = Protox.Decode.parse_uint32(bytes) {[varcollid: value], rest} <<5::5, _wire_type::3, bytes::binary>> -> {value, rest} = Protox.Decode.parse_int32(bytes) {[vartypmod: value], rest} <<4::5, _wire_type::3, bytes::binary>> -> {value, rest} = Protox.Decode.parse_uint32(bytes) {[vartype: value], rest} <<3::5, _wire_type::3, bytes::binary>> -> {value, rest} = Protox.Decode.parse_int32(bytes) {[varattno: value], rest} <<2::5, _wire_type::3, bytes::binary>> -> {value, rest} = Protox.Decode.parse_int32(bytes) {[varno: value], rest} <<1::5, _wire_type::3, bytes::binary>> -> {len, bytes} = Protox.Varint.decode(bytes) {delimited, rest} = Protox.Decode.parse_delimited(bytes, len) {[xpr: Protox.MergeMessage.merge(msg.xpr, PgQuery.Node.decode!(delimited))], rest} <> -> {tag, wire_type, rest} = Protox.Decode.parse_key(bytes) {value, rest} = Protox.Decode.parse_unknown(tag, wire_type, rest) {[__uf__: msg.__uf__ ++ [value]], rest} end msg_updated = struct(msg, field) parse_key_value(rest, msg_updated) end ) ) ( @spec unknown_fields(struct()) :: [{non_neg_integer(), Protox.Types.tag(), binary()}] def unknown_fields(msg) do msg.__uf__ end @spec unknown_fields_name() :: :__uf__ def unknown_fields_name() do :__uf__ end @spec clear_unknown_fields(struct) :: struct def clear_unknown_fields(msg) do struct!(msg, __uf__: []) end ) ( @spec default(atom()) :: {:ok, boolean() | integer() | String.t() | float()} | {:error, :no_such_field | :no_default_value} def default(:location) do {:ok, 0} end def default(:varlevelsup) do {:ok, 0} end def default(:varnullingrels) do {:error, :no_default_value} end def default(:varcollid) do {:ok, 0} end def default(:vartypmod) do {:ok, 0} end def default(:vartype) do {:ok, 0} end def default(:varattno) do {:ok, 0} end def default(:varno) do {:ok, 0} end def default(:xpr) do {:ok, nil} end def default(_) do {:error, :no_such_field} end ) @spec schema() :: Protox.MessageSchema.t() def schema() do %{ __struct__: Protox.MessageSchema, fields: %{ location: %{ __struct__: Protox.Field, extender: nil, kind: %{__struct__: Protox.Scalar, default_value: 0}, label: :optional, name: :location, tag: 9, type: :int32 }, varattno: %{ __struct__: Protox.Field, extender: nil, kind: %{__struct__: Protox.Scalar, default_value: 0}, label: :optional, name: :varattno, tag: 3, type: :int32 }, varcollid: %{ __struct__: Protox.Field, extender: nil, kind: %{__struct__: Protox.Scalar, default_value: 0}, label: :optional, name: :varcollid, tag: 6, type: :uint32 }, varlevelsup: %{ __struct__: Protox.Field, extender: nil, kind: %{__struct__: Protox.Scalar, default_value: 0}, label: :optional, name: :varlevelsup, tag: 8, type: :uint32 }, varno: %{ __struct__: Protox.Field, extender: nil, kind: %{__struct__: Protox.Scalar, default_value: 0}, label: :optional, name: :varno, tag: 2, type: :int32 }, varnullingrels: %{ __struct__: Protox.Field, extender: nil, kind: :packed, label: :repeated, name: :varnullingrels, tag: 7, type: :uint64 }, vartype: %{ __struct__: Protox.Field, extender: nil, kind: %{__struct__: Protox.Scalar, default_value: 0}, label: :optional, name: :vartype, tag: 4, type: :uint32 }, vartypmod: %{ __struct__: Protox.Field, extender: nil, kind: %{__struct__: Protox.Scalar, default_value: 0}, label: :optional, name: :vartypmod, tag: 5, type: :int32 }, xpr: %{ __struct__: Protox.Field, extender: nil, kind: %{__struct__: Protox.Scalar, default_value: nil}, label: :optional, name: :xpr, tag: 1, type: {:message, PgQuery.Node} } }, file_options: nil, name: PgQuery.Var, syntax: :proto3 } end end