%% -*- coding: utf-8 -*- %% @private %% Automatically generated, do not edit %% Generated by gpb_compile version 4.7.1 -module(kaa). -export([encode_msg/1, encode_msg/2, encode_msg/3]). -export([decode_msg/2, decode_msg/3]). -export([merge_msgs/2, merge_msgs/3, merge_msgs/4]). -export([verify_msg/1, verify_msg/2, verify_msg/3]). -export([get_msg_defs/0]). -export([get_msg_names/0]). -export([get_group_names/0]). -export([get_msg_or_group_names/0]). -export([get_enum_names/0]). -export([find_msg_def/1, fetch_msg_def/1]). -export([find_enum_def/1, fetch_enum_def/1]). -export([enum_symbol_by_value/2, enum_value_by_symbol/2]). -export([enum_symbol_by_value_mods/1, enum_value_by_symbol_mods/1]). -export([enum_symbol_by_value_funs/1, enum_value_by_symbol_funs/1]). -export([get_service_names/0]). -export([get_service_def/1]). -export([get_rpc_names/1]). -export([find_rpc_def/2, fetch_rpc_def/2]). -export([fqbin_to_service_name/1]). -export([service_name_to_fqbin/1]). -export([fqbins_to_service_and_rpc_name/2]). -export([service_and_rpc_name_to_fqbins/2]). -export([fqbin_to_msg_name/1]). -export([msg_name_to_fqbin/1]). -export([fqbin_to_enum_name/1]). -export([enum_name_to_fqbin/1]). -export([get_package_name/0]). -export([uses_packages/0]). -export([source_basename/0]). -export([get_all_source_basenames/0]). -export([get_all_proto_names/0]). -export([get_msg_containment/1]). -export([get_pkg_containment/1]). -export([get_service_containment/1]). -export([get_rpc_containment/1]). -export([get_enum_containment/1]). -export([get_proto_by_msg_name_as_fqbin/1]). -export([get_proto_by_service_name_as_fqbin/1]). -export([get_proto_by_enum_name_as_fqbin/1]). -export([get_protos_by_pkg_name_as_fqbin/1]). -export([gpb_version_as_string/0, gpb_version_as_list/0]). -include("kaa.hrl"). -include("gpb.hrl"). %% enumerated types -type 'mods'() :: 'jun_pandas' | 'jun_plotly' | 'jun_seaborn' | 'jun_pandas_series' | 'jun_pandas_timedelta'. -type 'funs'() :: 'read_csv' | 'to_csv' | 'to_html' | 'to_json' | 'to_datetime' | 'read_sql' | 'read_string' | 'sum' | 'max' | 'min' | 'count' | 'median' | 'unique' | 'query' | 'head' | 'tail' | 'columns' | 'len_columns' | 'len_index' | 'memory_usage' | 'info_columns' | 'selection' | 'single_selection' | 'plot' | 'groupby' | 'apply' | 'sort_values' | 'sort_index' | 'iplot' | 'extend' | 'get_figure' | 'lmplot' | 'factorplot' | 'pairplot' | 'jointplot' | 'stripplot' | 'swarmplot' | 'boxplot' | 'violinplot' | 'lvplot' | 'pointplot' | 'barplot' | 'countplot' | 'legacy_query' | 'legacy_assignment' | 'drop' | 'rename' | 'append' | 'combine' | 'days' | 'fillna' | 'dropna'. -export_type(['mods'/0, 'funs'/0]). %% message types -type 'Kaa'() :: #'Kaa'{}. -type m_frame() :: #m_frame{}. -type m_core() :: #m_core{}. -type 'Keywords'() :: #'Keywords'{}. -type 'KeywordValue'() :: #'KeywordValue'{}. -export_type(['Kaa'/0, 'm_frame'/0, 'm_core'/0, 'Keywords'/0, 'KeywordValue'/0]). -spec encode_msg(#'Kaa'{} | #m_frame{} | #m_core{} | #'Keywords'{} | #'KeywordValue'{}) -> binary(). encode_msg(Msg) when tuple_size(Msg) >= 1 -> encode_msg(Msg, element(1, Msg), []). -spec encode_msg(#'Kaa'{} | #m_frame{} | #m_core{} | #'Keywords'{} | #'KeywordValue'{}, atom() | list()) -> binary(). encode_msg(Msg, MsgName) when is_atom(MsgName) -> encode_msg(Msg, MsgName, []); encode_msg(Msg, Opts) when tuple_size(Msg) >= 1, is_list(Opts) -> encode_msg(Msg, element(1, Msg), Opts). -spec encode_msg(#'Kaa'{} | #m_frame{} | #m_core{} | #'Keywords'{} | #'KeywordValue'{}, atom(), list()) -> binary(). encode_msg(Msg, MsgName, Opts) -> case proplists:get_bool(verify, Opts) of true -> verify_msg(Msg, MsgName, Opts); false -> ok end, TrUserData = proplists:get_value(user_data, Opts), case MsgName of 'Kaa' -> encode_msg_Kaa(id(Msg, TrUserData), TrUserData); m_frame -> encode_msg_m_frame(id(Msg, TrUserData), TrUserData); m_core -> encode_msg_m_core(id(Msg, TrUserData), TrUserData); 'Keywords' -> encode_msg_Keywords(id(Msg, TrUserData), TrUserData); 'KeywordValue' -> encode_msg_KeywordValue(id(Msg, TrUserData), TrUserData) end. encode_msg_Kaa(Msg, TrUserData) -> encode_msg_Kaa(Msg, <<>>, TrUserData). encode_msg_Kaa(#'Kaa'{module = F1, function = F2, jun_worker = F3, arguments = F4}, Bin, TrUserData) -> B1 = begin TrF1 = id(F1, TrUserData), e_enum_mods(TrF1, <>, TrUserData) end, B2 = begin TrF2 = id(F2, TrUserData), e_enum_funs(TrF2, <>, TrUserData) end, B3 = begin TrF3 = id(F3, TrUserData), e_type_string(TrF3, <>, TrUserData) end, if F4 =:= undefined -> B3; true -> case id(F4, TrUserData) of {core, TF4} -> begin TrTF4 = id(TF4, TrUserData), e_mfield_Kaa_core(TrTF4, <>, TrUserData) end; {frame, TF4} -> begin TrTF4 = id(TF4, TrUserData), e_mfield_Kaa_frame(TrTF4, <>, TrUserData) end end end. encode_msg_m_frame(Msg, TrUserData) -> encode_msg_m_frame(Msg, <<>>, TrUserData). encode_msg_m_frame(#m_frame{dataframe = F1, axis = F2, keywords = F3}, Bin, TrUserData) -> B1 = begin TrF1 = id(F1, TrUserData), e_type_string(TrF1, <>, TrUserData) end, B2 = if F2 == undefined -> B1; true -> begin TrF2 = id(F2, TrUserData), e_type_string(TrF2, <>, TrUserData) end end, begin TrF3 = id(F3, TrUserData), if TrF3 == [] -> B2; true -> e_field_m_frame_keywords(TrF3, B2, TrUserData) end end. encode_msg_m_core(Msg, TrUserData) -> encode_msg_m_core(Msg, <<>>, TrUserData). encode_msg_m_core(#m_core{argument = F1, keywords = F2}, Bin, TrUserData) -> B1 = begin TrF1 = id(F1, TrUserData), e_type_string(TrF1, <>, TrUserData) end, begin TrF2 = id(F2, TrUserData), if TrF2 == [] -> B1; true -> e_field_m_core_keywords(TrF2, B1, TrUserData) end end. encode_msg_Keywords(Msg, TrUserData) -> encode_msg_Keywords(Msg, <<>>, TrUserData). encode_msg_Keywords(#'Keywords'{key = F1, value = F2}, Bin, TrUserData) -> B1 = begin TrF1 = id(F1, TrUserData), e_type_string(TrF1, <>, TrUserData) end, if F2 =:= undefined -> B1; true -> case id(F2, TrUserData) of {svalue, TF2} -> begin TrTF2 = id(TF2, TrUserData), e_type_string(TrTF2, <>, TrUserData) end; {ivalue, TF2} -> begin TrTF2 = id(TF2, TrUserData), e_type_int64(TrTF2, <>, TrUserData) end; {dvalue, TF2} -> begin TrTF2 = id(TF2, TrUserData), e_type_double(TrTF2, <>, TrUserData) end; {avalue, TF2} -> begin TrTF2 = id(TF2, TrUserData), e_mfield_Keywords_avalue(TrTF2, <>, TrUserData) end end end. encode_msg_KeywordValue(Msg, TrUserData) -> encode_msg_KeywordValue(Msg, <<>>, TrUserData). encode_msg_KeywordValue(#'KeywordValue'{svalue = F1, ivalue = F2, dvalue = F3}, Bin, TrUserData) -> B1 = begin TrF1 = id(F1, TrUserData), if TrF1 == [] -> Bin; true -> e_field_KeywordValue_svalue(TrF1, Bin, TrUserData) end end, B2 = begin TrF2 = id(F2, TrUserData), if TrF2 == [] -> B1; true -> e_field_KeywordValue_ivalue(TrF2, B1, TrUserData) end end, begin TrF3 = id(F3, TrUserData), if TrF3 == [] -> B2; true -> e_field_KeywordValue_dvalue(TrF3, B2, TrUserData) end end. e_mfield_Kaa_core(Msg, Bin, TrUserData) -> SubBin = encode_msg_m_core(Msg, <<>>, TrUserData), Bin2 = e_varint(byte_size(SubBin), Bin), <>. e_mfield_Kaa_frame(Msg, Bin, TrUserData) -> SubBin = encode_msg_m_frame(Msg, <<>>, TrUserData), Bin2 = e_varint(byte_size(SubBin), Bin), <>. e_mfield_m_frame_keywords(Msg, Bin, TrUserData) -> SubBin = encode_msg_Keywords(Msg, <<>>, TrUserData), Bin2 = e_varint(byte_size(SubBin), Bin), <>. e_field_m_frame_keywords([Elem | Rest], Bin, TrUserData) -> Bin2 = <>, Bin3 = e_mfield_m_frame_keywords(id(Elem, TrUserData), Bin2, TrUserData), e_field_m_frame_keywords(Rest, Bin3, TrUserData); e_field_m_frame_keywords([], Bin, _TrUserData) -> Bin. e_mfield_m_core_keywords(Msg, Bin, TrUserData) -> SubBin = encode_msg_Keywords(Msg, <<>>, TrUserData), Bin2 = e_varint(byte_size(SubBin), Bin), <>. e_field_m_core_keywords([Elem | Rest], Bin, TrUserData) -> Bin2 = <>, Bin3 = e_mfield_m_core_keywords(id(Elem, TrUserData), Bin2, TrUserData), e_field_m_core_keywords(Rest, Bin3, TrUserData); e_field_m_core_keywords([], Bin, _TrUserData) -> Bin. e_mfield_Keywords_avalue(Msg, Bin, TrUserData) -> SubBin = encode_msg_KeywordValue(Msg, <<>>, TrUserData), Bin2 = e_varint(byte_size(SubBin), Bin), <>. e_field_KeywordValue_svalue([Elem | Rest], Bin, TrUserData) -> Bin2 = <>, Bin3 = e_type_string(id(Elem, TrUserData), Bin2, TrUserData), e_field_KeywordValue_svalue(Rest, Bin3, TrUserData); e_field_KeywordValue_svalue([], Bin, _TrUserData) -> Bin. e_field_KeywordValue_ivalue([Elem | Rest], Bin, TrUserData) -> Bin2 = <>, Bin3 = e_type_int64(id(Elem, TrUserData), Bin2, TrUserData), e_field_KeywordValue_ivalue(Rest, Bin3, TrUserData); e_field_KeywordValue_ivalue([], Bin, _TrUserData) -> Bin. e_field_KeywordValue_dvalue([Elem | Rest], Bin, TrUserData) -> Bin2 = <>, Bin3 = e_type_double(id(Elem, TrUserData), Bin2, TrUserData), e_field_KeywordValue_dvalue(Rest, Bin3, TrUserData); e_field_KeywordValue_dvalue([], Bin, _TrUserData) -> Bin. e_enum_mods(jun_pandas, Bin, _TrUserData) -> <>; e_enum_mods(jun_plotly, Bin, _TrUserData) -> <>; e_enum_mods(jun_seaborn, Bin, _TrUserData) -> <>; e_enum_mods(jun_pandas_series, Bin, _TrUserData) -> <>; e_enum_mods(jun_pandas_timedelta, Bin, _TrUserData) -> <>; e_enum_mods(V, Bin, _TrUserData) -> e_varint(V, Bin). e_enum_funs(read_csv, Bin, _TrUserData) -> <>; e_enum_funs(to_csv, Bin, _TrUserData) -> <>; e_enum_funs(to_html, Bin, _TrUserData) -> <>; e_enum_funs(to_json, Bin, _TrUserData) -> <>; e_enum_funs(to_datetime, Bin, _TrUserData) -> <>; e_enum_funs(read_sql, Bin, _TrUserData) -> <>; e_enum_funs(read_string, Bin, _TrUserData) -> <>; e_enum_funs(sum, Bin, _TrUserData) -> <>; e_enum_funs(max, Bin, _TrUserData) -> <>; e_enum_funs(min, Bin, _TrUserData) -> <>; e_enum_funs(count, Bin, _TrUserData) -> <>; e_enum_funs(median, Bin, _TrUserData) -> <>; e_enum_funs(unique, Bin, _TrUserData) -> <>; e_enum_funs(query, Bin, _TrUserData) -> <>; e_enum_funs(head, Bin, _TrUserData) -> <>; e_enum_funs(tail, Bin, _TrUserData) -> <>; e_enum_funs(columns, Bin, _TrUserData) -> <>; e_enum_funs(len_columns, Bin, _TrUserData) -> <>; e_enum_funs(len_index, Bin, _TrUserData) -> <>; e_enum_funs(memory_usage, Bin, _TrUserData) -> <>; e_enum_funs(info_columns, Bin, _TrUserData) -> <>; e_enum_funs(selection, Bin, _TrUserData) -> <>; e_enum_funs(single_selection, Bin, _TrUserData) -> <>; e_enum_funs(plot, Bin, _TrUserData) -> <>; e_enum_funs(groupby, Bin, _TrUserData) -> <>; e_enum_funs(apply, Bin, _TrUserData) -> <>; e_enum_funs(sort_values, Bin, _TrUserData) -> <>; e_enum_funs(sort_index, Bin, _TrUserData) -> <>; e_enum_funs(iplot, Bin, _TrUserData) -> <>; e_enum_funs(extend, Bin, _TrUserData) -> <>; e_enum_funs(get_figure, Bin, _TrUserData) -> <>; e_enum_funs(lmplot, Bin, _TrUserData) -> <>; e_enum_funs(factorplot, Bin, _TrUserData) -> <>; e_enum_funs(pairplot, Bin, _TrUserData) -> <>; e_enum_funs(jointplot, Bin, _TrUserData) -> <>; e_enum_funs(stripplot, Bin, _TrUserData) -> <>; e_enum_funs(swarmplot, Bin, _TrUserData) -> <>; e_enum_funs(boxplot, Bin, _TrUserData) -> <>; e_enum_funs(violinplot, Bin, _TrUserData) -> <>; e_enum_funs(lvplot, Bin, _TrUserData) -> <>; e_enum_funs(pointplot, Bin, _TrUserData) -> <>; e_enum_funs(barplot, Bin, _TrUserData) -> <>; e_enum_funs(countplot, Bin, _TrUserData) -> <>; e_enum_funs(legacy_query, Bin, _TrUserData) -> <>; e_enum_funs(legacy_assignment, Bin, _TrUserData) -> <>; e_enum_funs(drop, Bin, _TrUserData) -> <>; e_enum_funs(rename, Bin, _TrUserData) -> <>; e_enum_funs(append, Bin, _TrUserData) -> <>; e_enum_funs(combine, Bin, _TrUserData) -> <>; e_enum_funs(days, Bin, _TrUserData) -> <>; e_enum_funs(fillna, Bin, _TrUserData) -> <>; e_enum_funs(dropna, Bin, _TrUserData) -> <>; e_enum_funs(V, Bin, _TrUserData) -> e_varint(V, Bin). -compile({nowarn_unused_function,e_type_sint/3}). e_type_sint(Value, Bin, _TrUserData) when Value >= 0 -> e_varint(Value * 2, Bin); e_type_sint(Value, Bin, _TrUserData) -> e_varint(Value * -2 - 1, Bin). -compile({nowarn_unused_function,e_type_int32/3}). e_type_int32(Value, Bin, _TrUserData) when 0 =< Value, Value =< 127 -> <>; e_type_int32(Value, Bin, _TrUserData) -> <> = <>, e_varint(N, Bin). -compile({nowarn_unused_function,e_type_int64/3}). e_type_int64(Value, Bin, _TrUserData) when 0 =< Value, Value =< 127 -> <>; e_type_int64(Value, Bin, _TrUserData) -> <> = <>, e_varint(N, Bin). -compile({nowarn_unused_function,e_type_bool/3}). e_type_bool(true, Bin, _TrUserData) -> <>; e_type_bool(false, Bin, _TrUserData) -> <>; e_type_bool(1, Bin, _TrUserData) -> <>; e_type_bool(0, Bin, _TrUserData) -> <>. -compile({nowarn_unused_function,e_type_string/3}). e_type_string(S, Bin, _TrUserData) -> Utf8 = unicode:characters_to_binary(S), Bin2 = e_varint(byte_size(Utf8), Bin), <>. -compile({nowarn_unused_function,e_type_bytes/3}). e_type_bytes(Bytes, Bin, _TrUserData) when is_binary(Bytes) -> Bin2 = e_varint(byte_size(Bytes), Bin), <>; e_type_bytes(Bytes, Bin, _TrUserData) when is_list(Bytes) -> BytesBin = iolist_to_binary(Bytes), Bin2 = e_varint(byte_size(BytesBin), Bin), <>. -compile({nowarn_unused_function,e_type_fixed32/3}). e_type_fixed32(Value, Bin, _TrUserData) -> <>. -compile({nowarn_unused_function,e_type_sfixed32/3}). e_type_sfixed32(Value, Bin, _TrUserData) -> <>. -compile({nowarn_unused_function,e_type_fixed64/3}). e_type_fixed64(Value, Bin, _TrUserData) -> <>. -compile({nowarn_unused_function,e_type_sfixed64/3}). e_type_sfixed64(Value, Bin, _TrUserData) -> <>. -compile({nowarn_unused_function,e_type_float/3}). e_type_float(V, Bin, _) when is_number(V) -> <>; e_type_float(infinity, Bin, _) -> <>; e_type_float('-infinity', Bin, _) -> <>; e_type_float(nan, Bin, _) -> <>. -compile({nowarn_unused_function,e_type_double/3}). e_type_double(V, Bin, _) when is_number(V) -> <>; e_type_double(infinity, Bin, _) -> <>; e_type_double('-infinity', Bin, _) -> <>; e_type_double(nan, Bin, _) -> <>. -compile({nowarn_unused_function,e_varint/3}). e_varint(N, Bin, _TrUserData) -> e_varint(N, Bin). -compile({nowarn_unused_function,e_varint/2}). e_varint(N, Bin) when N =< 127 -> <>; e_varint(N, Bin) -> Bin2 = <>, e_varint(N bsr 7, Bin2). decode_msg(Bin, MsgName) when is_binary(Bin) -> decode_msg(Bin, MsgName, []). decode_msg(Bin, MsgName, Opts) when is_binary(Bin) -> TrUserData = proplists:get_value(user_data, Opts), decode_msg_1_catch(Bin, MsgName, TrUserData). -ifdef('OTP_RELEASE'). decode_msg_1_catch(Bin, MsgName, TrUserData) -> try decode_msg_2_doit(MsgName, Bin, TrUserData) catch Class:Reason:StackTrace -> error({gpb_error,{decoding_failure, {Bin, MsgName, {Class, Reason, StackTrace}}}}) end. -else. decode_msg_1_catch(Bin, MsgName, TrUserData) -> try decode_msg_2_doit(MsgName, Bin, TrUserData) catch Class:Reason -> StackTrace = erlang:get_stacktrace(), error({gpb_error,{decoding_failure, {Bin, MsgName, {Class, Reason, StackTrace}}}}) end. -endif. decode_msg_2_doit('Kaa', Bin, TrUserData) -> id(decode_msg_Kaa(Bin, TrUserData), TrUserData); decode_msg_2_doit(m_frame, Bin, TrUserData) -> id(decode_msg_m_frame(Bin, TrUserData), TrUserData); decode_msg_2_doit(m_core, Bin, TrUserData) -> id(decode_msg_m_core(Bin, TrUserData), TrUserData); decode_msg_2_doit('Keywords', Bin, TrUserData) -> id(decode_msg_Keywords(Bin, TrUserData), TrUserData); decode_msg_2_doit('KeywordValue', Bin, TrUserData) -> id(decode_msg_KeywordValue(Bin, TrUserData), TrUserData). decode_msg_Kaa(Bin, TrUserData) -> dfp_read_field_def_Kaa(Bin, 0, 0, id(undefined, TrUserData), id(undefined, TrUserData), id(undefined, TrUserData), id(undefined, TrUserData), TrUserData). dfp_read_field_def_Kaa(<<8, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData) -> d_field_Kaa_module(Rest, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData); dfp_read_field_def_Kaa(<<16, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData) -> d_field_Kaa_function(Rest, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData); dfp_read_field_def_Kaa(<<26, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData) -> d_field_Kaa_jun_worker(Rest, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData); dfp_read_field_def_Kaa(<<34, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData) -> d_field_Kaa_core(Rest, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData); dfp_read_field_def_Kaa(<<42, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData) -> d_field_Kaa_frame(Rest, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData); dfp_read_field_def_Kaa(<<>>, 0, 0, F@_1, F@_2, F@_3, F@_4, _) -> #'Kaa'{module = F@_1, function = F@_2, jun_worker = F@_3, arguments = F@_4}; dfp_read_field_def_Kaa(Other, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData) -> dg_read_field_def_Kaa(Other, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData). dg_read_field_def_Kaa(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, F@_4, TrUserData) when N < 32 - 7 -> dg_read_field_def_Kaa(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, F@_4, TrUserData); dg_read_field_def_Kaa(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, F@_4, TrUserData) -> Key = X bsl N + Acc, case Key of 8 -> d_field_Kaa_module(Rest, 0, 0, F@_1, F@_2, F@_3, F@_4, TrUserData); 16 -> d_field_Kaa_function(Rest, 0, 0, F@_1, F@_2, F@_3, F@_4, TrUserData); 26 -> d_field_Kaa_jun_worker(Rest, 0, 0, F@_1, F@_2, F@_3, F@_4, TrUserData); 34 -> d_field_Kaa_core(Rest, 0, 0, F@_1, F@_2, F@_3, F@_4, TrUserData); 42 -> d_field_Kaa_frame(Rest, 0, 0, F@_1, F@_2, F@_3, F@_4, TrUserData); _ -> case Key band 7 of 0 -> skip_varint_Kaa(Rest, 0, 0, F@_1, F@_2, F@_3, F@_4, TrUserData); 1 -> skip_64_Kaa(Rest, 0, 0, F@_1, F@_2, F@_3, F@_4, TrUserData); 2 -> skip_length_delimited_Kaa(Rest, 0, 0, F@_1, F@_2, F@_3, F@_4, TrUserData); 3 -> skip_group_Kaa(Rest, Key bsr 3, 0, F@_1, F@_2, F@_3, F@_4, TrUserData); 5 -> skip_32_Kaa(Rest, 0, 0, F@_1, F@_2, F@_3, F@_4, TrUserData) end end; dg_read_field_def_Kaa(<<>>, 0, 0, F@_1, F@_2, F@_3, F@_4, _) -> #'Kaa'{module = F@_1, function = F@_2, jun_worker = F@_3, arguments = F@_4}. d_field_Kaa_module(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, F@_4, TrUserData) when N < 57 -> d_field_Kaa_module(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, F@_4, TrUserData); d_field_Kaa_module(<<0:1, X:7, Rest/binary>>, N, Acc, _, F@_2, F@_3, F@_4, TrUserData) -> {NewFValue, RestF} = {id(d_enum_mods(begin <> = <<(X bsl N + Acc):32/unsigned-native>>, id(Res, TrUserData) end), TrUserData), Rest}, dfp_read_field_def_Kaa(RestF, 0, 0, NewFValue, F@_2, F@_3, F@_4, TrUserData). d_field_Kaa_function(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, F@_4, TrUserData) when N < 57 -> d_field_Kaa_function(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, F@_4, TrUserData); d_field_Kaa_function(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, _, F@_3, F@_4, TrUserData) -> {NewFValue, RestF} = {id(d_enum_funs(begin <> = <<(X bsl N + Acc):32/unsigned-native>>, id(Res, TrUserData) end), TrUserData), Rest}, dfp_read_field_def_Kaa(RestF, 0, 0, F@_1, NewFValue, F@_3, F@_4, TrUserData). d_field_Kaa_jun_worker(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, F@_4, TrUserData) when N < 57 -> d_field_Kaa_jun_worker(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, F@_4, TrUserData); d_field_Kaa_jun_worker(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, _, F@_4, TrUserData) -> {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(unicode:characters_to_list(Utf8, unicode), TrUserData), Rest2} end, dfp_read_field_def_Kaa(RestF, 0, 0, F@_1, F@_2, NewFValue, F@_4, TrUserData). d_field_Kaa_core(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, F@_4, TrUserData) when N < 57 -> d_field_Kaa_core(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, F@_4, TrUserData); d_field_Kaa_core(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, Prev, TrUserData) -> {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(decode_msg_m_core(Bs, TrUserData), TrUserData), Rest2} end, dfp_read_field_def_Kaa(RestF, 0, 0, F@_1, F@_2, F@_3, case Prev of undefined -> id({core, NewFValue}, TrUserData); {core, MVPrev} -> id({core, merge_msg_m_core(MVPrev, NewFValue, TrUserData)}, TrUserData); _ -> id({core, NewFValue}, TrUserData) end, TrUserData). d_field_Kaa_frame(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, F@_4, TrUserData) when N < 57 -> d_field_Kaa_frame(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, F@_4, TrUserData); d_field_Kaa_frame(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, Prev, TrUserData) -> {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(decode_msg_m_frame(Bs, TrUserData), TrUserData), Rest2} end, dfp_read_field_def_Kaa(RestF, 0, 0, F@_1, F@_2, F@_3, case Prev of undefined -> id({frame, NewFValue}, TrUserData); {frame, MVPrev} -> id({frame, merge_msg_m_frame(MVPrev, NewFValue, TrUserData)}, TrUserData); _ -> id({frame, NewFValue}, TrUserData) end, TrUserData). skip_varint_Kaa(<<1:1, _:7, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData) -> skip_varint_Kaa(Rest, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData); skip_varint_Kaa(<<0:1, _:7, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData) -> dfp_read_field_def_Kaa(Rest, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData). skip_length_delimited_Kaa(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, F@_4, TrUserData) when N < 57 -> skip_length_delimited_Kaa(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, F@_4, TrUserData); skip_length_delimited_Kaa(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, F@_4, TrUserData) -> Length = X bsl N + Acc, <<_:Length/binary, Rest2/binary>> = Rest, dfp_read_field_def_Kaa(Rest2, 0, 0, F@_1, F@_2, F@_3, F@_4, TrUserData). skip_group_Kaa(Bin, FNum, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData) -> {_, Rest} = read_group(Bin, FNum), dfp_read_field_def_Kaa(Rest, 0, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData). skip_32_Kaa(<<_:32, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData) -> dfp_read_field_def_Kaa(Rest, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData). skip_64_Kaa(<<_:64, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData) -> dfp_read_field_def_Kaa(Rest, Z1, Z2, F@_1, F@_2, F@_3, F@_4, TrUserData). decode_msg_m_frame(Bin, TrUserData) -> dfp_read_field_def_m_frame(Bin, 0, 0, id(undefined, TrUserData), id(undefined, TrUserData), id([], TrUserData), TrUserData). dfp_read_field_def_m_frame(<<10, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> d_field_m_frame_dataframe(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData); dfp_read_field_def_m_frame(<<18, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> d_field_m_frame_axis(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData); dfp_read_field_def_m_frame(<<26, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> d_field_m_frame_keywords(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData); dfp_read_field_def_m_frame(<<>>, 0, 0, F@_1, F@_2, R1, TrUserData) -> #m_frame{dataframe = F@_1, axis = F@_2, keywords = lists_reverse(R1, TrUserData)}; dfp_read_field_def_m_frame(Other, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> dg_read_field_def_m_frame(Other, Z1, Z2, F@_1, F@_2, F@_3, TrUserData). dg_read_field_def_m_frame(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, TrUserData) when N < 32 - 7 -> dg_read_field_def_m_frame(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, TrUserData); dg_read_field_def_m_frame(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, TrUserData) -> Key = X bsl N + Acc, case Key of 10 -> d_field_m_frame_dataframe(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData); 18 -> d_field_m_frame_axis(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData); 26 -> d_field_m_frame_keywords(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData); _ -> case Key band 7 of 0 -> skip_varint_m_frame(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData); 1 -> skip_64_m_frame(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData); 2 -> skip_length_delimited_m_frame(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData); 3 -> skip_group_m_frame(Rest, Key bsr 3, 0, F@_1, F@_2, F@_3, TrUserData); 5 -> skip_32_m_frame(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData) end end; dg_read_field_def_m_frame(<<>>, 0, 0, F@_1, F@_2, R1, TrUserData) -> #m_frame{dataframe = F@_1, axis = F@_2, keywords = lists_reverse(R1, TrUserData)}. d_field_m_frame_dataframe(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, TrUserData) when N < 57 -> d_field_m_frame_dataframe(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, TrUserData); d_field_m_frame_dataframe(<<0:1, X:7, Rest/binary>>, N, Acc, _, F@_2, F@_3, TrUserData) -> {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(unicode:characters_to_list(Utf8, unicode), TrUserData), Rest2} end, dfp_read_field_def_m_frame(RestF, 0, 0, NewFValue, F@_2, F@_3, TrUserData). d_field_m_frame_axis(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, TrUserData) when N < 57 -> d_field_m_frame_axis(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, TrUserData); d_field_m_frame_axis(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, _, F@_3, TrUserData) -> {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(unicode:characters_to_list(Utf8, unicode), TrUserData), Rest2} end, dfp_read_field_def_m_frame(RestF, 0, 0, F@_1, NewFValue, F@_3, TrUserData). d_field_m_frame_keywords(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, TrUserData) when N < 57 -> d_field_m_frame_keywords(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, TrUserData); d_field_m_frame_keywords(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, Prev, TrUserData) -> {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(decode_msg_Keywords(Bs, TrUserData), TrUserData), Rest2} end, dfp_read_field_def_m_frame(RestF, 0, 0, F@_1, F@_2, cons(NewFValue, Prev, TrUserData), TrUserData). skip_varint_m_frame(<<1:1, _:7, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> skip_varint_m_frame(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData); skip_varint_m_frame(<<0:1, _:7, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> dfp_read_field_def_m_frame(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData). skip_length_delimited_m_frame(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, TrUserData) when N < 57 -> skip_length_delimited_m_frame(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, TrUserData); skip_length_delimited_m_frame(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, TrUserData) -> Length = X bsl N + Acc, <<_:Length/binary, Rest2/binary>> = Rest, dfp_read_field_def_m_frame(Rest2, 0, 0, F@_1, F@_2, F@_3, TrUserData). skip_group_m_frame(Bin, FNum, Z2, F@_1, F@_2, F@_3, TrUserData) -> {_, Rest} = read_group(Bin, FNum), dfp_read_field_def_m_frame(Rest, 0, Z2, F@_1, F@_2, F@_3, TrUserData). skip_32_m_frame(<<_:32, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> dfp_read_field_def_m_frame(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData). skip_64_m_frame(<<_:64, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> dfp_read_field_def_m_frame(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData). decode_msg_m_core(Bin, TrUserData) -> dfp_read_field_def_m_core(Bin, 0, 0, id(undefined, TrUserData), id([], TrUserData), TrUserData). dfp_read_field_def_m_core(<<10, Rest/binary>>, Z1, Z2, F@_1, F@_2, TrUserData) -> d_field_m_core_argument(Rest, Z1, Z2, F@_1, F@_2, TrUserData); dfp_read_field_def_m_core(<<18, Rest/binary>>, Z1, Z2, F@_1, F@_2, TrUserData) -> d_field_m_core_keywords(Rest, Z1, Z2, F@_1, F@_2, TrUserData); dfp_read_field_def_m_core(<<>>, 0, 0, F@_1, R1, TrUserData) -> #m_core{argument = F@_1, keywords = lists_reverse(R1, TrUserData)}; dfp_read_field_def_m_core(Other, Z1, Z2, F@_1, F@_2, TrUserData) -> dg_read_field_def_m_core(Other, Z1, Z2, F@_1, F@_2, TrUserData). dg_read_field_def_m_core(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, TrUserData) when N < 32 - 7 -> dg_read_field_def_m_core(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, TrUserData); dg_read_field_def_m_core(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, TrUserData) -> Key = X bsl N + Acc, case Key of 10 -> d_field_m_core_argument(Rest, 0, 0, F@_1, F@_2, TrUserData); 18 -> d_field_m_core_keywords(Rest, 0, 0, F@_1, F@_2, TrUserData); _ -> case Key band 7 of 0 -> skip_varint_m_core(Rest, 0, 0, F@_1, F@_2, TrUserData); 1 -> skip_64_m_core(Rest, 0, 0, F@_1, F@_2, TrUserData); 2 -> skip_length_delimited_m_core(Rest, 0, 0, F@_1, F@_2, TrUserData); 3 -> skip_group_m_core(Rest, Key bsr 3, 0, F@_1, F@_2, TrUserData); 5 -> skip_32_m_core(Rest, 0, 0, F@_1, F@_2, TrUserData) end end; dg_read_field_def_m_core(<<>>, 0, 0, F@_1, R1, TrUserData) -> #m_core{argument = F@_1, keywords = lists_reverse(R1, TrUserData)}. d_field_m_core_argument(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, TrUserData) when N < 57 -> d_field_m_core_argument(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, TrUserData); d_field_m_core_argument(<<0:1, X:7, Rest/binary>>, N, Acc, _, F@_2, TrUserData) -> {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(unicode:characters_to_list(Utf8, unicode), TrUserData), Rest2} end, dfp_read_field_def_m_core(RestF, 0, 0, NewFValue, F@_2, TrUserData). d_field_m_core_keywords(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, TrUserData) when N < 57 -> d_field_m_core_keywords(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, TrUserData); d_field_m_core_keywords(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, Prev, TrUserData) -> {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(decode_msg_Keywords(Bs, TrUserData), TrUserData), Rest2} end, dfp_read_field_def_m_core(RestF, 0, 0, F@_1, cons(NewFValue, Prev, TrUserData), TrUserData). skip_varint_m_core(<<1:1, _:7, Rest/binary>>, Z1, Z2, F@_1, F@_2, TrUserData) -> skip_varint_m_core(Rest, Z1, Z2, F@_1, F@_2, TrUserData); skip_varint_m_core(<<0:1, _:7, Rest/binary>>, Z1, Z2, F@_1, F@_2, TrUserData) -> dfp_read_field_def_m_core(Rest, Z1, Z2, F@_1, F@_2, TrUserData). skip_length_delimited_m_core(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, TrUserData) when N < 57 -> skip_length_delimited_m_core(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, TrUserData); skip_length_delimited_m_core(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, TrUserData) -> Length = X bsl N + Acc, <<_:Length/binary, Rest2/binary>> = Rest, dfp_read_field_def_m_core(Rest2, 0, 0, F@_1, F@_2, TrUserData). skip_group_m_core(Bin, FNum, Z2, F@_1, F@_2, TrUserData) -> {_, Rest} = read_group(Bin, FNum), dfp_read_field_def_m_core(Rest, 0, Z2, F@_1, F@_2, TrUserData). skip_32_m_core(<<_:32, Rest/binary>>, Z1, Z2, F@_1, F@_2, TrUserData) -> dfp_read_field_def_m_core(Rest, Z1, Z2, F@_1, F@_2, TrUserData). skip_64_m_core(<<_:64, Rest/binary>>, Z1, Z2, F@_1, F@_2, TrUserData) -> dfp_read_field_def_m_core(Rest, Z1, Z2, F@_1, F@_2, TrUserData). decode_msg_Keywords(Bin, TrUserData) -> dfp_read_field_def_Keywords(Bin, 0, 0, id(undefined, TrUserData), id(undefined, TrUserData), TrUserData). dfp_read_field_def_Keywords(<<10, Rest/binary>>, Z1, Z2, F@_1, F@_2, TrUserData) -> d_field_Keywords_key(Rest, Z1, Z2, F@_1, F@_2, TrUserData); dfp_read_field_def_Keywords(<<18, Rest/binary>>, Z1, Z2, F@_1, F@_2, TrUserData) -> d_field_Keywords_svalue(Rest, Z1, Z2, F@_1, F@_2, TrUserData); dfp_read_field_def_Keywords(<<24, Rest/binary>>, Z1, Z2, F@_1, F@_2, TrUserData) -> d_field_Keywords_ivalue(Rest, Z1, Z2, F@_1, F@_2, TrUserData); dfp_read_field_def_Keywords(<<33, Rest/binary>>, Z1, Z2, F@_1, F@_2, TrUserData) -> d_field_Keywords_dvalue(Rest, Z1, Z2, F@_1, F@_2, TrUserData); dfp_read_field_def_Keywords(<<42, Rest/binary>>, Z1, Z2, F@_1, F@_2, TrUserData) -> d_field_Keywords_avalue(Rest, Z1, Z2, F@_1, F@_2, TrUserData); dfp_read_field_def_Keywords(<<>>, 0, 0, F@_1, F@_2, _) -> #'Keywords'{key = F@_1, value = F@_2}; dfp_read_field_def_Keywords(Other, Z1, Z2, F@_1, F@_2, TrUserData) -> dg_read_field_def_Keywords(Other, Z1, Z2, F@_1, F@_2, TrUserData). dg_read_field_def_Keywords(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, TrUserData) when N < 32 - 7 -> dg_read_field_def_Keywords(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, TrUserData); dg_read_field_def_Keywords(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, TrUserData) -> Key = X bsl N + Acc, case Key of 10 -> d_field_Keywords_key(Rest, 0, 0, F@_1, F@_2, TrUserData); 18 -> d_field_Keywords_svalue(Rest, 0, 0, F@_1, F@_2, TrUserData); 24 -> d_field_Keywords_ivalue(Rest, 0, 0, F@_1, F@_2, TrUserData); 33 -> d_field_Keywords_dvalue(Rest, 0, 0, F@_1, F@_2, TrUserData); 42 -> d_field_Keywords_avalue(Rest, 0, 0, F@_1, F@_2, TrUserData); _ -> case Key band 7 of 0 -> skip_varint_Keywords(Rest, 0, 0, F@_1, F@_2, TrUserData); 1 -> skip_64_Keywords(Rest, 0, 0, F@_1, F@_2, TrUserData); 2 -> skip_length_delimited_Keywords(Rest, 0, 0, F@_1, F@_2, TrUserData); 3 -> skip_group_Keywords(Rest, Key bsr 3, 0, F@_1, F@_2, TrUserData); 5 -> skip_32_Keywords(Rest, 0, 0, F@_1, F@_2, TrUserData) end end; dg_read_field_def_Keywords(<<>>, 0, 0, F@_1, F@_2, _) -> #'Keywords'{key = F@_1, value = F@_2}. d_field_Keywords_key(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, TrUserData) when N < 57 -> d_field_Keywords_key(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, TrUserData); d_field_Keywords_key(<<0:1, X:7, Rest/binary>>, N, Acc, _, F@_2, TrUserData) -> {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(unicode:characters_to_list(Utf8, unicode), TrUserData), Rest2} end, dfp_read_field_def_Keywords(RestF, 0, 0, NewFValue, F@_2, TrUserData). d_field_Keywords_svalue(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, TrUserData) when N < 57 -> d_field_Keywords_svalue(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, TrUserData); d_field_Keywords_svalue(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, _, TrUserData) -> {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(unicode:characters_to_list(Utf8, unicode), TrUserData), Rest2} end, dfp_read_field_def_Keywords(RestF, 0, 0, F@_1, id({svalue, NewFValue}, TrUserData), TrUserData). d_field_Keywords_ivalue(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, TrUserData) when N < 57 -> d_field_Keywords_ivalue(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, TrUserData); d_field_Keywords_ivalue(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, _, TrUserData) -> {NewFValue, RestF} = {begin <> = <<(X bsl N + Acc):64/unsigned-native>>, id(Res, TrUserData) end, Rest}, dfp_read_field_def_Keywords(RestF, 0, 0, F@_1, id({ivalue, NewFValue}, TrUserData), TrUserData). d_field_Keywords_dvalue(<<0:48, 240, 127, Rest/binary>>, Z1, Z2, F@_1, _, TrUserData) -> dfp_read_field_def_Keywords(Rest, Z1, Z2, F@_1, id({dvalue, id(infinity, TrUserData)}, TrUserData), TrUserData); d_field_Keywords_dvalue(<<0:48, 240, 255, Rest/binary>>, Z1, Z2, F@_1, _, TrUserData) -> dfp_read_field_def_Keywords(Rest, Z1, Z2, F@_1, id({dvalue, id('-infinity', TrUserData)}, TrUserData), TrUserData); d_field_Keywords_dvalue(<<_:48, 15:4, _:4, _:1, 127:7, Rest/binary>>, Z1, Z2, F@_1, _, TrUserData) -> dfp_read_field_def_Keywords(Rest, Z1, Z2, F@_1, id({dvalue, id(nan, TrUserData)}, TrUserData), TrUserData); d_field_Keywords_dvalue(<>, Z1, Z2, F@_1, _, TrUserData) -> dfp_read_field_def_Keywords(Rest, Z1, Z2, F@_1, id({dvalue, id(Value, TrUserData)}, TrUserData), TrUserData). d_field_Keywords_avalue(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, TrUserData) when N < 57 -> d_field_Keywords_avalue(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, TrUserData); d_field_Keywords_avalue(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, Prev, TrUserData) -> {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(decode_msg_KeywordValue(Bs, TrUserData), TrUserData), Rest2} end, dfp_read_field_def_Keywords(RestF, 0, 0, F@_1, case Prev of undefined -> id({avalue, NewFValue}, TrUserData); {avalue, MVPrev} -> id({avalue, merge_msg_KeywordValue(MVPrev, NewFValue, TrUserData)}, TrUserData); _ -> id({avalue, NewFValue}, TrUserData) end, TrUserData). skip_varint_Keywords(<<1:1, _:7, Rest/binary>>, Z1, Z2, F@_1, F@_2, TrUserData) -> skip_varint_Keywords(Rest, Z1, Z2, F@_1, F@_2, TrUserData); skip_varint_Keywords(<<0:1, _:7, Rest/binary>>, Z1, Z2, F@_1, F@_2, TrUserData) -> dfp_read_field_def_Keywords(Rest, Z1, Z2, F@_1, F@_2, TrUserData). skip_length_delimited_Keywords(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, TrUserData) when N < 57 -> skip_length_delimited_Keywords(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, TrUserData); skip_length_delimited_Keywords(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, TrUserData) -> Length = X bsl N + Acc, <<_:Length/binary, Rest2/binary>> = Rest, dfp_read_field_def_Keywords(Rest2, 0, 0, F@_1, F@_2, TrUserData). skip_group_Keywords(Bin, FNum, Z2, F@_1, F@_2, TrUserData) -> {_, Rest} = read_group(Bin, FNum), dfp_read_field_def_Keywords(Rest, 0, Z2, F@_1, F@_2, TrUserData). skip_32_Keywords(<<_:32, Rest/binary>>, Z1, Z2, F@_1, F@_2, TrUserData) -> dfp_read_field_def_Keywords(Rest, Z1, Z2, F@_1, F@_2, TrUserData). skip_64_Keywords(<<_:64, Rest/binary>>, Z1, Z2, F@_1, F@_2, TrUserData) -> dfp_read_field_def_Keywords(Rest, Z1, Z2, F@_1, F@_2, TrUserData). decode_msg_KeywordValue(Bin, TrUserData) -> dfp_read_field_def_KeywordValue(Bin, 0, 0, id([], TrUserData), id([], TrUserData), id([], TrUserData), TrUserData). dfp_read_field_def_KeywordValue(<<10, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> d_field_KeywordValue_svalue(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData); dfp_read_field_def_KeywordValue(<<18, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> d_pfield_KeywordValue_ivalue(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData); dfp_read_field_def_KeywordValue(<<16, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> d_field_KeywordValue_ivalue(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData); dfp_read_field_def_KeywordValue(<<26, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> d_pfield_KeywordValue_dvalue(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData); dfp_read_field_def_KeywordValue(<<25, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> d_field_KeywordValue_dvalue(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData); dfp_read_field_def_KeywordValue(<<>>, 0, 0, R1, R2, R3, TrUserData) -> #'KeywordValue'{svalue = lists_reverse(R1, TrUserData), ivalue = lists_reverse(R2, TrUserData), dvalue = lists_reverse(R3, TrUserData)}; dfp_read_field_def_KeywordValue(Other, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> dg_read_field_def_KeywordValue(Other, Z1, Z2, F@_1, F@_2, F@_3, TrUserData). dg_read_field_def_KeywordValue(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, TrUserData) when N < 32 - 7 -> dg_read_field_def_KeywordValue(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, TrUserData); dg_read_field_def_KeywordValue(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, TrUserData) -> Key = X bsl N + Acc, case Key of 10 -> d_field_KeywordValue_svalue(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData); 18 -> d_pfield_KeywordValue_ivalue(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData); 16 -> d_field_KeywordValue_ivalue(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData); 26 -> d_pfield_KeywordValue_dvalue(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData); 25 -> d_field_KeywordValue_dvalue(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData); _ -> case Key band 7 of 0 -> skip_varint_KeywordValue(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData); 1 -> skip_64_KeywordValue(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData); 2 -> skip_length_delimited_KeywordValue(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData); 3 -> skip_group_KeywordValue(Rest, Key bsr 3, 0, F@_1, F@_2, F@_3, TrUserData); 5 -> skip_32_KeywordValue(Rest, 0, 0, F@_1, F@_2, F@_3, TrUserData) end end; dg_read_field_def_KeywordValue(<<>>, 0, 0, R1, R2, R3, TrUserData) -> #'KeywordValue'{svalue = lists_reverse(R1, TrUserData), ivalue = lists_reverse(R2, TrUserData), dvalue = lists_reverse(R3, TrUserData)}. d_field_KeywordValue_svalue(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, TrUserData) when N < 57 -> d_field_KeywordValue_svalue(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, TrUserData); d_field_KeywordValue_svalue(<<0:1, X:7, Rest/binary>>, N, Acc, Prev, F@_2, F@_3, TrUserData) -> {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(unicode:characters_to_list(Utf8, unicode), TrUserData), Rest2} end, dfp_read_field_def_KeywordValue(RestF, 0, 0, cons(NewFValue, Prev, TrUserData), F@_2, F@_3, TrUserData). d_field_KeywordValue_ivalue(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, TrUserData) when N < 57 -> d_field_KeywordValue_ivalue(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, TrUserData); d_field_KeywordValue_ivalue(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, Prev, F@_3, TrUserData) -> {NewFValue, RestF} = {begin <> = <<(X bsl N + Acc):64/unsigned-native>>, id(Res, TrUserData) end, Rest}, dfp_read_field_def_KeywordValue(RestF, 0, 0, F@_1, cons(NewFValue, Prev, TrUserData), F@_3, TrUserData). d_pfield_KeywordValue_ivalue(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, TrUserData) when N < 57 -> d_pfield_KeywordValue_ivalue(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, TrUserData); d_pfield_KeywordValue_ivalue(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, E, F@_3, TrUserData) -> Len = X bsl N + Acc, <> = Rest, NewSeq = d_packed_field_KeywordValue_ivalue(PackedBytes, 0, 0, E, TrUserData), dfp_read_field_def_KeywordValue(Rest2, 0, 0, F@_1, NewSeq, F@_3, TrUserData). d_packed_field_KeywordValue_ivalue(<<1:1, X:7, Rest/binary>>, N, Acc, AccSeq, TrUserData) when N < 57 -> d_packed_field_KeywordValue_ivalue(Rest, N + 7, X bsl N + Acc, AccSeq, TrUserData); d_packed_field_KeywordValue_ivalue(<<0:1, X:7, Rest/binary>>, N, Acc, AccSeq, TrUserData) -> {NewFValue, RestF} = {begin <> = <<(X bsl N + Acc):64/unsigned-native>>, id(Res, TrUserData) end, Rest}, d_packed_field_KeywordValue_ivalue(RestF, 0, 0, [NewFValue | AccSeq], TrUserData); d_packed_field_KeywordValue_ivalue(<<>>, 0, 0, AccSeq, _) -> AccSeq. d_field_KeywordValue_dvalue(<<0:48, 240, 127, Rest/binary>>, Z1, Z2, F@_1, F@_2, Prev, TrUserData) -> dfp_read_field_def_KeywordValue(Rest, Z1, Z2, F@_1, F@_2, cons(id(infinity, TrUserData), Prev, TrUserData), TrUserData); d_field_KeywordValue_dvalue(<<0:48, 240, 255, Rest/binary>>, Z1, Z2, F@_1, F@_2, Prev, TrUserData) -> dfp_read_field_def_KeywordValue(Rest, Z1, Z2, F@_1, F@_2, cons(id('-infinity', TrUserData), Prev, TrUserData), TrUserData); d_field_KeywordValue_dvalue(<<_:48, 15:4, _:4, _:1, 127:7, Rest/binary>>, Z1, Z2, F@_1, F@_2, Prev, TrUserData) -> dfp_read_field_def_KeywordValue(Rest, Z1, Z2, F@_1, F@_2, cons(id(nan, TrUserData), Prev, TrUserData), TrUserData); d_field_KeywordValue_dvalue(<>, Z1, Z2, F@_1, F@_2, Prev, TrUserData) -> dfp_read_field_def_KeywordValue(Rest, Z1, Z2, F@_1, F@_2, cons(id(Value, TrUserData), Prev, TrUserData), TrUserData). d_pfield_KeywordValue_dvalue(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, TrUserData) when N < 57 -> d_pfield_KeywordValue_dvalue(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, TrUserData); d_pfield_KeywordValue_dvalue(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, E, TrUserData) -> Len = X bsl N + Acc, <> = Rest, NewSeq = d_packed_field_KeywordValue_dvalue(PackedBytes, 0, 0, E, TrUserData), dfp_read_field_def_KeywordValue(Rest2, 0, 0, F@_1, F@_2, NewSeq, TrUserData). d_packed_field_KeywordValue_dvalue(<<0:48, 240, 127, Rest/binary>>, Z1, Z2, AccSeq, TrUserData) -> d_packed_field_KeywordValue_dvalue(Rest, Z1, Z2, cons(id(infinity, TrUserData), AccSeq, TrUserData), TrUserData); d_packed_field_KeywordValue_dvalue(<<0:48, 240, 255, Rest/binary>>, Z1, Z2, AccSeq, TrUserData) -> d_packed_field_KeywordValue_dvalue(Rest, Z1, Z2, cons(id('-infinity', TrUserData), AccSeq, TrUserData), TrUserData); d_packed_field_KeywordValue_dvalue(<<_:48, 15:4, _:4, _:1, 127:7, Rest/binary>>, Z1, Z2, AccSeq, TrUserData) -> d_packed_field_KeywordValue_dvalue(Rest, Z1, Z2, cons(id(nan, TrUserData), AccSeq, TrUserData), TrUserData); d_packed_field_KeywordValue_dvalue(<>, Z1, Z2, AccSeq, TrUserData) -> d_packed_field_KeywordValue_dvalue(Rest, Z1, Z2, cons(id(Value, TrUserData), AccSeq, TrUserData), TrUserData); d_packed_field_KeywordValue_dvalue(<<>>, _, _, AccSeq, _) -> AccSeq. skip_varint_KeywordValue(<<1:1, _:7, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> skip_varint_KeywordValue(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData); skip_varint_KeywordValue(<<0:1, _:7, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> dfp_read_field_def_KeywordValue(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData). skip_length_delimited_KeywordValue(<<1:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, TrUserData) when N < 57 -> skip_length_delimited_KeywordValue(Rest, N + 7, X bsl N + Acc, F@_1, F@_2, F@_3, TrUserData); skip_length_delimited_KeywordValue(<<0:1, X:7, Rest/binary>>, N, Acc, F@_1, F@_2, F@_3, TrUserData) -> Length = X bsl N + Acc, <<_:Length/binary, Rest2/binary>> = Rest, dfp_read_field_def_KeywordValue(Rest2, 0, 0, F@_1, F@_2, F@_3, TrUserData). skip_group_KeywordValue(Bin, FNum, Z2, F@_1, F@_2, F@_3, TrUserData) -> {_, Rest} = read_group(Bin, FNum), dfp_read_field_def_KeywordValue(Rest, 0, Z2, F@_1, F@_2, F@_3, TrUserData). skip_32_KeywordValue(<<_:32, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> dfp_read_field_def_KeywordValue(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData). skip_64_KeywordValue(<<_:64, Rest/binary>>, Z1, Z2, F@_1, F@_2, F@_3, TrUserData) -> dfp_read_field_def_KeywordValue(Rest, Z1, Z2, F@_1, F@_2, F@_3, TrUserData). d_enum_mods(0) -> jun_pandas; d_enum_mods(1) -> jun_plotly; d_enum_mods(2) -> jun_seaborn; d_enum_mods(3) -> jun_pandas_series; d_enum_mods(4) -> jun_pandas_timedelta; d_enum_mods(V) -> V. d_enum_funs(0) -> read_csv; d_enum_funs(7) -> to_csv; d_enum_funs(8) -> to_html; d_enum_funs(9) -> to_json; d_enum_funs(43) -> to_datetime; d_enum_funs(45) -> read_sql; d_enum_funs(49) -> read_string; d_enum_funs(1) -> sum; d_enum_funs(2) -> max; d_enum_funs(3) -> min; d_enum_funs(4) -> count; d_enum_funs(5) -> median; d_enum_funs(40) -> unique; d_enum_funs(6) -> query; d_enum_funs(15) -> head; d_enum_funs(16) -> tail; d_enum_funs(10) -> columns; d_enum_funs(11) -> len_columns; d_enum_funs(12) -> len_index; d_enum_funs(13) -> memory_usage; d_enum_funs(14) -> info_columns; d_enum_funs(18) -> selection; d_enum_funs(42) -> single_selection; d_enum_funs(17) -> plot; d_enum_funs(19) -> groupby; d_enum_funs(36) -> apply; d_enum_funs(20) -> sort_values; d_enum_funs(21) -> sort_index; d_enum_funs(23) -> iplot; d_enum_funs(47) -> extend; d_enum_funs(48) -> get_figure; d_enum_funs(24) -> lmplot; d_enum_funs(25) -> factorplot; d_enum_funs(26) -> pairplot; d_enum_funs(27) -> jointplot; d_enum_funs(28) -> stripplot; d_enum_funs(29) -> swarmplot; d_enum_funs(30) -> boxplot; d_enum_funs(31) -> violinplot; d_enum_funs(32) -> lvplot; d_enum_funs(33) -> pointplot; d_enum_funs(34) -> barplot; d_enum_funs(35) -> countplot; d_enum_funs(22) -> legacy_query; d_enum_funs(37) -> legacy_assignment; d_enum_funs(38) -> drop; d_enum_funs(41) -> rename; d_enum_funs(46) -> append; d_enum_funs(39) -> combine; d_enum_funs(44) -> days; d_enum_funs(50) -> fillna; d_enum_funs(51) -> dropna; d_enum_funs(V) -> V. read_group(Bin, FieldNum) -> {NumBytes, EndTagLen} = read_gr_b(Bin, 0, 0, 0, 0, FieldNum), <> = Bin, {Group, Rest}. %% Like skipping over fields, but record the total length, %% Each field is <(FieldNum bsl 3) bor FieldType> ++ %% Record the length because varints may be non-optimally encoded. %% %% Groups can be nested, but assume the same FieldNum cannot be nested %% because group field numbers are shared with the rest of the fields %% numbers. Thus we can search just for an group-end with the same %% field number. %% %% (The only time the same group field number could occur would %% be in a nested sub message, but then it would be inside a %% length-delimited entry, which we skip-read by length.) read_gr_b(<<1:1, X:7, Tl/binary>>, N, Acc, NumBytes, TagLen, FieldNum) when N < (32-7) -> read_gr_b(Tl, N+7, X bsl N + Acc, NumBytes, TagLen+1, FieldNum); read_gr_b(<<0:1, X:7, Tl/binary>>, N, Acc, NumBytes, TagLen, FieldNum) -> Key = X bsl N + Acc, TagLen1 = TagLen + 1, case {Key bsr 3, Key band 7} of {FieldNum, 4} -> % 4 = group_end {NumBytes, TagLen1}; {_, 0} -> % 0 = varint read_gr_vi(Tl, 0, NumBytes + TagLen1, FieldNum); {_, 1} -> % 1 = bits64 <<_:64, Tl2/binary>> = Tl, read_gr_b(Tl2, 0, 0, NumBytes + TagLen1 + 8, 0, FieldNum); {_, 2} -> % 2 = length_delimited read_gr_ld(Tl, 0, 0, NumBytes + TagLen1, FieldNum); {_, 3} -> % 3 = group_start read_gr_b(Tl, 0, 0, NumBytes + TagLen1, 0, FieldNum); {_, 4} -> % 4 = group_end read_gr_b(Tl, 0, 0, NumBytes + TagLen1, 0, FieldNum); {_, 5} -> % 5 = bits32 <<_:32, Tl2/binary>> = Tl, read_gr_b(Tl2, 0, 0, NumBytes + TagLen1 + 4, 0, FieldNum) end. read_gr_vi(<<1:1, _:7, Tl/binary>>, N, NumBytes, FieldNum) when N < (64-7) -> read_gr_vi(Tl, N+7, NumBytes+1, FieldNum); read_gr_vi(<<0:1, _:7, Tl/binary>>, _, NumBytes, FieldNum) -> read_gr_b(Tl, 0, 0, NumBytes+1, 0, FieldNum). read_gr_ld(<<1:1, X:7, Tl/binary>>, N, Acc, NumBytes, FieldNum) when N < (64-7) -> read_gr_ld(Tl, N+7, X bsl N + Acc, NumBytes+1, FieldNum); read_gr_ld(<<0:1, X:7, Tl/binary>>, N, Acc, NumBytes, FieldNum) -> Len = X bsl N + Acc, NumBytes1 = NumBytes + 1, <<_:Len/binary, Tl2/binary>> = Tl, read_gr_b(Tl2, 0, 0, NumBytes1 + Len, 0, FieldNum). merge_msgs(Prev, New) when element(1, Prev) =:= element(1, New) -> merge_msgs(Prev, New, element(1, Prev), []). merge_msgs(Prev, New, MsgName) when is_atom(MsgName) -> merge_msgs(Prev, New, MsgName, []); merge_msgs(Prev, New, Opts) when element(1, Prev) =:= element(1, New), is_list(Opts) -> merge_msgs(Prev, New, element(1, Prev), Opts). merge_msgs(Prev, New, MsgName, Opts) -> TrUserData = proplists:get_value(user_data, Opts), case MsgName of 'Kaa' -> merge_msg_Kaa(Prev, New, TrUserData); m_frame -> merge_msg_m_frame(Prev, New, TrUserData); m_core -> merge_msg_m_core(Prev, New, TrUserData); 'Keywords' -> merge_msg_Keywords(Prev, New, TrUserData); 'KeywordValue' -> merge_msg_KeywordValue(Prev, New, TrUserData) end. -compile({nowarn_unused_function,merge_msg_Kaa/3}). merge_msg_Kaa(#'Kaa'{arguments = PFarguments}, #'Kaa'{module = NFmodule, function = NFfunction, jun_worker = NFjun_worker, arguments = NFarguments}, TrUserData) -> #'Kaa'{module = NFmodule, function = NFfunction, jun_worker = NFjun_worker, arguments = case {PFarguments, NFarguments} of {{core, OPFarguments}, {core, ONFarguments}} -> {core, merge_msg_m_core(OPFarguments, ONFarguments, TrUserData)}; {{frame, OPFarguments}, {frame, ONFarguments}} -> {frame, merge_msg_m_frame(OPFarguments, ONFarguments, TrUserData)}; {_, undefined} -> PFarguments; _ -> NFarguments end}. -compile({nowarn_unused_function,merge_msg_m_frame/3}). merge_msg_m_frame(#m_frame{axis = PFaxis, keywords = PFkeywords}, #m_frame{dataframe = NFdataframe, axis = NFaxis, keywords = NFkeywords}, TrUserData) -> #m_frame{dataframe = NFdataframe, axis = if NFaxis =:= undefined -> PFaxis; true -> NFaxis end, keywords = if PFkeywords /= undefined, NFkeywords /= undefined -> 'erlang_++'(PFkeywords, NFkeywords, TrUserData); PFkeywords == undefined -> NFkeywords; NFkeywords == undefined -> PFkeywords end}. -compile({nowarn_unused_function,merge_msg_m_core/3}). merge_msg_m_core(#m_core{keywords = PFkeywords}, #m_core{argument = NFargument, keywords = NFkeywords}, TrUserData) -> #m_core{argument = NFargument, keywords = if PFkeywords /= undefined, NFkeywords /= undefined -> 'erlang_++'(PFkeywords, NFkeywords, TrUserData); PFkeywords == undefined -> NFkeywords; NFkeywords == undefined -> PFkeywords end}. -compile({nowarn_unused_function,merge_msg_Keywords/3}). merge_msg_Keywords(#'Keywords'{value = PFvalue}, #'Keywords'{key = NFkey, value = NFvalue}, TrUserData) -> #'Keywords'{key = NFkey, value = case {PFvalue, NFvalue} of {{avalue, OPFvalue}, {avalue, ONFvalue}} -> {avalue, merge_msg_KeywordValue(OPFvalue, ONFvalue, TrUserData)}; {_, undefined} -> PFvalue; _ -> NFvalue end}. -compile({nowarn_unused_function,merge_msg_KeywordValue/3}). merge_msg_KeywordValue(#'KeywordValue'{svalue = PFsvalue, ivalue = PFivalue, dvalue = PFdvalue}, #'KeywordValue'{svalue = NFsvalue, ivalue = NFivalue, dvalue = NFdvalue}, TrUserData) -> #'KeywordValue'{svalue = if PFsvalue /= undefined, NFsvalue /= undefined -> 'erlang_++'(PFsvalue, NFsvalue, TrUserData); PFsvalue == undefined -> NFsvalue; NFsvalue == undefined -> PFsvalue end, ivalue = if PFivalue /= undefined, NFivalue /= undefined -> 'erlang_++'(PFivalue, NFivalue, TrUserData); PFivalue == undefined -> NFivalue; NFivalue == undefined -> PFivalue end, dvalue = if PFdvalue /= undefined, NFdvalue /= undefined -> 'erlang_++'(PFdvalue, NFdvalue, TrUserData); PFdvalue == undefined -> NFdvalue; NFdvalue == undefined -> PFdvalue end}. verify_msg(Msg) when tuple_size(Msg) >= 1 -> verify_msg(Msg, element(1, Msg), []); verify_msg(X) -> mk_type_error(not_a_known_message, X, []). verify_msg(Msg, MsgName) when is_atom(MsgName) -> verify_msg(Msg, MsgName, []); verify_msg(Msg, Opts) when tuple_size(Msg) >= 1 -> verify_msg(Msg, element(1, Msg), Opts); verify_msg(X, _Opts) -> mk_type_error(not_a_known_message, X, []). verify_msg(Msg, MsgName, Opts) -> TrUserData = proplists:get_value(user_data, Opts), case MsgName of 'Kaa' -> v_msg_Kaa(Msg, [MsgName], TrUserData); m_frame -> v_msg_m_frame(Msg, [MsgName], TrUserData); m_core -> v_msg_m_core(Msg, [MsgName], TrUserData); 'Keywords' -> v_msg_Keywords(Msg, [MsgName], TrUserData); 'KeywordValue' -> v_msg_KeywordValue(Msg, [MsgName], TrUserData); _ -> mk_type_error(not_a_known_message, Msg, []) end. -compile({nowarn_unused_function,v_msg_Kaa/3}). -dialyzer({nowarn_function,v_msg_Kaa/3}). v_msg_Kaa(#'Kaa'{module = F1, function = F2, jun_worker = F3, arguments = F4}, Path, TrUserData) -> v_enum_mods(F1, [module | Path], TrUserData), v_enum_funs(F2, [function | Path], TrUserData), v_type_string(F3, [jun_worker | Path], TrUserData), case F4 of undefined -> ok; {core, OF4} -> v_msg_m_core(OF4, [core, arguments | Path], TrUserData); {frame, OF4} -> v_msg_m_frame(OF4, [frame, arguments | Path], TrUserData); _ -> mk_type_error(invalid_oneof, F4, [arguments | Path]) end, ok; v_msg_Kaa(X, Path, _TrUserData) -> mk_type_error({expected_msg, 'Kaa'}, X, Path). -compile({nowarn_unused_function,v_msg_m_frame/3}). -dialyzer({nowarn_function,v_msg_m_frame/3}). v_msg_m_frame(#m_frame{dataframe = F1, axis = F2, keywords = F3}, Path, TrUserData) -> v_type_string(F1, [dataframe | Path], TrUserData), if F2 == undefined -> ok; true -> v_type_string(F2, [axis | Path], TrUserData) end, if is_list(F3) -> _ = [v_msg_Keywords(Elem, [keywords | Path], TrUserData) || Elem <- F3], ok; true -> mk_type_error({invalid_list_of, {msg, 'Keywords'}}, F3, [keywords | Path]) end, ok; v_msg_m_frame(X, Path, _TrUserData) -> mk_type_error({expected_msg, m_frame}, X, Path). -compile({nowarn_unused_function,v_msg_m_core/3}). -dialyzer({nowarn_function,v_msg_m_core/3}). v_msg_m_core(#m_core{argument = F1, keywords = F2}, Path, TrUserData) -> v_type_string(F1, [argument | Path], TrUserData), if is_list(F2) -> _ = [v_msg_Keywords(Elem, [keywords | Path], TrUserData) || Elem <- F2], ok; true -> mk_type_error({invalid_list_of, {msg, 'Keywords'}}, F2, [keywords | Path]) end, ok; v_msg_m_core(X, Path, _TrUserData) -> mk_type_error({expected_msg, m_core}, X, Path). -compile({nowarn_unused_function,v_msg_Keywords/3}). -dialyzer({nowarn_function,v_msg_Keywords/3}). v_msg_Keywords(#'Keywords'{key = F1, value = F2}, Path, TrUserData) -> v_type_string(F1, [key | Path], TrUserData), case F2 of undefined -> ok; {svalue, OF2} -> v_type_string(OF2, [svalue, value | Path], TrUserData); {ivalue, OF2} -> v_type_int64(OF2, [ivalue, value | Path], TrUserData); {dvalue, OF2} -> v_type_double(OF2, [dvalue, value | Path], TrUserData); {avalue, OF2} -> v_msg_KeywordValue(OF2, [avalue, value | Path], TrUserData); _ -> mk_type_error(invalid_oneof, F2, [value | Path]) end, ok; v_msg_Keywords(X, Path, _TrUserData) -> mk_type_error({expected_msg, 'Keywords'}, X, Path). -compile({nowarn_unused_function,v_msg_KeywordValue/3}). -dialyzer({nowarn_function,v_msg_KeywordValue/3}). v_msg_KeywordValue(#'KeywordValue'{svalue = F1, ivalue = F2, dvalue = F3}, Path, TrUserData) -> if is_list(F1) -> _ = [v_type_string(Elem, [svalue | Path], TrUserData) || Elem <- F1], ok; true -> mk_type_error({invalid_list_of, string}, F1, [svalue | Path]) end, if is_list(F2) -> _ = [v_type_int64(Elem, [ivalue | Path], TrUserData) || Elem <- F2], ok; true -> mk_type_error({invalid_list_of, int64}, F2, [ivalue | Path]) end, if is_list(F3) -> _ = [v_type_double(Elem, [dvalue | Path], TrUserData) || Elem <- F3], ok; true -> mk_type_error({invalid_list_of, double}, F3, [dvalue | Path]) end, ok; v_msg_KeywordValue(X, Path, _TrUserData) -> mk_type_error({expected_msg, 'KeywordValue'}, X, Path). -compile({nowarn_unused_function,v_enum_mods/3}). -dialyzer({nowarn_function,v_enum_mods/3}). v_enum_mods(jun_pandas, _Path, _TrUserData) -> ok; v_enum_mods(jun_plotly, _Path, _TrUserData) -> ok; v_enum_mods(jun_seaborn, _Path, _TrUserData) -> ok; v_enum_mods(jun_pandas_series, _Path, _TrUserData) -> ok; v_enum_mods(jun_pandas_timedelta, _Path, _TrUserData) -> ok; v_enum_mods(V, Path, TrUserData) when is_integer(V) -> v_type_sint32(V, Path, TrUserData); v_enum_mods(X, Path, _TrUserData) -> mk_type_error({invalid_enum, mods}, X, Path). -compile({nowarn_unused_function,v_enum_funs/3}). -dialyzer({nowarn_function,v_enum_funs/3}). v_enum_funs(read_csv, _Path, _TrUserData) -> ok; v_enum_funs(to_csv, _Path, _TrUserData) -> ok; v_enum_funs(to_html, _Path, _TrUserData) -> ok; v_enum_funs(to_json, _Path, _TrUserData) -> ok; v_enum_funs(to_datetime, _Path, _TrUserData) -> ok; v_enum_funs(read_sql, _Path, _TrUserData) -> ok; v_enum_funs(read_string, _Path, _TrUserData) -> ok; v_enum_funs(sum, _Path, _TrUserData) -> ok; v_enum_funs(max, _Path, _TrUserData) -> ok; v_enum_funs(min, _Path, _TrUserData) -> ok; v_enum_funs(count, _Path, _TrUserData) -> ok; v_enum_funs(median, _Path, _TrUserData) -> ok; v_enum_funs(unique, _Path, _TrUserData) -> ok; v_enum_funs(query, _Path, _TrUserData) -> ok; v_enum_funs(head, _Path, _TrUserData) -> ok; v_enum_funs(tail, _Path, _TrUserData) -> ok; v_enum_funs(columns, _Path, _TrUserData) -> ok; v_enum_funs(len_columns, _Path, _TrUserData) -> ok; v_enum_funs(len_index, _Path, _TrUserData) -> ok; v_enum_funs(memory_usage, _Path, _TrUserData) -> ok; v_enum_funs(info_columns, _Path, _TrUserData) -> ok; v_enum_funs(selection, _Path, _TrUserData) -> ok; v_enum_funs(single_selection, _Path, _TrUserData) -> ok; v_enum_funs(plot, _Path, _TrUserData) -> ok; v_enum_funs(groupby, _Path, _TrUserData) -> ok; v_enum_funs(apply, _Path, _TrUserData) -> ok; v_enum_funs(sort_values, _Path, _TrUserData) -> ok; v_enum_funs(sort_index, _Path, _TrUserData) -> ok; v_enum_funs(iplot, _Path, _TrUserData) -> ok; v_enum_funs(extend, _Path, _TrUserData) -> ok; v_enum_funs(get_figure, _Path, _TrUserData) -> ok; v_enum_funs(lmplot, _Path, _TrUserData) -> ok; v_enum_funs(factorplot, _Path, _TrUserData) -> ok; v_enum_funs(pairplot, _Path, _TrUserData) -> ok; v_enum_funs(jointplot, _Path, _TrUserData) -> ok; v_enum_funs(stripplot, _Path, _TrUserData) -> ok; v_enum_funs(swarmplot, _Path, _TrUserData) -> ok; v_enum_funs(boxplot, _Path, _TrUserData) -> ok; v_enum_funs(violinplot, _Path, _TrUserData) -> ok; v_enum_funs(lvplot, _Path, _TrUserData) -> ok; v_enum_funs(pointplot, _Path, _TrUserData) -> ok; v_enum_funs(barplot, _Path, _TrUserData) -> ok; v_enum_funs(countplot, _Path, _TrUserData) -> ok; v_enum_funs(legacy_query, _Path, _TrUserData) -> ok; v_enum_funs(legacy_assignment, _Path, _TrUserData) -> ok; v_enum_funs(drop, _Path, _TrUserData) -> ok; v_enum_funs(rename, _Path, _TrUserData) -> ok; v_enum_funs(append, _Path, _TrUserData) -> ok; v_enum_funs(combine, _Path, _TrUserData) -> ok; v_enum_funs(days, _Path, _TrUserData) -> ok; v_enum_funs(fillna, _Path, _TrUserData) -> ok; v_enum_funs(dropna, _Path, _TrUserData) -> ok; v_enum_funs(V, Path, TrUserData) when is_integer(V) -> v_type_sint32(V, Path, TrUserData); v_enum_funs(X, Path, _TrUserData) -> mk_type_error({invalid_enum, funs}, X, Path). -compile({nowarn_unused_function,v_type_sint32/3}). -dialyzer({nowarn_function,v_type_sint32/3}). v_type_sint32(N, _Path, _TrUserData) when -2147483648 =< N, N =< 2147483647 -> ok; v_type_sint32(N, Path, _TrUserData) when is_integer(N) -> mk_type_error({value_out_of_range, sint32, signed, 32}, N, Path); v_type_sint32(X, Path, _TrUserData) -> mk_type_error({bad_integer, sint32, signed, 32}, X, Path). -compile({nowarn_unused_function,v_type_int64/3}). -dialyzer({nowarn_function,v_type_int64/3}). v_type_int64(N, _Path, _TrUserData) when -9223372036854775808 =< N, N =< 9223372036854775807 -> ok; v_type_int64(N, Path, _TrUserData) when is_integer(N) -> mk_type_error({value_out_of_range, int64, signed, 64}, N, Path); v_type_int64(X, Path, _TrUserData) -> mk_type_error({bad_integer, int64, signed, 64}, X, Path). -compile({nowarn_unused_function,v_type_double/3}). -dialyzer({nowarn_function,v_type_double/3}). v_type_double(N, _Path, _TrUserData) when is_float(N) -> ok; v_type_double(N, _Path, _TrUserData) when is_integer(N) -> ok; v_type_double(infinity, _Path, _TrUserData) -> ok; v_type_double('-infinity', _Path, _TrUserData) -> ok; v_type_double(nan, _Path, _TrUserData) -> ok; v_type_double(X, Path, _TrUserData) -> mk_type_error(bad_double_value, X, Path). -compile({nowarn_unused_function,v_type_string/3}). -dialyzer({nowarn_function,v_type_string/3}). v_type_string(S, Path, _TrUserData) when is_list(S); is_binary(S) -> try unicode:characters_to_binary(S) of B when is_binary(B) -> ok; {error, _, _} -> mk_type_error(bad_unicode_string, S, Path) catch error:badarg -> mk_type_error(bad_unicode_string, S, Path) end; v_type_string(X, Path, _TrUserData) -> mk_type_error(bad_unicode_string, X, Path). -compile({nowarn_unused_function,mk_type_error/3}). -spec mk_type_error(_, _, list()) -> no_return(). mk_type_error(Error, ValueSeen, Path) -> Path2 = prettify_path(Path), erlang:error({gpb_type_error, {Error, [{value, ValueSeen}, {path, Path2}]}}). -compile({nowarn_unused_function,prettify_path/1}). -dialyzer({nowarn_function,prettify_path/1}). prettify_path([]) -> top_level; prettify_path(PathR) -> list_to_atom(lists:append(lists:join(".", lists:map(fun atom_to_list/1, lists:reverse(PathR))))). -compile({nowarn_unused_function,id/2}). -compile({inline,id/2}). id(X, _TrUserData) -> X. -compile({nowarn_unused_function,v_ok/3}). -compile({inline,v_ok/3}). v_ok(_Value, _Path, _TrUserData) -> ok. -compile({nowarn_unused_function,m_overwrite/3}). -compile({inline,m_overwrite/3}). m_overwrite(_Prev, New, _TrUserData) -> New. -compile({nowarn_unused_function,cons/3}). -compile({inline,cons/3}). cons(Elem, Acc, _TrUserData) -> [Elem | Acc]. -compile({nowarn_unused_function,lists_reverse/2}). -compile({inline,lists_reverse/2}). 'lists_reverse'(L, _TrUserData) -> lists:reverse(L). -compile({nowarn_unused_function,'erlang_++'/3}). -compile({inline,'erlang_++'/3}). 'erlang_++'(A, B, _TrUserData) -> A ++ B. get_msg_defs() -> [{{enum, mods}, [{jun_pandas, 0}, {jun_plotly, 1}, {jun_seaborn, 2}, {jun_pandas_series, 3}, {jun_pandas_timedelta, 4}]}, {{enum, funs}, [{read_csv, 0}, {to_csv, 7}, {to_html, 8}, {to_json, 9}, {to_datetime, 43}, {read_sql, 45}, {read_string, 49}, {sum, 1}, {max, 2}, {min, 3}, {count, 4}, {median, 5}, {unique, 40}, {query, 6}, {head, 15}, {tail, 16}, {columns, 10}, {len_columns, 11}, {len_index, 12}, {memory_usage, 13}, {info_columns, 14}, {selection, 18}, {single_selection, 42}, {plot, 17}, {groupby, 19}, {apply, 36}, {sort_values, 20}, {sort_index, 21}, {iplot, 23}, {extend, 47}, {get_figure, 48}, {lmplot, 24}, {factorplot, 25}, {pairplot, 26}, {jointplot, 27}, {stripplot, 28}, {swarmplot, 29}, {boxplot, 30}, {violinplot, 31}, {lvplot, 32}, {pointplot, 33}, {barplot, 34}, {countplot, 35}, {legacy_query, 22}, {legacy_assignment, 37}, {drop, 38}, {rename, 41}, {append, 46}, {combine, 39}, {days, 44}, {fillna, 50}, {dropna, 51}]}, {{msg, 'Kaa'}, [#field{name = module, fnum = 1, rnum = 2, type = {enum, mods}, occurrence = required, opts = []}, #field{name = function, fnum = 2, rnum = 3, type = {enum, funs}, occurrence = required, opts = []}, #field{name = jun_worker, fnum = 3, rnum = 4, type = string, occurrence = required, opts = []}, #gpb_oneof{name = arguments, rnum = 5, fields = [#field{name = core, fnum = 4, rnum = 5, type = {msg, m_core}, occurrence = optional, opts = []}, #field{name = frame, fnum = 5, rnum = 5, type = {msg, m_frame}, occurrence = optional, opts = []}]}]}, {{msg, m_frame}, [#field{name = dataframe, fnum = 1, rnum = 2, type = string, occurrence = required, opts = []}, #field{name = axis, fnum = 2, rnum = 3, type = string, occurrence = optional, opts = []}, #field{name = keywords, fnum = 3, rnum = 4, type = {msg, 'Keywords'}, occurrence = repeated, opts = []}]}, {{msg, m_core}, [#field{name = argument, fnum = 1, rnum = 2, type = string, occurrence = required, opts = []}, #field{name = keywords, fnum = 2, rnum = 3, type = {msg, 'Keywords'}, occurrence = repeated, opts = []}]}, {{msg, 'Keywords'}, [#field{name = key, fnum = 1, rnum = 2, type = string, occurrence = required, opts = []}, #gpb_oneof{name = value, rnum = 3, fields = [#field{name = svalue, fnum = 2, rnum = 3, type = string, occurrence = optional, opts = []}, #field{name = ivalue, fnum = 3, rnum = 3, type = int64, occurrence = optional, opts = []}, #field{name = dvalue, fnum = 4, rnum = 3, type = double, occurrence = optional, opts = []}, #field{name = avalue, fnum = 5, rnum = 3, type = {msg, 'KeywordValue'}, occurrence = optional, opts = []}]}]}, {{msg, 'KeywordValue'}, [#field{name = svalue, fnum = 1, rnum = 2, type = string, occurrence = repeated, opts = []}, #field{name = ivalue, fnum = 2, rnum = 3, type = int64, occurrence = repeated, opts = []}, #field{name = dvalue, fnum = 3, rnum = 4, type = double, occurrence = repeated, opts = []}]}]. get_msg_names() -> ['Kaa', m_frame, m_core, 'Keywords', 'KeywordValue']. get_group_names() -> []. get_msg_or_group_names() -> ['Kaa', m_frame, m_core, 'Keywords', 'KeywordValue']. get_enum_names() -> [mods, funs]. fetch_msg_def(MsgName) -> case find_msg_def(MsgName) of Fs when is_list(Fs) -> Fs; error -> erlang:error({no_such_msg, MsgName}) end. fetch_enum_def(EnumName) -> case find_enum_def(EnumName) of Es when is_list(Es) -> Es; error -> erlang:error({no_such_enum, EnumName}) end. find_msg_def('Kaa') -> [#field{name = module, fnum = 1, rnum = 2, type = {enum, mods}, occurrence = required, opts = []}, #field{name = function, fnum = 2, rnum = 3, type = {enum, funs}, occurrence = required, opts = []}, #field{name = jun_worker, fnum = 3, rnum = 4, type = string, occurrence = required, opts = []}, #gpb_oneof{name = arguments, rnum = 5, fields = [#field{name = core, fnum = 4, rnum = 5, type = {msg, m_core}, occurrence = optional, opts = []}, #field{name = frame, fnum = 5, rnum = 5, type = {msg, m_frame}, occurrence = optional, opts = []}]}]; find_msg_def(m_frame) -> [#field{name = dataframe, fnum = 1, rnum = 2, type = string, occurrence = required, opts = []}, #field{name = axis, fnum = 2, rnum = 3, type = string, occurrence = optional, opts = []}, #field{name = keywords, fnum = 3, rnum = 4, type = {msg, 'Keywords'}, occurrence = repeated, opts = []}]; find_msg_def(m_core) -> [#field{name = argument, fnum = 1, rnum = 2, type = string, occurrence = required, opts = []}, #field{name = keywords, fnum = 2, rnum = 3, type = {msg, 'Keywords'}, occurrence = repeated, opts = []}]; find_msg_def('Keywords') -> [#field{name = key, fnum = 1, rnum = 2, type = string, occurrence = required, opts = []}, #gpb_oneof{name = value, rnum = 3, fields = [#field{name = svalue, fnum = 2, rnum = 3, type = string, occurrence = optional, opts = []}, #field{name = ivalue, fnum = 3, rnum = 3, type = int64, occurrence = optional, opts = []}, #field{name = dvalue, fnum = 4, rnum = 3, type = double, occurrence = optional, opts = []}, #field{name = avalue, fnum = 5, rnum = 3, type = {msg, 'KeywordValue'}, occurrence = optional, opts = []}]}]; find_msg_def('KeywordValue') -> [#field{name = svalue, fnum = 1, rnum = 2, type = string, occurrence = repeated, opts = []}, #field{name = ivalue, fnum = 2, rnum = 3, type = int64, occurrence = repeated, opts = []}, #field{name = dvalue, fnum = 3, rnum = 4, type = double, occurrence = repeated, opts = []}]; find_msg_def(_) -> error. find_enum_def(mods) -> [{jun_pandas, 0}, {jun_plotly, 1}, {jun_seaborn, 2}, {jun_pandas_series, 3}, {jun_pandas_timedelta, 4}]; find_enum_def(funs) -> [{read_csv, 0}, {to_csv, 7}, {to_html, 8}, {to_json, 9}, {to_datetime, 43}, {read_sql, 45}, {read_string, 49}, {sum, 1}, {max, 2}, {min, 3}, {count, 4}, {median, 5}, {unique, 40}, {query, 6}, {head, 15}, {tail, 16}, {columns, 10}, {len_columns, 11}, {len_index, 12}, {memory_usage, 13}, {info_columns, 14}, {selection, 18}, {single_selection, 42}, {plot, 17}, {groupby, 19}, {apply, 36}, {sort_values, 20}, {sort_index, 21}, {iplot, 23}, {extend, 47}, {get_figure, 48}, {lmplot, 24}, {factorplot, 25}, {pairplot, 26}, {jointplot, 27}, {stripplot, 28}, {swarmplot, 29}, {boxplot, 30}, {violinplot, 31}, {lvplot, 32}, {pointplot, 33}, {barplot, 34}, {countplot, 35}, {legacy_query, 22}, {legacy_assignment, 37}, {drop, 38}, {rename, 41}, {append, 46}, {combine, 39}, {days, 44}, {fillna, 50}, {dropna, 51}]; find_enum_def(_) -> error. enum_symbol_by_value(mods, Value) -> enum_symbol_by_value_mods(Value); enum_symbol_by_value(funs, Value) -> enum_symbol_by_value_funs(Value). enum_value_by_symbol(mods, Sym) -> enum_value_by_symbol_mods(Sym); enum_value_by_symbol(funs, Sym) -> enum_value_by_symbol_funs(Sym). enum_symbol_by_value_mods(0) -> jun_pandas; enum_symbol_by_value_mods(1) -> jun_plotly; enum_symbol_by_value_mods(2) -> jun_seaborn; enum_symbol_by_value_mods(3) -> jun_pandas_series; enum_symbol_by_value_mods(4) -> jun_pandas_timedelta. enum_value_by_symbol_mods(jun_pandas) -> 0; enum_value_by_symbol_mods(jun_plotly) -> 1; enum_value_by_symbol_mods(jun_seaborn) -> 2; enum_value_by_symbol_mods(jun_pandas_series) -> 3; enum_value_by_symbol_mods(jun_pandas_timedelta) -> 4. enum_symbol_by_value_funs(0) -> read_csv; enum_symbol_by_value_funs(7) -> to_csv; enum_symbol_by_value_funs(8) -> to_html; enum_symbol_by_value_funs(9) -> to_json; enum_symbol_by_value_funs(43) -> to_datetime; enum_symbol_by_value_funs(45) -> read_sql; enum_symbol_by_value_funs(49) -> read_string; enum_symbol_by_value_funs(1) -> sum; enum_symbol_by_value_funs(2) -> max; enum_symbol_by_value_funs(3) -> min; enum_symbol_by_value_funs(4) -> count; enum_symbol_by_value_funs(5) -> median; enum_symbol_by_value_funs(40) -> unique; enum_symbol_by_value_funs(6) -> query; enum_symbol_by_value_funs(15) -> head; enum_symbol_by_value_funs(16) -> tail; enum_symbol_by_value_funs(10) -> columns; enum_symbol_by_value_funs(11) -> len_columns; enum_symbol_by_value_funs(12) -> len_index; enum_symbol_by_value_funs(13) -> memory_usage; enum_symbol_by_value_funs(14) -> info_columns; enum_symbol_by_value_funs(18) -> selection; enum_symbol_by_value_funs(42) -> single_selection; enum_symbol_by_value_funs(17) -> plot; enum_symbol_by_value_funs(19) -> groupby; enum_symbol_by_value_funs(36) -> apply; enum_symbol_by_value_funs(20) -> sort_values; enum_symbol_by_value_funs(21) -> sort_index; enum_symbol_by_value_funs(23) -> iplot; enum_symbol_by_value_funs(47) -> extend; enum_symbol_by_value_funs(48) -> get_figure; enum_symbol_by_value_funs(24) -> lmplot; enum_symbol_by_value_funs(25) -> factorplot; enum_symbol_by_value_funs(26) -> pairplot; enum_symbol_by_value_funs(27) -> jointplot; enum_symbol_by_value_funs(28) -> stripplot; enum_symbol_by_value_funs(29) -> swarmplot; enum_symbol_by_value_funs(30) -> boxplot; enum_symbol_by_value_funs(31) -> violinplot; enum_symbol_by_value_funs(32) -> lvplot; enum_symbol_by_value_funs(33) -> pointplot; enum_symbol_by_value_funs(34) -> barplot; enum_symbol_by_value_funs(35) -> countplot; enum_symbol_by_value_funs(22) -> legacy_query; enum_symbol_by_value_funs(37) -> legacy_assignment; enum_symbol_by_value_funs(38) -> drop; enum_symbol_by_value_funs(41) -> rename; enum_symbol_by_value_funs(46) -> append; enum_symbol_by_value_funs(39) -> combine; enum_symbol_by_value_funs(44) -> days; enum_symbol_by_value_funs(50) -> fillna; enum_symbol_by_value_funs(51) -> dropna. enum_value_by_symbol_funs(read_csv) -> 0; enum_value_by_symbol_funs(to_csv) -> 7; enum_value_by_symbol_funs(to_html) -> 8; enum_value_by_symbol_funs(to_json) -> 9; enum_value_by_symbol_funs(to_datetime) -> 43; enum_value_by_symbol_funs(read_sql) -> 45; enum_value_by_symbol_funs(read_string) -> 49; enum_value_by_symbol_funs(sum) -> 1; enum_value_by_symbol_funs(max) -> 2; enum_value_by_symbol_funs(min) -> 3; enum_value_by_symbol_funs(count) -> 4; enum_value_by_symbol_funs(median) -> 5; enum_value_by_symbol_funs(unique) -> 40; enum_value_by_symbol_funs(query) -> 6; enum_value_by_symbol_funs(head) -> 15; enum_value_by_symbol_funs(tail) -> 16; enum_value_by_symbol_funs(columns) -> 10; enum_value_by_symbol_funs(len_columns) -> 11; enum_value_by_symbol_funs(len_index) -> 12; enum_value_by_symbol_funs(memory_usage) -> 13; enum_value_by_symbol_funs(info_columns) -> 14; enum_value_by_symbol_funs(selection) -> 18; enum_value_by_symbol_funs(single_selection) -> 42; enum_value_by_symbol_funs(plot) -> 17; enum_value_by_symbol_funs(groupby) -> 19; enum_value_by_symbol_funs(apply) -> 36; enum_value_by_symbol_funs(sort_values) -> 20; enum_value_by_symbol_funs(sort_index) -> 21; enum_value_by_symbol_funs(iplot) -> 23; enum_value_by_symbol_funs(extend) -> 47; enum_value_by_symbol_funs(get_figure) -> 48; enum_value_by_symbol_funs(lmplot) -> 24; enum_value_by_symbol_funs(factorplot) -> 25; enum_value_by_symbol_funs(pairplot) -> 26; enum_value_by_symbol_funs(jointplot) -> 27; enum_value_by_symbol_funs(stripplot) -> 28; enum_value_by_symbol_funs(swarmplot) -> 29; enum_value_by_symbol_funs(boxplot) -> 30; enum_value_by_symbol_funs(violinplot) -> 31; enum_value_by_symbol_funs(lvplot) -> 32; enum_value_by_symbol_funs(pointplot) -> 33; enum_value_by_symbol_funs(barplot) -> 34; enum_value_by_symbol_funs(countplot) -> 35; enum_value_by_symbol_funs(legacy_query) -> 22; enum_value_by_symbol_funs(legacy_assignment) -> 37; enum_value_by_symbol_funs(drop) -> 38; enum_value_by_symbol_funs(rename) -> 41; enum_value_by_symbol_funs(append) -> 46; enum_value_by_symbol_funs(combine) -> 39; enum_value_by_symbol_funs(days) -> 44; enum_value_by_symbol_funs(fillna) -> 50; enum_value_by_symbol_funs(dropna) -> 51. get_service_names() -> []. get_service_def(_) -> error. get_rpc_names(_) -> error. find_rpc_def(_, _) -> error. -spec fetch_rpc_def(_, _) -> no_return(). fetch_rpc_def(ServiceName, RpcName) -> erlang:error({no_such_rpc, ServiceName, RpcName}). %% Convert a a fully qualified (ie with package name) service name %% as a binary to a service name as an atom. -spec fqbin_to_service_name(_) -> no_return(). fqbin_to_service_name(X) -> error({gpb_error, {badservice, X}}). %% Convert a service name as an atom to a fully qualified %% (ie with package name) name as a binary. -spec service_name_to_fqbin(_) -> no_return(). service_name_to_fqbin(X) -> error({gpb_error, {badservice, X}}). %% Convert a a fully qualified (ie with package name) service name %% and an rpc name, both as binaries to a service name and an rpc %% name, as atoms. -spec fqbins_to_service_and_rpc_name(_, _) -> no_return(). fqbins_to_service_and_rpc_name(S, R) -> error({gpb_error, {badservice_or_rpc, {S, R}}}). %% Convert a service name and an rpc name, both as atoms, %% to a fully qualified (ie with package name) service name and %% an rpc name as binaries. -spec service_and_rpc_name_to_fqbins(_, _) -> no_return(). service_and_rpc_name_to_fqbins(S, R) -> error({gpb_error, {badservice_or_rpc, {S, R}}}). fqbin_to_msg_name(<<"Kaa">>) -> 'Kaa'; fqbin_to_msg_name(<<"m_frame">>) -> m_frame; fqbin_to_msg_name(<<"m_core">>) -> m_core; fqbin_to_msg_name(<<"Keywords">>) -> 'Keywords'; fqbin_to_msg_name(<<"KeywordValue">>) -> 'KeywordValue'; fqbin_to_msg_name(E) -> error({gpb_error, {badmsg, E}}). msg_name_to_fqbin('Kaa') -> <<"Kaa">>; msg_name_to_fqbin(m_frame) -> <<"m_frame">>; msg_name_to_fqbin(m_core) -> <<"m_core">>; msg_name_to_fqbin('Keywords') -> <<"Keywords">>; msg_name_to_fqbin('KeywordValue') -> <<"KeywordValue">>; msg_name_to_fqbin(E) -> error({gpb_error, {badmsg, E}}). fqbin_to_enum_name(<<"mods">>) -> mods; fqbin_to_enum_name(<<"funs">>) -> funs; fqbin_to_enum_name(E) -> error({gpb_error, {badenum, E}}). enum_name_to_fqbin(mods) -> <<"mods">>; enum_name_to_fqbin(funs) -> <<"funs">>; enum_name_to_fqbin(E) -> error({gpb_error, {badenum, E}}). get_package_name() -> undefined. %% Whether or not the message names %% are prepended with package name or not. uses_packages() -> false. source_basename() -> "kaa.proto". %% Retrieve all proto file names, also imported ones. %% The order is top-down. The first element is always the main %% source file. The files are returned with extension, %% see get_all_proto_names/0 for a version that returns %% the basenames sans extension get_all_source_basenames() -> ["kaa.proto"]. %% Retrieve all proto file names, also imported ones. %% The order is top-down. The first element is always the main %% source file. The files are returned sans .proto extension, %% to make it easier to use them with the various get_xyz_containment %% functions. get_all_proto_names() -> ["kaa"]. get_msg_containment("kaa") -> ['Kaa', 'KeywordValue', 'Keywords', m_core, m_frame]; get_msg_containment(P) -> error({gpb_error, {badproto, P}}). get_pkg_containment("kaa") -> undefined; get_pkg_containment(P) -> error({gpb_error, {badproto, P}}). get_service_containment("kaa") -> []; get_service_containment(P) -> error({gpb_error, {badproto, P}}). get_rpc_containment("kaa") -> []; get_rpc_containment(P) -> error({gpb_error, {badproto, P}}). get_enum_containment("kaa") -> [funs, mods]; get_enum_containment(P) -> error({gpb_error, {badproto, P}}). get_proto_by_msg_name_as_fqbin(<<"Kaa">>) -> "kaa"; get_proto_by_msg_name_as_fqbin(<<"Keywords">>) -> "kaa"; get_proto_by_msg_name_as_fqbin(<<"m_frame">>) -> "kaa"; get_proto_by_msg_name_as_fqbin(<<"m_core">>) -> "kaa"; get_proto_by_msg_name_as_fqbin(<<"KeywordValue">>) -> "kaa"; get_proto_by_msg_name_as_fqbin(E) -> error({gpb_error, {badmsg, E}}). -spec get_proto_by_service_name_as_fqbin(_) -> no_return(). get_proto_by_service_name_as_fqbin(E) -> error({gpb_error, {badservice, E}}). get_proto_by_enum_name_as_fqbin(<<"mods">>) -> "kaa"; get_proto_by_enum_name_as_fqbin(<<"funs">>) -> "kaa"; get_proto_by_enum_name_as_fqbin(E) -> error({gpb_error, {badenum, E}}). -spec get_protos_by_pkg_name_as_fqbin(_) -> no_return(). get_protos_by_pkg_name_as_fqbin(E) -> error({gpb_error, {badpkg, E}}). gpb_version_as_string() -> "4.7.1". gpb_version_as_list() -> [4,7,1].