Module Dtc_pb.Dtcprotocol_piqi

module Dtcprotocol_piqi : sig ... end
module Encoding_request : sig ... end
module Encoding_response : sig ... end
module Logon_request : sig ... end
module Logon_response : sig ... end
module Logoff : sig ... end
module Heartbeat : sig ... end
module Market_data_feed_status : sig ... end
module Market_data_feed_symbol_status : sig ... end
module Trading_symbol_status : sig ... end
module Market_data_request : sig ... end
module Market_depth_request : sig ... end
module Market_data_reject : sig ... end
module Market_data_snapshot : sig ... end
module Market_data_snapshot_int : sig ... end
module Market_depth_snapshot_level : sig ... end
module Market_depth_snapshot_level_int : sig ... end
module Market_depth_update_level : sig ... end
module Market_depth_update_level_int : sig ... end
module Market_data_update_session_open : sig ... end
module Market_depth_reject : sig ... end
module Market_data_update_trade : sig ... end
module Market_data_update_trade_int : sig ... end
module Market_data_update_bid_ask : sig ... end
module Market_data_update_bid_ask2 : sig ... end
module Market_data_update_bid_ask_int : sig ... end
module Market_data_update_session_high : sig ... end
module Market_data_update_session_low : sig ... end
module Submit_new_single_order : sig ... end
module Submit_new_single_order_int : sig ... end
module Submit_flatten_position_order : sig ... end
module Cancel_replace_order : sig ... end
module Cancel_replace_order_int : sig ... end
module Cancel_order : sig ... end
module Submit_new_ocoorder : sig ... end
module Submit_new_ocoorder_int : sig ... end
module Open_orders_request : sig ... end
module Historical_order_fills_request : sig ... end
module Historical_order_fills_reject : sig ... end
module Current_positions_request : sig ... end
module Current_positions_reject : sig ... end
module Order_update : sig ... end
module Open_orders_reject : sig ... end
module Historical_order_fill_response : sig ... end
module Position_update : sig ... end
module Trade_accounts_request : sig ... end
module Trade_account_response : sig ... end
module Exchange_list_request : sig ... end
module Exchange_list_response : sig ... end
module Symbols_for_exchange_request : sig ... end
module Symbols_for_underlying_request : sig ... end
module Symbol_search_request : sig ... end
module Security_definition_response : sig ... end
module Security_definition_reject : sig ... end
module Account_balance_request : sig ... end
module Account_balance_reject : sig ... end
module Account_balance_update : sig ... end
module Account_balance_adjustment : sig ... end
module User_message : sig ... end
module General_log_message : sig ... end
module Journal_entry_add : sig ... end
module Journal_entries_request : sig ... end
module Journal_entries_reject : sig ... end
module Journal_entry_response : sig ... end
module Alert_message : sig ... end
module Historical_price_data_request : sig ... end
module Historical_price_data_reject : sig ... end
val parse_int32 : Piqirun.t -> int32
val packed_parse_int32 : Piqirun.IBuf.t -> int32
val parse_int64 : Piqirun.t -> int64
val packed_parse_int64 : Piqirun.IBuf.t -> int64
val parse_protobuf_int32 : Piqirun.t -> Dtcprotocol_piqi.protobuf_int32
val packed_parse_protobuf_int32 : Piqirun.IBuf.t -> int32
val parse_string : Piqirun.t -> string
val parse_bool : Piqirun.t -> bool
val packed_parse_bool : Piqirun.IBuf.t -> bool
val parse_uint32 : Piqirun.t -> Dtcprotocol_piqi.uint32
val packed_parse_uint32 : Piqirun.IBuf.t -> int32
val parse_int64_fixed : Piqirun.t -> Dtcprotocol_piqi.int64_fixed
val packed_parse_int64_fixed : Piqirun.IBuf.t -> int64
val parse_float64 : Piqirun.t -> Dtcprotocol_piqi.float64
val packed_parse_float64 : Piqirun.IBuf.t -> float
val parse_float32 : Piqirun.t -> Dtcprotocol_piqi.float32
val packed_parse_float32 : Piqirun.IBuf.t -> float
val parse_protobuf_int64 : Piqirun.t -> Dtcprotocol_piqi.protobuf_int64
val packed_parse_protobuf_int64 : Piqirun.IBuf.t -> int64
val parse_int32_fixed : Piqirun.t -> Dtcprotocol_piqi.int32_fixed
val packed_parse_int32_fixed : Piqirun.IBuf.t -> int32
val parse_uint64 : Piqirun.t -> Dtcprotocol_piqi.uint64
val packed_parse_uint64 : Piqirun.IBuf.t -> int64
val parse_encoding_request : Piqirun.t -> Encoding_request.t
val parse_encoding_response : Piqirun.t -> Encoding_response.t
val parse_logon_request : Piqirun.t -> Logon_request.t
val parse_logon_response : Piqirun.t -> Logon_response.t
val parse_logoff : Piqirun.t -> Logoff.t
val parse_heartbeat : Piqirun.t -> Heartbeat.t
val parse_market_data_feed_status : Piqirun.t -> Market_data_feed_status.t
val parse_market_data_feed_symbol_status : Piqirun.t -> Market_data_feed_symbol_status.t
val parse_trading_symbol_status : Piqirun.t -> Trading_symbol_status.t
val parse_market_data_request : Piqirun.t -> Market_data_request.t
val parse_market_depth_request : Piqirun.t -> Market_depth_request.t
val parse_market_data_reject : Piqirun.t -> Market_data_reject.t
val parse_market_data_snapshot : Piqirun.t -> Market_data_snapshot.t
val parse_market_data_snapshot_int : Piqirun.t -> Market_data_snapshot_int.t
val parse_market_depth_snapshot_level : Piqirun.t -> Market_depth_snapshot_level.t
val parse_market_depth_snapshot_level_float : Piqirun.t -> Market_depth_snapshot_level_float.t
val parse_market_depth_snapshot_level_int : Piqirun.t -> Market_depth_snapshot_level_int.t
val parse_market_depth_update_level : Piqirun.t -> Market_depth_update_level.t
val parse_market_depth_update_level_int : Piqirun.t -> Market_depth_update_level_int.t
val parse_market_depth_update_level_float_with_milliseconds : Piqirun.t -> Market_depth_update_level_float_with_milliseconds.t
val parse_market_depth_update_level_no_timestamp : Piqirun.t -> Market_depth_update_level_no_timestamp.t
val parse_market_data_update_session_settlement : Piqirun.t -> Market_data_update_session_settlement.t
val parse_market_data_update_session_settlement_int : Piqirun.t -> Market_data_update_session_settlement_int.t
val parse_market_data_update_session_open : Piqirun.t -> Market_data_update_session_open.t
val parse_market_data_update_session_open_int : Piqirun.t -> Market_data_update_session_open_int.t
val parse_market_data_update_session_num_trades : Piqirun.t -> Market_data_update_session_num_trades.t
val parse_market_data_update_trading_session_date : Piqirun.t -> Market_data_update_trading_session_date.t
val parse_market_depth_reject : Piqirun.t -> Market_depth_reject.t
val parse_market_data_update_trade : Piqirun.t -> Market_data_update_trade.t
val parse_market_data_update_trade_compact : Piqirun.t -> Market_data_update_trade_compact.t
val parse_market_data_update_trade_int : Piqirun.t -> Market_data_update_trade_int.t
val parse_market_data_update_last_trade_snapshot : Piqirun.t -> Market_data_update_last_trade_snapshot.t
val parse_market_data_update_trade_with_unbundled_indicator : Piqirun.t -> Market_data_update_trade_with_unbundled_indicator.t
val parse_market_data_update_trade_no_timestamp : Piqirun.t -> Market_data_update_trade_no_timestamp.t
val parse_market_data_update_bid_ask : Piqirun.t -> Market_data_update_bid_ask.t
val parse_market_data_update_bid_ask2 : Piqirun.t -> Market_data_update_bid_ask2.t
val parse_market_data_update_bid_ask_int : Piqirun.t -> Market_data_update_bid_ask_int.t
val parse_market_data_update_bid_ask_compact : Piqirun.t -> Market_data_update_bid_ask_compact.t
val parse_market_data_update_bid_ask_no_time_stamp : Piqirun.t -> Market_data_update_bid_ask_no_time_stamp.t
val parse_market_data_update_session_volume : Piqirun.t -> Market_data_update_session_volume.t
val parse_market_data_update_open_interest : Piqirun.t -> Market_data_update_open_interest.t
val parse_market_data_update_session_high : Piqirun.t -> Market_data_update_session_high.t
val parse_market_data_update_session_high_int : Piqirun.t -> Market_data_update_session_high_int.t
val parse_market_data_update_session_low : Piqirun.t -> Market_data_update_session_low.t
val parse_market_data_update_session_low_int : Piqirun.t -> Market_data_update_session_low_int.t
val parse_submit_new_single_order : Piqirun.t -> Submit_new_single_order.t
val parse_submit_new_single_order_int : Piqirun.t -> Submit_new_single_order_int.t
val parse_submit_flatten_position_order : Piqirun.t -> Submit_flatten_position_order.t
val parse_cancel_replace_order : Piqirun.t -> Cancel_replace_order.t
val parse_cancel_replace_order_int : Piqirun.t -> Cancel_replace_order_int.t
val parse_cancel_order : Piqirun.t -> Cancel_order.t
val parse_submit_new_ocoorder : Piqirun.t -> Submit_new_ocoorder.t
val parse_submit_new_ocoorder_int : Piqirun.t -> Submit_new_ocoorder_int.t
val parse_open_orders_request : Piqirun.t -> Open_orders_request.t
val parse_historical_order_fills_request : Piqirun.t -> Historical_order_fills_request.t
val parse_historical_order_fills_reject : Piqirun.t -> Historical_order_fills_reject.t
val parse_current_positions_request : Piqirun.t -> Current_positions_request.t
val parse_current_positions_reject : Piqirun.t -> Current_positions_reject.t
val parse_order_update : Piqirun.t -> Order_update.t
val parse_open_orders_reject : Piqirun.t -> Open_orders_reject.t
val parse_historical_order_fill_response : Piqirun.t -> Historical_order_fill_response.t
val parse_position_update : Piqirun.t -> Position_update.t
val parse_trade_accounts_request : Piqirun.t -> Trade_accounts_request.t
val parse_trade_account_response : Piqirun.t -> Trade_account_response.t
val parse_exchange_list_request : Piqirun.t -> Exchange_list_request.t
val parse_exchange_list_response : Piqirun.t -> Exchange_list_response.t
val parse_symbols_for_exchange_request : Piqirun.t -> Symbols_for_exchange_request.t
val parse_underlying_symbols_for_exchange_request : Piqirun.t -> Underlying_symbols_for_exchange_request.t
val parse_symbols_for_underlying_request : Piqirun.t -> Symbols_for_underlying_request.t
val parse_symbol_search_request : Piqirun.t -> Symbol_search_request.t
val parse_security_definition_for_symbol_request : Piqirun.t -> Security_definition_for_symbol_request.t
val parse_security_definition_response : Piqirun.t -> Security_definition_response.t
val parse_security_definition_reject : Piqirun.t -> Security_definition_reject.t
val parse_account_balance_request : Piqirun.t -> Account_balance_request.t
val parse_account_balance_reject : Piqirun.t -> Account_balance_reject.t
val parse_account_balance_update : Piqirun.t -> Account_balance_update.t
val parse_account_balance_adjustment : Piqirun.t -> Account_balance_adjustment.t
val parse_account_balance_adjustment_reject : Piqirun.t -> Account_balance_adjustment_reject.t
val parse_account_balance_adjustment_complete : Piqirun.t -> Account_balance_adjustment_complete.t
val parse_historical_account_balances_request : Piqirun.t -> Historical_account_balances_request.t
val parse_historical_account_balances_reject : Piqirun.t -> Historical_account_balances_reject.t
val parse_historical_account_balance_response : Piqirun.t -> Historical_account_balance_response.t
val parse_user_message : Piqirun.t -> User_message.t
val parse_general_log_message : Piqirun.t -> General_log_message.t
val parse_journal_entry_add : Piqirun.t -> Journal_entry_add.t
val parse_journal_entries_request : Piqirun.t -> Journal_entries_request.t
val parse_journal_entries_reject : Piqirun.t -> Journal_entries_reject.t
val parse_journal_entry_response : Piqirun.t -> Journal_entry_response.t
val parse_alert_message : Piqirun.t -> Alert_message.t
val parse_historical_price_data_request : Piqirun.t -> Historical_price_data_request.t
val parse_historical_price_data_response_header : Piqirun.t -> Historical_price_data_response_header.t
val parse_historical_price_data_reject : Piqirun.t -> Historical_price_data_reject.t
val parse_historical_price_data_record_response : Piqirun.t -> Historical_price_data_record_response.t
val parse_historical_price_data_tick_record_response : Piqirun.t -> Historical_price_data_tick_record_response.t
val parse_historical_price_data_record_response_int : Piqirun.t -> Historical_price_data_record_response_int.t
val parse_historical_price_data_tick_record_response_int : Piqirun.t -> Historical_price_data_tick_record_response_int.t
val parse_historical_price_data_response_trailer : Piqirun.t -> Historical_price_data_response_trailer.t
val parse_dtcversion : Piqirun.t -> [> `current_version | `dtc_version_unset ]
val packed_parse_dtcversion : Piqirun.IBuf.t -> [> `current_version | `dtc_version_unset ]
val parse_dtcmessage_type : Piqirun.t -> [> `account_balance_adjustment | `account_balance_adjustment_complete | `account_balance_adjustment_reject | `account_balance_reject | `account_balance_request | `account_balance_update | `alert_message | `cancel_order | `cancel_replace_order | `cancel_replace_order_int | `current_positions_reject | `current_positions_request | `encoding_request | `encoding_response | `exchange_list_request | `exchange_list_response | `general_log_message | `heartbeat | `historical_account_balance_response | `historical_account_balances_reject | `historical_account_balances_request | `historical_order_fill_response | `historical_order_fills_reject | `historical_order_fills_request | `historical_price_data_record_response | `historical_price_data_record_response_int | `historical_price_data_reject | `historical_price_data_request | `historical_price_data_response_header | `historical_price_data_tick_record_response | `historical_price_data_tick_record_response_int | `journal_entries_reject | `journal_entries_request | `journal_entry_add | `journal_entry_response | `logoff | `logon_request | `logon_response | `market_data_feed_status | `market_data_feed_symbol_status | `market_data_reject | `market_data_request | `market_data_snapshot | `market_data_snapshot_int | `market_data_update_bid_ask | `market_data_update_bid_ask_compact | `market_data_update_bid_ask_int | `market_data_update_bid_ask_no_timestamp | `market_data_update_last_trade_snapshot | `market_data_update_open_interest | `market_data_update_session_high | `market_data_update_session_high_int | `market_data_update_session_low | `market_data_update_session_low_int | `market_data_update_session_num_trades | `market_data_update_session_open | `market_data_update_session_open_int | `market_data_update_session_settlement | `market_data_update_session_settlement_int | `market_data_update_session_volume | `market_data_update_trade | `market_data_update_trade_compact | `market_data_update_trade_int | `market_data_update_trade_no_timestamp | `market_data_update_trade_with_unbundled_indicator | `market_data_update_trading_session_date | `market_depth_reject | `market_depth_request | `market_depth_snapshot_level | `market_depth_snapshot_level_float | `market_depth_snapshot_level_int | `market_depth_update_level | `market_depth_update_level_float_with_milliseconds | `market_depth_update_level_int | `market_depth_update_level_no_timestamp | `message_type_unset | `open_orders_reject | `open_orders_request | `order_update | `position_update | `security_definition_for_symbol_request | `security_definition_reject | `security_definition_response | `submit_flatten_position_order | `submit_new_oco_order | `submit_new_oco_order_int | `submit_new_single_order | `submit_new_single_order_int | `symbol_search_request | `symbols_for_exchange_request | `symbols_for_underlying_request | `trade_account_response | `trade_accounts_request | `trading_symbol_status | `underlying_symbols_for_exchange_request | `user_message ]
val packed_parse_dtcmessage_type : Piqirun.IBuf.t -> [> `account_balance_adjustment | `account_balance_adjustment_complete | `account_balance_adjustment_reject | `account_balance_reject | `account_balance_request | `account_balance_update | `alert_message | `cancel_order | `cancel_replace_order | `cancel_replace_order_int | `current_positions_reject | `current_positions_request | `encoding_request | `encoding_response | `exchange_list_request | `exchange_list_response | `general_log_message | `heartbeat | `historical_account_balance_response | `historical_account_balances_reject | `historical_account_balances_request | `historical_order_fill_response | `historical_order_fills_reject | `historical_order_fills_request | `historical_price_data_record_response | `historical_price_data_record_response_int | `historical_price_data_reject | `historical_price_data_request | `historical_price_data_response_header | `historical_price_data_tick_record_response | `historical_price_data_tick_record_response_int | `journal_entries_reject | `journal_entries_request | `journal_entry_add | `journal_entry_response | `logoff | `logon_request | `logon_response | `market_data_feed_status | `market_data_feed_symbol_status | `market_data_reject | `market_data_request | `market_data_snapshot | `market_data_snapshot_int | `market_data_update_bid_ask | `market_data_update_bid_ask_compact | `market_data_update_bid_ask_int | `market_data_update_bid_ask_no_timestamp | `market_data_update_last_trade_snapshot | `market_data_update_open_interest | `market_data_update_session_high | `market_data_update_session_high_int | `market_data_update_session_low | `market_data_update_session_low_int | `market_data_update_session_num_trades | `market_data_update_session_open | `market_data_update_session_open_int | `market_data_update_session_settlement | `market_data_update_session_settlement_int | `market_data_update_session_volume | `market_data_update_trade | `market_data_update_trade_compact | `market_data_update_trade_int | `market_data_update_trade_no_timestamp | `market_data_update_trade_with_unbundled_indicator | `market_data_update_trading_session_date | `market_depth_reject | `market_depth_request | `market_depth_snapshot_level | `market_depth_snapshot_level_float | `market_depth_snapshot_level_int | `market_depth_update_level | `market_depth_update_level_float_with_milliseconds | `market_depth_update_level_int | `market_depth_update_level_no_timestamp | `message_type_unset | `open_orders_reject | `open_orders_request | `order_update | `position_update | `security_definition_for_symbol_request | `security_definition_reject | `security_definition_response | `submit_flatten_position_order | `submit_new_oco_order | `submit_new_oco_order_int | `submit_new_single_order | `submit_new_single_order_int | `symbol_search_request | `symbols_for_exchange_request | `symbols_for_underlying_request | `trade_account_response | `trade_accounts_request | `trading_symbol_status | `underlying_symbols_for_exchange_request | `user_message ]
val parse_encoding_enum : Piqirun.t -> Dtcprotocol_piqi.encoding_enum
val packed_parse_encoding_enum : Piqirun.IBuf.t -> [> `binary_encoding | `binary_with_variable_length_strings | `json_compact_encoding | `json_encoding | `protocol_buffers ]
val parse_logon_status_enum : Piqirun.t -> Dtcprotocol_piqi.logon_status_enum
val packed_parse_logon_status_enum : Piqirun.IBuf.t -> [> `logon_error | `logon_error_no_reconnect | `logon_reconnect_new_address | `logon_status_unset | `logon_success ]
val parse_message_supported_enum : Piqirun.t -> [> `message_supported | `message_unsupported ]
val packed_parse_message_supported_enum : Piqirun.IBuf.t -> [> `message_supported | `message_unsupported ]
val parse_trade_mode_enum : Piqirun.t -> Dtcprotocol_piqi.trade_mode_enum
val packed_parse_trade_mode_enum : Piqirun.IBuf.t -> [> `trade_mode_demo | `trade_mode_live | `trade_mode_simulated | `trade_mode_unset ]
val parse_request_action_enum : Piqirun.t -> Dtcprotocol_piqi.request_action_enum
val packed_parse_request_action_enum : Piqirun.IBuf.t -> [> `request_action_unset | `snapshot | `subscribe | `unsubscribe ]
val parse_unbundled_trade_indicator_enum : Piqirun.t -> Dtcprotocol_piqi.unbundled_trade_indicator_enum
val packed_parse_unbundled_trade_indicator_enum : Piqirun.IBuf.t -> [> `first_sub_trade_of_unbundled_trade | `last_sub_trade_of_unbundled_trade | `unbundled_trade_none ]
val parse_order_status_enum : Piqirun.t -> Dtcprotocol_piqi.order_status_enum
val packed_parse_order_status_enum : Piqirun.IBuf.t -> [> `order_status_canceled | `order_status_filled | `order_status_open | `order_status_order_sent | `order_status_partially_filled | `order_status_pending_cancel | `order_status_pending_cancel_replace | `order_status_pending_child | `order_status_pending_open | `order_status_rejected | `order_status_unspecified ]
val parse_order_update_reason_enum : Piqirun.t -> Dtcprotocol_piqi.order_update_reason_enum
val packed_parse_order_update_reason_enum : Piqirun.IBuf.t -> [> `general_order_update | `new_order_accepted | `new_order_rejected | `open_orders_request_response | `order_cancel_rejected | `order_cancel_replace_complete | `order_cancel_replace_rejected | `order_canceled | `order_filled | `order_filled_partially | `order_update_reason_unset ]
val parse_at_bid_or_ask_enum : Piqirun.t -> Dtcprotocol_piqi.at_bid_or_ask_enum
val packed_parse_at_bid_or_ask_enum : Piqirun.IBuf.t -> [> `at_ask | `at_bid | `bid_ask_unset ]
val parse_at_bid_or_ask_enum8 : Piqirun.t -> Dtcprotocol_piqi.at_bid_or_ask_enum8
val packed_parse_at_bid_or_ask_enum8 : Piqirun.IBuf.t -> [> `at_ask_8 | `at_bid_8 | `bid_ask_unset_8 ]
val parse_market_depth_update_type_enum : Piqirun.t -> Dtcprotocol_piqi.market_depth_update_type_enum
val packed_parse_market_depth_update_type_enum : Piqirun.IBuf.t -> [> `depth_unset | `market_depth_delete_level | `market_depth_insert_update_level ]
val parse_final_update_in_batch_enum : Piqirun.t -> Dtcprotocol_piqi.final_update_in_batch_enum
val packed_parse_final_update_in_batch_enum : Piqirun.IBuf.t -> [> `final_update_begin_batch | `final_update_false | `final_update_true | `final_update_unset ]
val parse_order_type_enum : Piqirun.t -> Dtcprotocol_piqi.order_type_enum
val packed_parse_order_type_enum : Piqirun.IBuf.t -> [> `order_type_limit | `order_type_limit_if_touched | `order_type_market | `order_type_market_if_touched | `order_type_stop | `order_type_stop_limit | `order_type_unset ]
val parse_time_in_force_enum : Piqirun.t -> Dtcprotocol_piqi.time_in_force_enum
val packed_parse_time_in_force_enum : Piqirun.IBuf.t -> [> `tif_all_or_none | `tif_day | `tif_fill_or_kill | `tif_good_till_canceled | `tif_good_till_date_time | `tif_immediate_or_cancel | `tif_unset ]
val parse_buy_sell_enum : Piqirun.t -> Dtcprotocol_piqi.buy_sell_enum
val packed_parse_buy_sell_enum : Piqirun.IBuf.t -> [> `buy | `buy_sell_unset | `sell ]
val parse_open_close_trade_enum : Piqirun.t -> Dtcprotocol_piqi.open_close_trade_enum
val packed_parse_open_close_trade_enum : Piqirun.IBuf.t -> [> `trade_close | `trade_open | `trade_unset ]
val parse_partial_fill_handling_enum : Piqirun.t -> Dtcprotocol_piqi.partial_fill_handling_enum
val packed_parse_partial_fill_handling_enum : Piqirun.IBuf.t -> [> `partial_fill_handling_immediate_cancel | `partial_fill_handling_reduce_quantity | `partial_fill_unset ]
val parse_market_data_feed_status_enum : Piqirun.t -> Dtcprotocol_piqi.market_data_feed_status_enum
val packed_parse_market_data_feed_status_enum : Piqirun.IBuf.t -> [> `market_data_feed_available | `market_data_feed_status_unset | `market_data_feed_unavailable ]
val parse_price_display_format_enum : Piqirun.t -> Dtcprotocol_piqi.price_display_format_enum
val packed_parse_price_display_format_enum : Piqirun.IBuf.t -> [> `price_display_format_decimal_0 | `price_display_format_decimal_1 | `price_display_format_decimal_2 | `price_display_format_decimal_3 | `price_display_format_decimal_4 | `price_display_format_decimal_5 | `price_display_format_decimal_6 | `price_display_format_decimal_7 | `price_display_format_decimal_8 | `price_display_format_decimal_9 | `price_display_format_denominator_128 | `price_display_format_denominator_16 | `price_display_format_denominator_2 | `price_display_format_denominator_256 | `price_display_format_denominator_32 | `price_display_format_denominator_32_halves | `price_display_format_denominator_32_quarters | `price_display_format_denominator_4 | `price_display_format_denominator_64 | `price_display_format_denominator_8 | `price_display_format_unset ]
val parse_security_type_enum : Piqirun.t -> Dtcprotocol_piqi.security_type_enum
val packed_parse_security_type_enum : Piqirun.IBuf.t -> [> `security_type_bond | `security_type_forex | `security_type_future | `security_type_futures_option | `security_type_futures_strategy | `security_type_index | `security_type_index_option | `security_type_mutual_fund | `security_type_stock | `security_type_stock_option | `security_type_unset ]
val parse_put_call_enum : Piqirun.t -> Dtcprotocol_piqi.put_call_enum
val packed_parse_put_call_enum : Piqirun.IBuf.t -> [> `pc_call | `pc_put | `pc_unset ]
val parse_search_type_enum : Piqirun.t -> Dtcprotocol_piqi.search_type_enum
val packed_parse_search_type_enum : Piqirun.IBuf.t -> [> `search_type_by_description | `search_type_by_symbol | `search_type_unset ]
val parse_historical_data_interval_enum : Piqirun.t -> Dtcprotocol_piqi.historical_data_interval_enum
val packed_parse_historical_data_interval_enum : Piqirun.IBuf.t -> [> `interval_10_minute | `interval_10_seconds | `interval_15_minute | `interval_1_day | `interval_1_hour | `interval_1_minute | `interval_1_second | `interval_1_week | `interval_2_hours | `interval_2_seconds | `interval_30_minute | `interval_30_seconds | `interval_4_seconds | `interval_5_minute | `interval_5_seconds | `interval_tick ]
val parse_historical_price_data_reject_reason_code_enum : Piqirun.t -> Dtcprotocol_piqi.historical_price_data_reject_reason_code_enum
val packed_parse_historical_price_data_reject_reason_code_enum : Piqirun.IBuf.t -> [> `hpdr_data_request_outside_bounds_of_available_data | `hpdr_general_reject_error | `hpdr_unable_to_serve_data_do_not_retry | `hpdr_unable_to_serve_data_retry_later | `hpdr_unset ]
val parse_trading_status_enum : Piqirun.t -> Dtcprotocol_piqi.trading_status_enum
val packed_parse_trading_status_enum : Piqirun.IBuf.t -> [> `trading_status_close | `trading_status_open | `trading_status_pre_open | `trading_status_trading_halt | `trading_status_unknown ]
val gen__int32 : int -> int32 -> Piqirun.OBuf.t
val packed_gen__int32 : int32 -> Piqirun.OBuf.t
val gen__int64 : int -> int64 -> Piqirun.OBuf.t
val packed_gen__int64 : int64 -> Piqirun.OBuf.t
val gen__protobuf_int32 : int -> Stdlib.Int32.t -> Piqirun.OBuf.t
val packed_gen__protobuf_int32 : Stdlib.Int32.t -> Piqirun.OBuf.t
val gen__string : int -> string -> Piqirun.OBuf.t
val gen__bool : int -> bool -> Piqirun.OBuf.t
val packed_gen__bool : bool -> Piqirun.OBuf.t
val gen__uint32 : int -> Dtcprotocol_piqi.uint32 -> Piqirun.OBuf.t
val packed_gen__uint32 : int32 -> Piqirun.OBuf.t
val gen__int64_fixed : int -> Dtcprotocol_piqi.int64_fixed -> Piqirun.OBuf.t
val packed_gen__int64_fixed : int64 -> Piqirun.OBuf.t
val gen__float64 : int -> Dtcprotocol_piqi.float64 -> Piqirun.OBuf.t
val packed_gen__float64 : float -> Piqirun.OBuf.t
val gen__float32 : int -> Dtcprotocol_piqi.float32 -> Piqirun.OBuf.t
val packed_gen__float32 : float -> Piqirun.OBuf.t
val gen__protobuf_int64 : int -> Dtcprotocol_piqi.protobuf_int64 -> Piqirun.OBuf.t
val packed_gen__protobuf_int64 : int64 -> Piqirun.OBuf.t
val gen__int32_fixed : int -> Dtcprotocol_piqi.int32_fixed -> Piqirun.OBuf.t
val packed_gen__int32_fixed : int32 -> Piqirun.OBuf.t
val gen__uint64 : int -> Dtcprotocol_piqi.uint64 -> Piqirun.OBuf.t
val packed_gen__uint64 : int64 -> Piqirun.OBuf.t
val gen__encoding_request : int -> Encoding_request.t -> Piqirun.OBuf.t
val gen__encoding_response : int -> Encoding_response.t -> Piqirun.OBuf.t
val gen__logon_request : int -> Logon_request.t -> Piqirun.OBuf.t
val gen__logon_response : int -> Logon_response.t -> Piqirun.OBuf.t
val gen__logoff : int -> Logoff.t -> Piqirun.OBuf.t
val gen__heartbeat : int -> Heartbeat.t -> Piqirun.OBuf.t
val gen__market_data_feed_status : int -> Market_data_feed_status.t -> Piqirun.OBuf.t
val gen__market_data_feed_symbol_status : int -> Market_data_feed_symbol_status.t -> Piqirun.OBuf.t
val gen__trading_symbol_status : int -> Trading_symbol_status.t -> Piqirun.OBuf.t
val gen__market_data_request : int -> Market_data_request.t -> Piqirun.OBuf.t
val gen__market_depth_request : int -> Market_depth_request.t -> Piqirun.OBuf.t
val gen__market_data_reject : int -> Market_data_reject.t -> Piqirun.OBuf.t
val gen__market_data_snapshot : int -> Market_data_snapshot.t -> Piqirun.OBuf.t
val gen__market_data_snapshot_int : int -> Market_data_snapshot_int.t -> Piqirun.OBuf.t
val gen__market_depth_snapshot_level : int -> Market_depth_snapshot_level.t -> Piqirun.OBuf.t
val gen__market_depth_snapshot_level_float : int -> Market_depth_snapshot_level_float.t -> Piqirun.OBuf.t
val gen__market_depth_snapshot_level_int : int -> Market_depth_snapshot_level_int.t -> Piqirun.OBuf.t
val gen__market_depth_update_level : int -> Market_depth_update_level.t -> Piqirun.OBuf.t
val gen__market_depth_update_level_int : int -> Market_depth_update_level_int.t -> Piqirun.OBuf.t
val gen__market_depth_update_level_float_with_milliseconds : int -> Market_depth_update_level_float_with_milliseconds.t -> Piqirun.OBuf.t
val gen__market_depth_update_level_no_timestamp : int -> Market_depth_update_level_no_timestamp.t -> Piqirun.OBuf.t
val gen__market_data_update_session_settlement : int -> Market_data_update_session_settlement.t -> Piqirun.OBuf.t
val gen__market_data_update_session_settlement_int : int -> Market_data_update_session_settlement_int.t -> Piqirun.OBuf.t
val gen__market_data_update_session_open : int -> Market_data_update_session_open.t -> Piqirun.OBuf.t
val gen__market_data_update_session_open_int : int -> Market_data_update_session_open_int.t -> Piqirun.OBuf.t
val gen__market_data_update_session_num_trades : int -> Market_data_update_session_num_trades.t -> Piqirun.OBuf.t
val gen__market_data_update_trading_session_date : int -> Market_data_update_trading_session_date.t -> Piqirun.OBuf.t
val gen__market_depth_reject : int -> Market_depth_reject.t -> Piqirun.OBuf.t
val gen__market_data_update_trade : int -> Market_data_update_trade.t -> Piqirun.OBuf.t
val gen__market_data_update_trade_compact : int -> Market_data_update_trade_compact.t -> Piqirun.OBuf.t
val gen__market_data_update_trade_int : int -> Market_data_update_trade_int.t -> Piqirun.OBuf.t
val gen__market_data_update_last_trade_snapshot : int -> Market_data_update_last_trade_snapshot.t -> Piqirun.OBuf.t
val gen__market_data_update_trade_with_unbundled_indicator : int -> Market_data_update_trade_with_unbundled_indicator.t -> Piqirun.OBuf.t
val gen__market_data_update_trade_no_timestamp : int -> Market_data_update_trade_no_timestamp.t -> Piqirun.OBuf.t
val gen__market_data_update_bid_ask : int -> Market_data_update_bid_ask.t -> Piqirun.OBuf.t
val gen__market_data_update_bid_ask2 : int -> Market_data_update_bid_ask2.t -> Piqirun.OBuf.t
val gen__market_data_update_bid_ask_int : int -> Market_data_update_bid_ask_int.t -> Piqirun.OBuf.t
val gen__market_data_update_bid_ask_compact : int -> Market_data_update_bid_ask_compact.t -> Piqirun.OBuf.t
val gen__market_data_update_bid_ask_no_time_stamp : int -> Market_data_update_bid_ask_no_time_stamp.t -> Piqirun.OBuf.t
val gen__market_data_update_session_volume : int -> Market_data_update_session_volume.t -> Piqirun.OBuf.t
val gen__market_data_update_open_interest : int -> Market_data_update_open_interest.t -> Piqirun.OBuf.t
val gen__market_data_update_session_high : int -> Market_data_update_session_high.t -> Piqirun.OBuf.t
val gen__market_data_update_session_high_int : int -> Market_data_update_session_high_int.t -> Piqirun.OBuf.t
val gen__market_data_update_session_low : int -> Market_data_update_session_low.t -> Piqirun.OBuf.t
val gen__market_data_update_session_low_int : int -> Market_data_update_session_low_int.t -> Piqirun.OBuf.t
val gen__submit_new_single_order : int -> Submit_new_single_order.t -> Piqirun.OBuf.t
val gen__submit_new_single_order_int : int -> Submit_new_single_order_int.t -> Piqirun.OBuf.t
val gen__submit_flatten_position_order : int -> Submit_flatten_position_order.t -> Piqirun.OBuf.t
val gen__cancel_replace_order : int -> Cancel_replace_order.t -> Piqirun.OBuf.t
val gen__cancel_replace_order_int : int -> Cancel_replace_order_int.t -> Piqirun.OBuf.t
val gen__cancel_order : int -> Cancel_order.t -> Piqirun.OBuf.t
val gen__submit_new_ocoorder : int -> Submit_new_ocoorder.t -> Piqirun.OBuf.t
val gen__submit_new_ocoorder_int : int -> Submit_new_ocoorder_int.t -> Piqirun.OBuf.t
val gen__open_orders_request : int -> Open_orders_request.t -> Piqirun.OBuf.t
val gen__historical_order_fills_request : int -> Historical_order_fills_request.t -> Piqirun.OBuf.t
val gen__historical_order_fills_reject : int -> Historical_order_fills_reject.t -> Piqirun.OBuf.t
val gen__current_positions_request : int -> Current_positions_request.t -> Piqirun.OBuf.t
val gen__current_positions_reject : int -> Current_positions_reject.t -> Piqirun.OBuf.t
val gen__order_update : int -> Order_update.t -> Piqirun.OBuf.t
val gen__open_orders_reject : int -> Open_orders_reject.t -> Piqirun.OBuf.t
val gen__historical_order_fill_response : int -> Historical_order_fill_response.t -> Piqirun.OBuf.t
val gen__position_update : int -> Position_update.t -> Piqirun.OBuf.t
val gen__trade_accounts_request : int -> Trade_accounts_request.t -> Piqirun.OBuf.t
val gen__trade_account_response : int -> Trade_account_response.t -> Piqirun.OBuf.t
val gen__exchange_list_request : int -> Exchange_list_request.t -> Piqirun.OBuf.t
val gen__exchange_list_response : int -> Exchange_list_response.t -> Piqirun.OBuf.t
val gen__symbols_for_exchange_request : int -> Symbols_for_exchange_request.t -> Piqirun.OBuf.t
val gen__underlying_symbols_for_exchange_request : int -> Underlying_symbols_for_exchange_request.t -> Piqirun.OBuf.t
val gen__symbols_for_underlying_request : int -> Symbols_for_underlying_request.t -> Piqirun.OBuf.t
val gen__symbol_search_request : int -> Symbol_search_request.t -> Piqirun.OBuf.t
val gen__security_definition_for_symbol_request : int -> Security_definition_for_symbol_request.t -> Piqirun.OBuf.t
val gen__security_definition_response : int -> Security_definition_response.t -> Piqirun.OBuf.t
val gen__security_definition_reject : int -> Security_definition_reject.t -> Piqirun.OBuf.t
val gen__account_balance_request : int -> Account_balance_request.t -> Piqirun.OBuf.t
val gen__account_balance_reject : int -> Account_balance_reject.t -> Piqirun.OBuf.t
val gen__account_balance_update : int -> Account_balance_update.t -> Piqirun.OBuf.t
val gen__account_balance_adjustment : int -> Account_balance_adjustment.t -> Piqirun.OBuf.t
val gen__account_balance_adjustment_reject : int -> Account_balance_adjustment_reject.t -> Piqirun.OBuf.t
val gen__account_balance_adjustment_complete : int -> Account_balance_adjustment_complete.t -> Piqirun.OBuf.t
val gen__historical_account_balances_request : int -> Historical_account_balances_request.t -> Piqirun.OBuf.t
val gen__historical_account_balances_reject : int -> Historical_account_balances_reject.t -> Piqirun.OBuf.t
val gen__historical_account_balance_response : int -> Historical_account_balance_response.t -> Piqirun.OBuf.t
val gen__user_message : int -> User_message.t -> Piqirun.OBuf.t
val gen__general_log_message : int -> General_log_message.t -> Piqirun.OBuf.t
val gen__journal_entry_add : int -> Journal_entry_add.t -> Piqirun.OBuf.t
val gen__journal_entries_request : int -> Journal_entries_request.t -> Piqirun.OBuf.t
val gen__journal_entries_reject : int -> Journal_entries_reject.t -> Piqirun.OBuf.t
val gen__journal_entry_response : int -> Journal_entry_response.t -> Piqirun.OBuf.t
val gen__alert_message : int -> Alert_message.t -> Piqirun.OBuf.t
val gen__historical_price_data_request : int -> Historical_price_data_request.t -> Piqirun.OBuf.t
val gen__historical_price_data_response_header : int -> Historical_price_data_response_header.t -> Piqirun.OBuf.t
val gen__historical_price_data_reject : int -> Historical_price_data_reject.t -> Piqirun.OBuf.t
val gen__historical_price_data_record_response : int -> Historical_price_data_record_response.t -> Piqirun.OBuf.t
val gen__historical_price_data_tick_record_response : int -> Historical_price_data_tick_record_response.t -> Piqirun.OBuf.t
val gen__historical_price_data_record_response_int : int -> Historical_price_data_record_response_int.t -> Piqirun.OBuf.t
val gen__historical_price_data_tick_record_response_int : int -> Historical_price_data_tick_record_response_int.t -> Piqirun.OBuf.t
val gen__historical_price_data_response_trailer : int -> Historical_price_data_response_trailer.t -> Piqirun.OBuf.t
val gen__dtcversion : int -> [< `current_version | `dtc_version_unset ] -> Piqirun.OBuf.t
val packed_gen__dtcversion : [< `current_version | `dtc_version_unset ] -> Piqirun.OBuf.t
val gen__dtcmessage_type : int -> [< `account_balance_adjustment | `account_balance_adjustment_complete | `account_balance_adjustment_reject | `account_balance_reject | `account_balance_request | `account_balance_update | `alert_message | `cancel_order | `cancel_replace_order | `cancel_replace_order_int | `current_positions_reject | `current_positions_request | `encoding_request | `encoding_response | `exchange_list_request | `exchange_list_response | `general_log_message | `heartbeat | `historical_account_balance_response | `historical_account_balances_reject | `historical_account_balances_request | `historical_order_fill_response | `historical_order_fills_reject | `historical_order_fills_request | `historical_price_data_record_response | `historical_price_data_record_response_int | `historical_price_data_reject | `historical_price_data_request | `historical_price_data_response_header | `historical_price_data_tick_record_response | `historical_price_data_tick_record_response_int | `journal_entries_reject | `journal_entries_request | `journal_entry_add | `journal_entry_response | `logoff | `logon_request | `logon_response | `market_data_feed_status | `market_data_feed_symbol_status | `market_data_reject | `market_data_request | `market_data_snapshot | `market_data_snapshot_int | `market_data_update_bid_ask | `market_data_update_bid_ask_compact | `market_data_update_bid_ask_int | `market_data_update_bid_ask_no_timestamp | `market_data_update_last_trade_snapshot | `market_data_update_open_interest | `market_data_update_session_high | `market_data_update_session_high_int | `market_data_update_session_low | `market_data_update_session_low_int | `market_data_update_session_num_trades | `market_data_update_session_open | `market_data_update_session_open_int | `market_data_update_session_settlement | `market_data_update_session_settlement_int | `market_data_update_session_volume | `market_data_update_trade | `market_data_update_trade_compact | `market_data_update_trade_int | `market_data_update_trade_no_timestamp | `market_data_update_trade_with_unbundled_indicator | `market_data_update_trading_session_date | `market_depth_reject | `market_depth_request | `market_depth_snapshot_level | `market_depth_snapshot_level_float | `market_depth_snapshot_level_int | `market_depth_update_level | `market_depth_update_level_float_with_milliseconds | `market_depth_update_level_int | `market_depth_update_level_no_timestamp | `message_type_unset | `open_orders_reject | `open_orders_request | `order_update | `position_update | `security_definition_for_symbol_request | `security_definition_reject | `security_definition_response | `submit_flatten_position_order | `submit_new_oco_order | `submit_new_oco_order_int | `submit_new_single_order | `submit_new_single_order_int | `symbol_search_request | `symbols_for_exchange_request | `symbols_for_underlying_request | `trade_account_response | `trade_accounts_request | `trading_symbol_status | `underlying_symbols_for_exchange_request | `user_message ] -> Piqirun.OBuf.t
val packed_gen__dtcmessage_type : [< `account_balance_adjustment | `account_balance_adjustment_complete | `account_balance_adjustment_reject | `account_balance_reject | `account_balance_request | `account_balance_update | `alert_message | `cancel_order | `cancel_replace_order | `cancel_replace_order_int | `current_positions_reject | `current_positions_request | `encoding_request | `encoding_response | `exchange_list_request | `exchange_list_response | `general_log_message | `heartbeat | `historical_account_balance_response | `historical_account_balances_reject | `historical_account_balances_request | `historical_order_fill_response | `historical_order_fills_reject | `historical_order_fills_request | `historical_price_data_record_response | `historical_price_data_record_response_int | `historical_price_data_reject | `historical_price_data_request | `historical_price_data_response_header | `historical_price_data_tick_record_response | `historical_price_data_tick_record_response_int | `journal_entries_reject | `journal_entries_request | `journal_entry_add | `journal_entry_response | `logoff | `logon_request | `logon_response | `market_data_feed_status | `market_data_feed_symbol_status | `market_data_reject | `market_data_request | `market_data_snapshot | `market_data_snapshot_int | `market_data_update_bid_ask | `market_data_update_bid_ask_compact | `market_data_update_bid_ask_int | `market_data_update_bid_ask_no_timestamp | `market_data_update_last_trade_snapshot | `market_data_update_open_interest | `market_data_update_session_high | `market_data_update_session_high_int | `market_data_update_session_low | `market_data_update_session_low_int | `market_data_update_session_num_trades | `market_data_update_session_open | `market_data_update_session_open_int | `market_data_update_session_settlement | `market_data_update_session_settlement_int | `market_data_update_session_volume | `market_data_update_trade | `market_data_update_trade_compact | `market_data_update_trade_int | `market_data_update_trade_no_timestamp | `market_data_update_trade_with_unbundled_indicator | `market_data_update_trading_session_date | `market_depth_reject | `market_depth_request | `market_depth_snapshot_level | `market_depth_snapshot_level_float | `market_depth_snapshot_level_int | `market_depth_update_level | `market_depth_update_level_float_with_milliseconds | `market_depth_update_level_int | `market_depth_update_level_no_timestamp | `message_type_unset | `open_orders_reject | `open_orders_request | `order_update | `position_update | `security_definition_for_symbol_request | `security_definition_reject | `security_definition_response | `submit_flatten_position_order | `submit_new_oco_order | `submit_new_oco_order_int | `submit_new_single_order | `submit_new_single_order_int | `symbol_search_request | `symbols_for_exchange_request | `symbols_for_underlying_request | `trade_account_response | `trade_accounts_request | `trading_symbol_status | `underlying_symbols_for_exchange_request | `user_message ] -> Piqirun.OBuf.t
val gen__encoding_enum : int -> Dtcprotocol_piqi.encoding_enum -> Piqirun.OBuf.t
val packed_gen__encoding_enum : [< `binary_encoding | `binary_with_variable_length_strings | `json_compact_encoding | `json_encoding | `protocol_buffers ] -> Piqirun.OBuf.t
val gen__logon_status_enum : int -> Dtcprotocol_piqi.logon_status_enum -> Piqirun.OBuf.t
val packed_gen__logon_status_enum : [< `logon_error | `logon_error_no_reconnect | `logon_reconnect_new_address | `logon_status_unset | `logon_success ] -> Piqirun.OBuf.t
val gen__message_supported_enum : int -> [< `message_supported | `message_unsupported ] -> Piqirun.OBuf.t
val packed_gen__message_supported_enum : [< `message_supported | `message_unsupported ] -> Piqirun.OBuf.t
val gen__trade_mode_enum : int -> Dtcprotocol_piqi.trade_mode_enum -> Piqirun.OBuf.t
val packed_gen__trade_mode_enum : [< `trade_mode_demo | `trade_mode_live | `trade_mode_simulated | `trade_mode_unset ] -> Piqirun.OBuf.t
val gen__request_action_enum : int -> Dtcprotocol_piqi.request_action_enum -> Piqirun.OBuf.t
val packed_gen__request_action_enum : [< `request_action_unset | `snapshot | `subscribe | `unsubscribe ] -> Piqirun.OBuf.t
val gen__unbundled_trade_indicator_enum : int -> Dtcprotocol_piqi.unbundled_trade_indicator_enum -> Piqirun.OBuf.t
val packed_gen__unbundled_trade_indicator_enum : [< `first_sub_trade_of_unbundled_trade | `last_sub_trade_of_unbundled_trade | `unbundled_trade_none ] -> Piqirun.OBuf.t
val gen__order_status_enum : int -> Dtcprotocol_piqi.order_status_enum -> Piqirun.OBuf.t
val packed_gen__order_status_enum : [< `order_status_canceled | `order_status_filled | `order_status_open | `order_status_order_sent | `order_status_partially_filled | `order_status_pending_cancel | `order_status_pending_cancel_replace | `order_status_pending_child | `order_status_pending_open | `order_status_rejected | `order_status_unspecified ] -> Piqirun.OBuf.t
val gen__order_update_reason_enum : int -> Dtcprotocol_piqi.order_update_reason_enum -> Piqirun.OBuf.t
val packed_gen__order_update_reason_enum : [< `general_order_update | `new_order_accepted | `new_order_rejected | `open_orders_request_response | `order_cancel_rejected | `order_cancel_replace_complete | `order_cancel_replace_rejected | `order_canceled | `order_filled | `order_filled_partially | `order_update_reason_unset ] -> Piqirun.OBuf.t
val gen__at_bid_or_ask_enum : int -> Dtcprotocol_piqi.at_bid_or_ask_enum -> Piqirun.OBuf.t
val packed_gen__at_bid_or_ask_enum : [< `at_ask | `at_bid | `bid_ask_unset ] -> Piqirun.OBuf.t
val gen__at_bid_or_ask_enum8 : int -> Dtcprotocol_piqi.at_bid_or_ask_enum8 -> Piqirun.OBuf.t
val packed_gen__at_bid_or_ask_enum8 : [< `at_ask_8 | `at_bid_8 | `bid_ask_unset_8 ] -> Piqirun.OBuf.t
val gen__market_depth_update_type_enum : int -> Dtcprotocol_piqi.market_depth_update_type_enum -> Piqirun.OBuf.t
val packed_gen__market_depth_update_type_enum : [< `depth_unset | `market_depth_delete_level | `market_depth_insert_update_level ] -> Piqirun.OBuf.t
val gen__final_update_in_batch_enum : int -> Dtcprotocol_piqi.final_update_in_batch_enum -> Piqirun.OBuf.t
val packed_gen__final_update_in_batch_enum : [< `final_update_begin_batch | `final_update_false | `final_update_true | `final_update_unset ] -> Piqirun.OBuf.t
val gen__order_type_enum : int -> Dtcprotocol_piqi.order_type_enum -> Piqirun.OBuf.t
val packed_gen__order_type_enum : [< `order_type_limit | `order_type_limit_if_touched | `order_type_market | `order_type_market_if_touched | `order_type_stop | `order_type_stop_limit | `order_type_unset ] -> Piqirun.OBuf.t
val gen__time_in_force_enum : int -> Dtcprotocol_piqi.time_in_force_enum -> Piqirun.OBuf.t
val packed_gen__time_in_force_enum : [< `tif_all_or_none | `tif_day | `tif_fill_or_kill | `tif_good_till_canceled | `tif_good_till_date_time | `tif_immediate_or_cancel | `tif_unset ] -> Piqirun.OBuf.t
val gen__buy_sell_enum : int -> Dtcprotocol_piqi.buy_sell_enum -> Piqirun.OBuf.t
val packed_gen__buy_sell_enum : [< `buy | `buy_sell_unset | `sell ] -> Piqirun.OBuf.t
val gen__open_close_trade_enum : int -> Dtcprotocol_piqi.open_close_trade_enum -> Piqirun.OBuf.t
val packed_gen__open_close_trade_enum : [< `trade_close | `trade_open | `trade_unset ] -> Piqirun.OBuf.t
val gen__partial_fill_handling_enum : int -> Dtcprotocol_piqi.partial_fill_handling_enum -> Piqirun.OBuf.t
val packed_gen__partial_fill_handling_enum : [< `partial_fill_handling_immediate_cancel | `partial_fill_handling_reduce_quantity | `partial_fill_unset ] -> Piqirun.OBuf.t
val gen__market_data_feed_status_enum : int -> Dtcprotocol_piqi.market_data_feed_status_enum -> Piqirun.OBuf.t
val packed_gen__market_data_feed_status_enum : [< `market_data_feed_available | `market_data_feed_status_unset | `market_data_feed_unavailable ] -> Piqirun.OBuf.t
val gen__price_display_format_enum : int -> Dtcprotocol_piqi.price_display_format_enum -> Piqirun.OBuf.t
val packed_gen__price_display_format_enum : [< `price_display_format_decimal_0 | `price_display_format_decimal_1 | `price_display_format_decimal_2 | `price_display_format_decimal_3 | `price_display_format_decimal_4 | `price_display_format_decimal_5 | `price_display_format_decimal_6 | `price_display_format_decimal_7 | `price_display_format_decimal_8 | `price_display_format_decimal_9 | `price_display_format_denominator_128 | `price_display_format_denominator_16 | `price_display_format_denominator_2 | `price_display_format_denominator_256 | `price_display_format_denominator_32 | `price_display_format_denominator_32_halves | `price_display_format_denominator_32_quarters | `price_display_format_denominator_4 | `price_display_format_denominator_64 | `price_display_format_denominator_8 | `price_display_format_unset ] -> Piqirun.OBuf.t
val gen__security_type_enum : int -> Dtcprotocol_piqi.security_type_enum -> Piqirun.OBuf.t
val packed_gen__security_type_enum : [< `security_type_bond | `security_type_forex | `security_type_future | `security_type_futures_option | `security_type_futures_strategy | `security_type_index | `security_type_index_option | `security_type_mutual_fund | `security_type_stock | `security_type_stock_option | `security_type_unset ] -> Piqirun.OBuf.t
val gen__put_call_enum : int -> Dtcprotocol_piqi.put_call_enum -> Piqirun.OBuf.t
val packed_gen__put_call_enum : [< `pc_call | `pc_put | `pc_unset ] -> Piqirun.OBuf.t
val gen__search_type_enum : int -> Dtcprotocol_piqi.search_type_enum -> Piqirun.OBuf.t
val packed_gen__search_type_enum : [< `search_type_by_description | `search_type_by_symbol | `search_type_unset ] -> Piqirun.OBuf.t
val gen__historical_data_interval_enum : int -> Dtcprotocol_piqi.historical_data_interval_enum -> Piqirun.OBuf.t
val packed_gen__historical_data_interval_enum : [< `interval_10_minute | `interval_10_seconds | `interval_15_minute | `interval_1_day | `interval_1_hour | `interval_1_minute | `interval_1_second | `interval_1_week | `interval_2_hours | `interval_2_seconds | `interval_30_minute | `interval_30_seconds | `interval_4_seconds | `interval_5_minute | `interval_5_seconds | `interval_tick ] -> Piqirun.OBuf.t
val gen__historical_price_data_reject_reason_code_enum : int -> Dtcprotocol_piqi.historical_price_data_reject_reason_code_enum -> Piqirun.OBuf.t
val packed_gen__historical_price_data_reject_reason_code_enum : [< `hpdr_data_request_outside_bounds_of_available_data | `hpdr_general_reject_error | `hpdr_unable_to_serve_data_do_not_retry | `hpdr_unable_to_serve_data_retry_later | `hpdr_unset ] -> Piqirun.OBuf.t
val gen__trading_status_enum : int -> Dtcprotocol_piqi.trading_status_enum -> Piqirun.OBuf.t
val packed_gen__trading_status_enum : [< `trading_status_close | `trading_status_open | `trading_status_pre_open | `trading_status_trading_halt | `trading_status_unknown ] -> Piqirun.OBuf.t
val gen_int32 : int32 -> Piqirun.OBuf.t
val gen_int64 : int64 -> Piqirun.OBuf.t
val gen_protobuf_int32 : Stdlib.Int32.t -> Piqirun.OBuf.t
val gen_string : string -> Piqirun.OBuf.t
val gen_bool : bool -> Piqirun.OBuf.t
val gen_uint32 : Dtcprotocol_piqi.uint32 -> Piqirun.OBuf.t
val gen_int64_fixed : Dtcprotocol_piqi.int64_fixed -> Piqirun.OBuf.t
val gen_float64 : Dtcprotocol_piqi.float64 -> Piqirun.OBuf.t
val gen_float32 : Dtcprotocol_piqi.float32 -> Piqirun.OBuf.t
val gen_protobuf_int64 : Dtcprotocol_piqi.protobuf_int64 -> Piqirun.OBuf.t
val gen_int32_fixed : Dtcprotocol_piqi.int32_fixed -> Piqirun.OBuf.t
val gen_uint64 : Dtcprotocol_piqi.uint64 -> Piqirun.OBuf.t
val gen_encoding_request : Encoding_request.t -> Piqirun.OBuf.t
val gen_encoding_response : Encoding_response.t -> Piqirun.OBuf.t
val gen_logon_request : Logon_request.t -> Piqirun.OBuf.t
val gen_logon_response : Logon_response.t -> Piqirun.OBuf.t
val gen_logoff : Logoff.t -> Piqirun.OBuf.t
val gen_heartbeat : Heartbeat.t -> Piqirun.OBuf.t
val gen_market_data_feed_status : Market_data_feed_status.t -> Piqirun.OBuf.t
val gen_market_data_feed_symbol_status : Market_data_feed_symbol_status.t -> Piqirun.OBuf.t
val gen_trading_symbol_status : Trading_symbol_status.t -> Piqirun.OBuf.t
val gen_market_data_request : Market_data_request.t -> Piqirun.OBuf.t
val gen_market_depth_request : Market_depth_request.t -> Piqirun.OBuf.t
val gen_market_data_reject : Market_data_reject.t -> Piqirun.OBuf.t
val gen_market_data_snapshot : Market_data_snapshot.t -> Piqirun.OBuf.t
val gen_market_data_snapshot_int : Market_data_snapshot_int.t -> Piqirun.OBuf.t
val gen_market_depth_snapshot_level : Market_depth_snapshot_level.t -> Piqirun.OBuf.t
val gen_market_depth_snapshot_level_float : Market_depth_snapshot_level_float.t -> Piqirun.OBuf.t
val gen_market_depth_snapshot_level_int : Market_depth_snapshot_level_int.t -> Piqirun.OBuf.t
val gen_market_depth_update_level : Market_depth_update_level.t -> Piqirun.OBuf.t
val gen_market_depth_update_level_int : Market_depth_update_level_int.t -> Piqirun.OBuf.t
val gen_market_depth_update_level_float_with_milliseconds : Market_depth_update_level_float_with_milliseconds.t -> Piqirun.OBuf.t
val gen_market_depth_update_level_no_timestamp : Market_depth_update_level_no_timestamp.t -> Piqirun.OBuf.t
val gen_market_data_update_session_settlement : Market_data_update_session_settlement.t -> Piqirun.OBuf.t
val gen_market_data_update_session_settlement_int : Market_data_update_session_settlement_int.t -> Piqirun.OBuf.t
val gen_market_data_update_session_open : Market_data_update_session_open.t -> Piqirun.OBuf.t
val gen_market_data_update_session_open_int : Market_data_update_session_open_int.t -> Piqirun.OBuf.t
val gen_market_data_update_session_num_trades : Market_data_update_session_num_trades.t -> Piqirun.OBuf.t
val gen_market_data_update_trading_session_date : Market_data_update_trading_session_date.t -> Piqirun.OBuf.t
val gen_market_depth_reject : Market_depth_reject.t -> Piqirun.OBuf.t
val gen_market_data_update_trade : Market_data_update_trade.t -> Piqirun.OBuf.t
val gen_market_data_update_trade_compact : Market_data_update_trade_compact.t -> Piqirun.OBuf.t
val gen_market_data_update_trade_int : Market_data_update_trade_int.t -> Piqirun.OBuf.t
val gen_market_data_update_last_trade_snapshot : Market_data_update_last_trade_snapshot.t -> Piqirun.OBuf.t
val gen_market_data_update_trade_with_unbundled_indicator : Market_data_update_trade_with_unbundled_indicator.t -> Piqirun.OBuf.t
val gen_market_data_update_trade_no_timestamp : Market_data_update_trade_no_timestamp.t -> Piqirun.OBuf.t
val gen_market_data_update_bid_ask : Market_data_update_bid_ask.t -> Piqirun.OBuf.t
val gen_market_data_update_bid_ask2 : Market_data_update_bid_ask2.t -> Piqirun.OBuf.t
val gen_market_data_update_bid_ask_int : Market_data_update_bid_ask_int.t -> Piqirun.OBuf.t
val gen_market_data_update_bid_ask_compact : Market_data_update_bid_ask_compact.t -> Piqirun.OBuf.t
val gen_market_data_update_bid_ask_no_time_stamp : Market_data_update_bid_ask_no_time_stamp.t -> Piqirun.OBuf.t
val gen_market_data_update_session_volume : Market_data_update_session_volume.t -> Piqirun.OBuf.t
val gen_market_data_update_open_interest : Market_data_update_open_interest.t -> Piqirun.OBuf.t
val gen_market_data_update_session_high : Market_data_update_session_high.t -> Piqirun.OBuf.t
val gen_market_data_update_session_high_int : Market_data_update_session_high_int.t -> Piqirun.OBuf.t
val gen_market_data_update_session_low : Market_data_update_session_low.t -> Piqirun.OBuf.t
val gen_market_data_update_session_low_int : Market_data_update_session_low_int.t -> Piqirun.OBuf.t
val gen_submit_new_single_order : Submit_new_single_order.t -> Piqirun.OBuf.t
val gen_submit_new_single_order_int : Submit_new_single_order_int.t -> Piqirun.OBuf.t
val gen_submit_flatten_position_order : Submit_flatten_position_order.t -> Piqirun.OBuf.t
val gen_cancel_replace_order : Cancel_replace_order.t -> Piqirun.OBuf.t
val gen_cancel_replace_order_int : Cancel_replace_order_int.t -> Piqirun.OBuf.t
val gen_cancel_order : Cancel_order.t -> Piqirun.OBuf.t
val gen_submit_new_ocoorder : Submit_new_ocoorder.t -> Piqirun.OBuf.t
val gen_submit_new_ocoorder_int : Submit_new_ocoorder_int.t -> Piqirun.OBuf.t
val gen_open_orders_request : Open_orders_request.t -> Piqirun.OBuf.t
val gen_historical_order_fills_request : Historical_order_fills_request.t -> Piqirun.OBuf.t
val gen_historical_order_fills_reject : Historical_order_fills_reject.t -> Piqirun.OBuf.t
val gen_current_positions_request : Current_positions_request.t -> Piqirun.OBuf.t
val gen_current_positions_reject : Current_positions_reject.t -> Piqirun.OBuf.t
val gen_order_update : Order_update.t -> Piqirun.OBuf.t
val gen_open_orders_reject : Open_orders_reject.t -> Piqirun.OBuf.t
val gen_historical_order_fill_response : Historical_order_fill_response.t -> Piqirun.OBuf.t
val gen_position_update : Position_update.t -> Piqirun.OBuf.t
val gen_trade_accounts_request : Trade_accounts_request.t -> Piqirun.OBuf.t
val gen_trade_account_response : Trade_account_response.t -> Piqirun.OBuf.t
val gen_exchange_list_request : Exchange_list_request.t -> Piqirun.OBuf.t
val gen_exchange_list_response : Exchange_list_response.t -> Piqirun.OBuf.t
val gen_symbols_for_exchange_request : Symbols_for_exchange_request.t -> Piqirun.OBuf.t
val gen_underlying_symbols_for_exchange_request : Underlying_symbols_for_exchange_request.t -> Piqirun.OBuf.t
val gen_symbols_for_underlying_request : Symbols_for_underlying_request.t -> Piqirun.OBuf.t
val gen_symbol_search_request : Symbol_search_request.t -> Piqirun.OBuf.t
val gen_security_definition_for_symbol_request : Security_definition_for_symbol_request.t -> Piqirun.OBuf.t
val gen_security_definition_response : Security_definition_response.t -> Piqirun.OBuf.t
val gen_security_definition_reject : Security_definition_reject.t -> Piqirun.OBuf.t
val gen_account_balance_request : Account_balance_request.t -> Piqirun.OBuf.t
val gen_account_balance_reject : Account_balance_reject.t -> Piqirun.OBuf.t
val gen_account_balance_update : Account_balance_update.t -> Piqirun.OBuf.t
val gen_account_balance_adjustment : Account_balance_adjustment.t -> Piqirun.OBuf.t
val gen_account_balance_adjustment_reject : Account_balance_adjustment_reject.t -> Piqirun.OBuf.t
val gen_account_balance_adjustment_complete : Account_balance_adjustment_complete.t -> Piqirun.OBuf.t
val gen_historical_account_balances_request : Historical_account_balances_request.t -> Piqirun.OBuf.t
val gen_historical_account_balances_reject : Historical_account_balances_reject.t -> Piqirun.OBuf.t
val gen_historical_account_balance_response : Historical_account_balance_response.t -> Piqirun.OBuf.t
val gen_user_message : User_message.t -> Piqirun.OBuf.t
val gen_general_log_message : General_log_message.t -> Piqirun.OBuf.t
val gen_journal_entry_add : Journal_entry_add.t -> Piqirun.OBuf.t
val gen_journal_entries_request : Journal_entries_request.t -> Piqirun.OBuf.t
val gen_journal_entries_reject : Journal_entries_reject.t -> Piqirun.OBuf.t
val gen_journal_entry_response : Journal_entry_response.t -> Piqirun.OBuf.t
val gen_alert_message : Alert_message.t -> Piqirun.OBuf.t
val gen_historical_price_data_request : Historical_price_data_request.t -> Piqirun.OBuf.t
val gen_historical_price_data_response_header : Historical_price_data_response_header.t -> Piqirun.OBuf.t
val gen_historical_price_data_reject : Historical_price_data_reject.t -> Piqirun.OBuf.t
val gen_historical_price_data_record_response : Historical_price_data_record_response.t -> Piqirun.OBuf.t
val gen_historical_price_data_tick_record_response : Historical_price_data_tick_record_response.t -> Piqirun.OBuf.t
val gen_historical_price_data_record_response_int : Historical_price_data_record_response_int.t -> Piqirun.OBuf.t
val gen_historical_price_data_tick_record_response_int : Historical_price_data_tick_record_response_int.t -> Piqirun.OBuf.t
val gen_historical_price_data_response_trailer : Historical_price_data_response_trailer.t -> Piqirun.OBuf.t
val gen_dtcversion : [< `current_version | `dtc_version_unset ] -> Piqirun.OBuf.t
val gen_dtcmessage_type : [< `account_balance_adjustment | `account_balance_adjustment_complete | `account_balance_adjustment_reject | `account_balance_reject | `account_balance_request | `account_balance_update | `alert_message | `cancel_order | `cancel_replace_order | `cancel_replace_order_int | `current_positions_reject | `current_positions_request | `encoding_request | `encoding_response | `exchange_list_request | `exchange_list_response | `general_log_message | `heartbeat | `historical_account_balance_response | `historical_account_balances_reject | `historical_account_balances_request | `historical_order_fill_response | `historical_order_fills_reject | `historical_order_fills_request | `historical_price_data_record_response | `historical_price_data_record_response_int | `historical_price_data_reject | `historical_price_data_request | `historical_price_data_response_header | `historical_price_data_tick_record_response | `historical_price_data_tick_record_response_int | `journal_entries_reject | `journal_entries_request | `journal_entry_add | `journal_entry_response | `logoff | `logon_request | `logon_response | `market_data_feed_status | `market_data_feed_symbol_status | `market_data_reject | `market_data_request | `market_data_snapshot | `market_data_snapshot_int | `market_data_update_bid_ask | `market_data_update_bid_ask_compact | `market_data_update_bid_ask_int | `market_data_update_bid_ask_no_timestamp | `market_data_update_last_trade_snapshot | `market_data_update_open_interest | `market_data_update_session_high | `market_data_update_session_high_int | `market_data_update_session_low | `market_data_update_session_low_int | `market_data_update_session_num_trades | `market_data_update_session_open | `market_data_update_session_open_int | `market_data_update_session_settlement | `market_data_update_session_settlement_int | `market_data_update_session_volume | `market_data_update_trade | `market_data_update_trade_compact | `market_data_update_trade_int | `market_data_update_trade_no_timestamp | `market_data_update_trade_with_unbundled_indicator | `market_data_update_trading_session_date | `market_depth_reject | `market_depth_request | `market_depth_snapshot_level | `market_depth_snapshot_level_float | `market_depth_snapshot_level_int | `market_depth_update_level | `market_depth_update_level_float_with_milliseconds | `market_depth_update_level_int | `market_depth_update_level_no_timestamp | `message_type_unset | `open_orders_reject | `open_orders_request | `order_update | `position_update | `security_definition_for_symbol_request | `security_definition_reject | `security_definition_response | `submit_flatten_position_order | `submit_new_oco_order | `submit_new_oco_order_int | `submit_new_single_order | `submit_new_single_order_int | `symbol_search_request | `symbols_for_exchange_request | `symbols_for_underlying_request | `trade_account_response | `trade_accounts_request | `trading_symbol_status | `underlying_symbols_for_exchange_request | `user_message ] -> Piqirun.OBuf.t
val gen_encoding_enum : Dtcprotocol_piqi.encoding_enum -> Piqirun.OBuf.t
val gen_logon_status_enum : Dtcprotocol_piqi.logon_status_enum -> Piqirun.OBuf.t
val gen_message_supported_enum : [< `message_supported | `message_unsupported ] -> Piqirun.OBuf.t
val gen_trade_mode_enum : Dtcprotocol_piqi.trade_mode_enum -> Piqirun.OBuf.t
val gen_request_action_enum : Dtcprotocol_piqi.request_action_enum -> Piqirun.OBuf.t
val gen_unbundled_trade_indicator_enum : Dtcprotocol_piqi.unbundled_trade_indicator_enum -> Piqirun.OBuf.t
val gen_order_status_enum : Dtcprotocol_piqi.order_status_enum -> Piqirun.OBuf.t
val gen_order_update_reason_enum : Dtcprotocol_piqi.order_update_reason_enum -> Piqirun.OBuf.t
val gen_at_bid_or_ask_enum : Dtcprotocol_piqi.at_bid_or_ask_enum -> Piqirun.OBuf.t
val gen_at_bid_or_ask_enum8 : Dtcprotocol_piqi.at_bid_or_ask_enum8 -> Piqirun.OBuf.t
val gen_market_depth_update_type_enum : Dtcprotocol_piqi.market_depth_update_type_enum -> Piqirun.OBuf.t
val gen_final_update_in_batch_enum : Dtcprotocol_piqi.final_update_in_batch_enum -> Piqirun.OBuf.t
val gen_order_type_enum : Dtcprotocol_piqi.order_type_enum -> Piqirun.OBuf.t
val gen_time_in_force_enum : Dtcprotocol_piqi.time_in_force_enum -> Piqirun.OBuf.t
val gen_buy_sell_enum : Dtcprotocol_piqi.buy_sell_enum -> Piqirun.OBuf.t
val gen_open_close_trade_enum : Dtcprotocol_piqi.open_close_trade_enum -> Piqirun.OBuf.t
val gen_partial_fill_handling_enum : Dtcprotocol_piqi.partial_fill_handling_enum -> Piqirun.OBuf.t
val gen_market_data_feed_status_enum : Dtcprotocol_piqi.market_data_feed_status_enum -> Piqirun.OBuf.t
val gen_price_display_format_enum : Dtcprotocol_piqi.price_display_format_enum -> Piqirun.OBuf.t
val gen_security_type_enum : Dtcprotocol_piqi.security_type_enum -> Piqirun.OBuf.t
val gen_put_call_enum : Dtcprotocol_piqi.put_call_enum -> Piqirun.OBuf.t
val gen_search_type_enum : Dtcprotocol_piqi.search_type_enum -> Piqirun.OBuf.t
val gen_historical_data_interval_enum : Dtcprotocol_piqi.historical_data_interval_enum -> Piqirun.OBuf.t
val gen_historical_price_data_reject_reason_code_enum : Dtcprotocol_piqi.historical_price_data_reject_reason_code_enum -> Piqirun.OBuf.t
val gen_trading_status_enum : Dtcprotocol_piqi.trading_status_enum -> Piqirun.OBuf.t
val default_int32 : unit -> int32
val default_int64 : unit -> int64
val default_protobuf_int32 : unit -> int32
val default_string : unit -> string
val default_bool : unit -> bool
val default_uint32 : unit -> int32
val default_int64_fixed : unit -> int64
val default_float64 : unit -> float
val default_float32 : unit -> float
val default_protobuf_int64 : unit -> int64
val default_int32_fixed : unit -> int32
val default_uint64 : unit -> int64
val default_encoding_request : unit -> Encoding_request.t
val default_encoding_response : unit -> Encoding_response.t
val default_logon_request : unit -> Logon_request.t
val default_logon_response : unit -> Logon_response.t
val default_logoff : unit -> Logoff.t
val default_heartbeat : unit -> Heartbeat.t
val default_market_data_feed_status : unit -> Market_data_feed_status.t
val default_market_data_feed_symbol_status : unit -> Market_data_feed_symbol_status.t
val default_trading_symbol_status : unit -> Trading_symbol_status.t
val default_market_data_request : unit -> Market_data_request.t
val default_market_depth_request : unit -> Market_depth_request.t
val default_market_data_reject : unit -> Market_data_reject.t
val default_market_data_snapshot : unit -> Market_data_snapshot.t
val default_market_data_snapshot_int : unit -> Market_data_snapshot_int.t
val default_market_depth_snapshot_level : unit -> Market_depth_snapshot_level.t
val default_market_depth_snapshot_level_float : unit -> Market_depth_snapshot_level_float.t
val default_market_depth_snapshot_level_int : unit -> Market_depth_snapshot_level_int.t
val default_market_depth_update_level : unit -> Market_depth_update_level.t
val default_market_depth_update_level_int : unit -> Market_depth_update_level_int.t
val default_market_depth_update_level_float_with_milliseconds : unit -> Market_depth_update_level_float_with_milliseconds.t
val default_market_depth_update_level_no_timestamp : unit -> Market_depth_update_level_no_timestamp.t
val default_market_data_update_session_settlement : unit -> Market_data_update_session_settlement.t
val default_market_data_update_session_settlement_int : unit -> Market_data_update_session_settlement_int.t
val default_market_data_update_session_open : unit -> Market_data_update_session_open.t
val default_market_data_update_session_open_int : unit -> Market_data_update_session_open_int.t
val default_market_data_update_session_num_trades : unit -> Market_data_update_session_num_trades.t
val default_market_data_update_trading_session_date : unit -> Market_data_update_trading_session_date.t
val default_market_depth_reject : unit -> Market_depth_reject.t
val default_market_data_update_trade : unit -> Market_data_update_trade.t
val default_market_data_update_trade_compact : unit -> Market_data_update_trade_compact.t
val default_market_data_update_trade_int : unit -> Market_data_update_trade_int.t
val default_market_data_update_last_trade_snapshot : unit -> Market_data_update_last_trade_snapshot.t
val default_market_data_update_trade_with_unbundled_indicator : unit -> Market_data_update_trade_with_unbundled_indicator.t
val default_market_data_update_trade_no_timestamp : unit -> Market_data_update_trade_no_timestamp.t
val default_market_data_update_bid_ask : unit -> Market_data_update_bid_ask.t
val default_market_data_update_bid_ask2 : unit -> Market_data_update_bid_ask2.t
val default_market_data_update_bid_ask_int : unit -> Market_data_update_bid_ask_int.t
val default_market_data_update_bid_ask_compact : unit -> Market_data_update_bid_ask_compact.t
val default_market_data_update_bid_ask_no_time_stamp : unit -> Market_data_update_bid_ask_no_time_stamp.t
val default_market_data_update_session_volume : unit -> Market_data_update_session_volume.t
val default_market_data_update_open_interest : unit -> Market_data_update_open_interest.t
val default_market_data_update_session_high : unit -> Market_data_update_session_high.t
val default_market_data_update_session_high_int : unit -> Market_data_update_session_high_int.t
val default_market_data_update_session_low : unit -> Market_data_update_session_low.t
val default_market_data_update_session_low_int : unit -> Market_data_update_session_low_int.t
val default_submit_new_single_order : unit -> Submit_new_single_order.t
val default_submit_new_single_order_int : unit -> Submit_new_single_order_int.t
val default_submit_flatten_position_order : unit -> Submit_flatten_position_order.t
val default_cancel_replace_order : unit -> Cancel_replace_order.t
val default_cancel_replace_order_int : unit -> Cancel_replace_order_int.t
val default_cancel_order : unit -> Cancel_order.t
val default_submit_new_ocoorder : unit -> Submit_new_ocoorder.t
val default_submit_new_ocoorder_int : unit -> Submit_new_ocoorder_int.t
val default_open_orders_request : unit -> Open_orders_request.t
val default_historical_order_fills_request : unit -> Historical_order_fills_request.t
val default_historical_order_fills_reject : unit -> Historical_order_fills_reject.t
val default_current_positions_request : unit -> Current_positions_request.t
val default_current_positions_reject : unit -> Current_positions_reject.t
val default_order_update : unit -> Order_update.t
val default_open_orders_reject : unit -> Open_orders_reject.t
val default_historical_order_fill_response : unit -> Historical_order_fill_response.t
val default_position_update : unit -> Position_update.t
val default_trade_accounts_request : unit -> Trade_accounts_request.t
val default_trade_account_response : unit -> Trade_account_response.t
val default_exchange_list_request : unit -> Exchange_list_request.t
val default_exchange_list_response : unit -> Exchange_list_response.t
val default_symbols_for_exchange_request : unit -> Symbols_for_exchange_request.t
val default_underlying_symbols_for_exchange_request : unit -> Underlying_symbols_for_exchange_request.t
val default_symbols_for_underlying_request : unit -> Symbols_for_underlying_request.t
val default_symbol_search_request : unit -> Symbol_search_request.t
val default_security_definition_for_symbol_request : unit -> Security_definition_for_symbol_request.t
val default_security_definition_response : unit -> Security_definition_response.t
val default_security_definition_reject : unit -> Security_definition_reject.t
val default_account_balance_request : unit -> Account_balance_request.t
val default_account_balance_reject : unit -> Account_balance_reject.t
val default_account_balance_update : unit -> Account_balance_update.t
val default_account_balance_adjustment : unit -> Account_balance_adjustment.t
val default_account_balance_adjustment_reject : unit -> Account_balance_adjustment_reject.t
val default_account_balance_adjustment_complete : unit -> Account_balance_adjustment_complete.t
val default_historical_account_balances_request : unit -> Historical_account_balances_request.t
val default_historical_account_balances_reject : unit -> Historical_account_balances_reject.t
val default_historical_account_balance_response : unit -> Historical_account_balance_response.t
val default_user_message : unit -> User_message.t
val default_general_log_message : unit -> General_log_message.t
val default_journal_entry_add : unit -> Journal_entry_add.t
val default_journal_entries_request : unit -> Journal_entries_request.t
val default_journal_entries_reject : unit -> Journal_entries_reject.t
val default_journal_entry_response : unit -> Journal_entry_response.t
val default_alert_message : unit -> Alert_message.t
val default_historical_price_data_request : unit -> Historical_price_data_request.t
val default_historical_price_data_response_header : unit -> Historical_price_data_response_header.t
val default_historical_price_data_reject : unit -> Historical_price_data_reject.t
val default_historical_price_data_record_response : unit -> Historical_price_data_record_response.t
val default_historical_price_data_tick_record_response : unit -> Historical_price_data_tick_record_response.t
val default_historical_price_data_record_response_int : unit -> Historical_price_data_record_response_int.t
val default_historical_price_data_tick_record_response_int : unit -> Historical_price_data_tick_record_response_int.t
val default_historical_price_data_response_trailer : unit -> Historical_price_data_response_trailer.t
val default_dtcversion : unit -> [> `dtc_version_unset ]
val default_dtcmessage_type : unit -> [> `message_type_unset ]
val default_encoding_enum : unit -> [> `binary_encoding ]
val default_logon_status_enum : unit -> [> `logon_status_unset ]
val default_message_supported_enum : unit -> [> `message_unsupported ]
val default_trade_mode_enum : unit -> [> `trade_mode_unset ]
val default_request_action_enum : unit -> [> `request_action_unset ]
val default_unbundled_trade_indicator_enum : unit -> [> `unbundled_trade_none ]
val default_order_status_enum : unit -> [> `order_status_unspecified ]
val default_order_update_reason_enum : unit -> [> `order_update_reason_unset ]
val default_at_bid_or_ask_enum : unit -> [> `bid_ask_unset ]
val default_at_bid_or_ask_enum8 : unit -> [> `bid_ask_unset_8 ]
val default_market_depth_update_type_enum : unit -> [> `depth_unset ]
val default_final_update_in_batch_enum : unit -> [> `final_update_unset ]
val default_order_type_enum : unit -> [> `order_type_unset ]
val default_time_in_force_enum : unit -> [> `tif_unset ]
val default_buy_sell_enum : unit -> [> `buy_sell_unset ]
val default_open_close_trade_enum : unit -> [> `trade_unset ]
val default_partial_fill_handling_enum : unit -> [> `partial_fill_unset ]
val default_market_data_feed_status_enum : unit -> [> `market_data_feed_status_unset ]
val default_price_display_format_enum : unit -> [> `price_display_format_decimal_0 ]
val default_security_type_enum : unit -> [> `security_type_unset ]
val default_put_call_enum : unit -> [> `pc_unset ]
val default_search_type_enum : unit -> [> `search_type_unset ]
val default_historical_data_interval_enum : unit -> [> `interval_tick ]
val default_historical_price_data_reject_reason_code_enum : unit -> [> `hpdr_unset ]
val default_trading_status_enum : unit -> [> `trading_status_unknown ]
include module type of struct include Dtcprotocol_piqi end
type uint32 = int32
type float64 = float
type float32 = float
type uint64 = int64
type protobuf_int32 = int32
type int64_fixed = int64
type protobuf_int64 = int64
type int32_fixed = int32
type dtcversion = [
| `dtc_version_unset
| `current_version
]
type dtcmessage_type = [
| `message_type_unset
| `logon_request
| `logon_response
| `heartbeat
| `logoff
| `encoding_request
| `encoding_response
| `market_data_request
| `market_data_reject
| `market_data_snapshot
| `market_data_snapshot_int
| `market_data_update_trade
| `market_data_update_trade_compact
| `market_data_update_trade_int
| `market_data_update_last_trade_snapshot
| `market_data_update_trade_with_unbundled_indicator
| `market_data_update_trade_no_timestamp
| `market_data_update_bid_ask
| `market_data_update_bid_ask_compact
| `market_data_update_bid_ask_no_timestamp
| `market_data_update_bid_ask_int
| `market_data_update_session_open
| `market_data_update_session_open_int
| `market_data_update_session_high
| `market_data_update_session_high_int
| `market_data_update_session_low
| `market_data_update_session_low_int
| `market_data_update_session_volume
| `market_data_update_open_interest
| `market_data_update_session_settlement
| `market_data_update_session_settlement_int
| `market_data_update_session_num_trades
| `market_data_update_trading_session_date
| `market_depth_request
| `market_depth_reject
| `market_depth_snapshot_level
| `market_depth_snapshot_level_int
| `market_depth_snapshot_level_float
| `market_depth_update_level
| `market_depth_update_level_float_with_milliseconds
| `market_depth_update_level_no_timestamp
| `market_depth_update_level_int
| `market_data_feed_status
| `market_data_feed_symbol_status
| `trading_symbol_status
| `submit_new_single_order
| `submit_new_single_order_int
| `submit_new_oco_order
| `submit_new_oco_order_int
| `submit_flatten_position_order
| `cancel_order
| `cancel_replace_order
| `cancel_replace_order_int
| `open_orders_request
| `open_orders_reject
| `order_update
| `historical_order_fills_request
| `historical_order_fill_response
| `historical_order_fills_reject
| `current_positions_request
| `current_positions_reject
| `position_update
| `trade_accounts_request
| `trade_account_response
| `exchange_list_request
| `exchange_list_response
| `symbols_for_exchange_request
| `underlying_symbols_for_exchange_request
| `symbols_for_underlying_request
| `security_definition_for_symbol_request
| `security_definition_response
| `symbol_search_request
| `security_definition_reject
| `account_balance_request
| `account_balance_reject
| `account_balance_update
| `account_balance_adjustment
| `account_balance_adjustment_reject
| `account_balance_adjustment_complete
| `historical_account_balances_request
| `historical_account_balances_reject
| `historical_account_balance_response
| `user_message
| `general_log_message
| `alert_message
| `journal_entry_add
| `journal_entries_request
| `journal_entries_reject
| `journal_entry_response
| `historical_price_data_request
| `historical_price_data_response_header
| `historical_price_data_reject
| `historical_price_data_record_response
| `historical_price_data_tick_record_response
| `historical_price_data_record_response_int
| `historical_price_data_tick_record_response_int
]
type encoding_enum = [
| `binary_encoding
| `binary_with_variable_length_strings
| `json_encoding
| `json_compact_encoding
| `protocol_buffers
]
type logon_status_enum = [
| `logon_status_unset
| `logon_success
| `logon_error
| `logon_error_no_reconnect
| `logon_reconnect_new_address
]
type message_supported_enum = [
| `message_unsupported
| `message_supported
]
type trade_mode_enum = [
| `trade_mode_unset
| `trade_mode_demo
| `trade_mode_simulated
| `trade_mode_live
]
type request_action_enum = [
| `request_action_unset
| `subscribe
| `unsubscribe
| `snapshot
]
type unbundled_trade_indicator_enum = [
| `unbundled_trade_none
| `first_sub_trade_of_unbundled_trade
| `last_sub_trade_of_unbundled_trade
]
type order_status_enum = [
| `order_status_unspecified
| `order_status_order_sent
| `order_status_pending_open
| `order_status_pending_child
| `order_status_open
| `order_status_pending_cancel_replace
| `order_status_pending_cancel
| `order_status_filled
| `order_status_canceled
| `order_status_rejected
| `order_status_partially_filled
]
type order_update_reason_enum = [
| `order_update_reason_unset
| `open_orders_request_response
| `new_order_accepted
| `general_order_update
| `order_filled
| `order_filled_partially
| `order_canceled
| `order_cancel_replace_complete
| `new_order_rejected
| `order_cancel_rejected
| `order_cancel_replace_rejected
]
type at_bid_or_ask_enum = [
| `bid_ask_unset
| `at_bid
| `at_ask
]
type at_bid_or_ask_enum8 = [
| `bid_ask_unset_8
| `at_bid_8
| `at_ask_8
]
type market_depth_update_type_enum = [
| `depth_unset
| `market_depth_insert_update_level
| `market_depth_delete_level
]
type final_update_in_batch_enum = [
| `final_update_unset
| `final_update_true
| `final_update_false
| `final_update_begin_batch
]
type order_type_enum = [
| `order_type_unset
| `order_type_market
| `order_type_limit
| `order_type_stop
| `order_type_stop_limit
| `order_type_market_if_touched
| `order_type_limit_if_touched
]
type time_in_force_enum = [
| `tif_unset
| `tif_day
| `tif_good_till_canceled
| `tif_good_till_date_time
| `tif_immediate_or_cancel
| `tif_all_or_none
| `tif_fill_or_kill
]
type buy_sell_enum = [
| `buy_sell_unset
| `buy
| `sell
]
type open_close_trade_enum = [
| `trade_unset
| `trade_open
| `trade_close
]
type partial_fill_handling_enum = [
| `partial_fill_unset
| `partial_fill_handling_reduce_quantity
| `partial_fill_handling_immediate_cancel
]
type market_data_feed_status_enum = [
| `market_data_feed_status_unset
| `market_data_feed_unavailable
| `market_data_feed_available
]
type price_display_format_enum = [
| `price_display_format_decimal_0
| `price_display_format_decimal_1
| `price_display_format_decimal_2
| `price_display_format_decimal_3
| `price_display_format_decimal_4
| `price_display_format_decimal_5
| `price_display_format_decimal_6
| `price_display_format_decimal_7
| `price_display_format_decimal_8
| `price_display_format_decimal_9
| `price_display_format_denominator_256
| `price_display_format_denominator_128
| `price_display_format_denominator_64
| `price_display_format_denominator_32_quarters
| `price_display_format_denominator_32_halves
| `price_display_format_denominator_32
| `price_display_format_denominator_16
| `price_display_format_denominator_8
| `price_display_format_denominator_4
| `price_display_format_denominator_2
| `price_display_format_unset
]
type security_type_enum = [
| `security_type_unset
| `security_type_future
| `security_type_stock
| `security_type_forex
| `security_type_index
| `security_type_futures_strategy
| `security_type_futures_option
| `security_type_stock_option
| `security_type_index_option
| `security_type_bond
| `security_type_mutual_fund
]
type put_call_enum = [
| `pc_unset
| `pc_call
| `pc_put
]
type search_type_enum = [
| `search_type_unset
| `search_type_by_symbol
| `search_type_by_description
]
type historical_data_interval_enum = [
| `interval_tick
| `interval_1_second
| `interval_2_seconds
| `interval_4_seconds
| `interval_5_seconds
| `interval_10_seconds
| `interval_30_seconds
| `interval_1_minute
| `interval_5_minute
| `interval_10_minute
| `interval_15_minute
| `interval_30_minute
| `interval_1_hour
| `interval_2_hours
| `interval_1_day
| `interval_1_week
]
type historical_price_data_reject_reason_code_enum = [
| `hpdr_unset
| `hpdr_unable_to_serve_data_retry_later
| `hpdr_unable_to_serve_data_do_not_retry
| `hpdr_data_request_outside_bounds_of_available_data
| `hpdr_general_reject_error
]
type trading_status_enum = [
| `trading_status_unknown
| `trading_status_pre_open
| `trading_status_open
| `trading_status_close
| `trading_status_trading_halt
]
type encoding_request = Encoding_request.t
type encoding_response = Encoding_response.t
type logon_request = Logon_request.t
type logon_response = Logon_response.t
type logoff = Logoff.t
type heartbeat = Heartbeat.t
type market_data_feed_status = Market_data_feed_status.t
type market_data_feed_symbol_status = Market_data_feed_symbol_status.t
type trading_symbol_status = Trading_symbol_status.t
type market_data_request = Market_data_request.t
type market_depth_request = Market_depth_request.t
type market_data_reject = Market_data_reject.t
type market_data_snapshot = Market_data_snapshot.t
type market_data_snapshot_int = Market_data_snapshot_int.t
type market_depth_snapshot_level = Market_depth_snapshot_level.t
type market_depth_snapshot_level_float = Market_depth_snapshot_level_float.t
type market_depth_snapshot_level_int = Market_depth_snapshot_level_int.t
type market_depth_update_level = Market_depth_update_level.t
type market_depth_update_level_int = Market_depth_update_level_int.t
type market_depth_update_level_float_with_milliseconds = Market_depth_update_level_float_with_milliseconds.t
type market_depth_update_level_no_timestamp = Market_depth_update_level_no_timestamp.t
type market_data_update_session_settlement = Market_data_update_session_settlement.t
type market_data_update_session_settlement_int = Market_data_update_session_settlement_int.t
type market_data_update_session_open = Market_data_update_session_open.t
type market_data_update_session_open_int = Market_data_update_session_open_int.t
type market_data_update_session_num_trades = Market_data_update_session_num_trades.t
type market_data_update_trading_session_date = Market_data_update_trading_session_date.t
type market_depth_reject = Market_depth_reject.t
type market_data_update_trade = Market_data_update_trade.t
type market_data_update_trade_compact = Market_data_update_trade_compact.t
type market_data_update_trade_int = Market_data_update_trade_int.t
type market_data_update_last_trade_snapshot = Market_data_update_last_trade_snapshot.t
type market_data_update_trade_with_unbundled_indicator = Market_data_update_trade_with_unbundled_indicator.t
type market_data_update_trade_no_timestamp = Market_data_update_trade_no_timestamp.t
type market_data_update_bid_ask = Market_data_update_bid_ask.t
type market_data_update_bid_ask2 = Market_data_update_bid_ask2.t
type market_data_update_bid_ask_int = Market_data_update_bid_ask_int.t
type market_data_update_bid_ask_compact = Market_data_update_bid_ask_compact.t
type market_data_update_bid_ask_no_time_stamp = Market_data_update_bid_ask_no_time_stamp.t
type market_data_update_session_volume = Market_data_update_session_volume.t
type market_data_update_open_interest = Market_data_update_open_interest.t
type market_data_update_session_high = Market_data_update_session_high.t
type market_data_update_session_high_int = Market_data_update_session_high_int.t
type market_data_update_session_low = Market_data_update_session_low.t
type market_data_update_session_low_int = Market_data_update_session_low_int.t
type submit_new_single_order = Submit_new_single_order.t
type submit_new_single_order_int = Submit_new_single_order_int.t
type submit_flatten_position_order = Submit_flatten_position_order.t
type cancel_replace_order = Cancel_replace_order.t
type cancel_replace_order_int = Cancel_replace_order_int.t
type cancel_order = Cancel_order.t
type submit_new_ocoorder = Submit_new_ocoorder.t
type submit_new_ocoorder_int = Submit_new_ocoorder_int.t
type open_orders_request = Open_orders_request.t
type historical_order_fills_request = Historical_order_fills_request.t
type historical_order_fills_reject = Historical_order_fills_reject.t
type current_positions_request = Current_positions_request.t
type current_positions_reject = Current_positions_reject.t
type order_update = Order_update.t
type open_orders_reject = Open_orders_reject.t
type historical_order_fill_response = Historical_order_fill_response.t
type position_update = Position_update.t
type trade_accounts_request = Trade_accounts_request.t
type trade_account_response = Trade_account_response.t
type exchange_list_request = Exchange_list_request.t
type exchange_list_response = Exchange_list_response.t
type symbols_for_exchange_request = Symbols_for_exchange_request.t
type underlying_symbols_for_exchange_request = Underlying_symbols_for_exchange_request.t
type symbols_for_underlying_request = Symbols_for_underlying_request.t
type symbol_search_request = Symbol_search_request.t
type security_definition_for_symbol_request = Security_definition_for_symbol_request.t
type security_definition_response = Security_definition_response.t
type security_definition_reject = Security_definition_reject.t
type account_balance_request = Account_balance_request.t
type account_balance_reject = Account_balance_reject.t
type account_balance_update = Account_balance_update.t
type account_balance_adjustment = Account_balance_adjustment.t
type account_balance_adjustment_reject = Account_balance_adjustment_reject.t
type account_balance_adjustment_complete = Account_balance_adjustment_complete.t
type historical_account_balances_request = Historical_account_balances_request.t
type historical_account_balances_reject = Historical_account_balances_reject.t
type historical_account_balance_response = Historical_account_balance_response.t
type user_message = User_message.t
type general_log_message = General_log_message.t
type journal_entry_add = Journal_entry_add.t
type journal_entries_request = Journal_entries_request.t
type journal_entries_reject = Journal_entries_reject.t
type journal_entry_response = Journal_entry_response.t
type alert_message = Alert_message.t
type historical_price_data_request = Historical_price_data_request.t
type historical_price_data_response_header = Historical_price_data_response_header.t
type historical_price_data_reject = Historical_price_data_reject.t
type historical_price_data_record_response = Historical_price_data_record_response.t
type historical_price_data_tick_record_response = Historical_price_data_tick_record_response.t
type historical_price_data_record_response_int = Historical_price_data_record_response_int.t
type historical_price_data_tick_record_response_int = Historical_price_data_tick_record_response_int.t
type historical_price_data_response_trailer = Historical_price_data_response_trailer.t