Skip to main content

Module quote_sub

Module quote_sub 

Source

Modules§

sbit
后端 SubscribeBit 值
sub_type
FTAPI SubType 枚举值

Structs§

DispatchAccepted
EmptyDesiredMarket
NormalSubscriptionDispatchHooks
QotSubscriptionWriterAdmission
RedactedQotSubError
Fail-closed production logging projection for QotSubError.
SecurityWithOpts
SubBitOptions
SubscribeBitInfo

Enums§

Cmd6211RetryPolicy
GitHub issue #55:单次 CMD6211 发送失败后的重试归属。
NormalDispatchOutcome
QotSubError
v1.4.106 codex 1131 F1: submit_global_desired_set 错误类型. 让 caller (SubHandler) 区分 backend reject vs decode err vs timeout → ack-then-commit pattern (F1 P1).
SubscribeSetCommandMode
SubscribeSetPlanError

Constants§

CMD6211_SEND_FAILED_RETRY_MAX
GitHub issue #55:CMD6211 失败重试上限(不含初次发送)。 Ref: C++ MktQotSub.cpp:9 #define SubFailedRetryMax (3)OnReply_SubOrUnSub (:334-339) bFailedReachMax = (m_nReqFailedTimes++ >= SubFailedRetryMax):连续失败 0/1/2 次继续起定时器重发,第 3 次失败后停止 → 初次 + 3 次重试共 4 次。
CMD6211_SEND_RETRY_PAUSE
GitHub issue #55:CMD6211 失败重试间隔。 Ref: C++ NNProtoCenter/Quote/MktQotSub.cpp:5 #define TimerPause_SendSubReq (250) //0.2秒以上,防止粘包StartSendSubReqTimer (:730-741) 用它起一次性发送定时器。
CMD_QOT_PULL_TICKER
Pull ticker. Ref: NNBase_Define_ProtoCmd.h:93.
CMD_QOT_PUSH
后端推送命令 ID
CMD_QOT_SUB
QOT subscription push protocol commands. Ref: NNBase_Define_ProtoCmd.h:98-100.
TICKER_PAGE_MAX_ITEMS

Functions§

build_keep_subscribe_req_with_options
build_subscribe_req_with_options
v1.4.106 codex 1131 F6: 构建带 SubBitOptions 的订阅请求 — 真传 session / detail / extended_time 给 backend.
cmd6211_reply_failure_should_retry
GitHub issue #55:一次 CMD6211 失败后是否按 C++ 语义重发。
empty_desired_market_for_sub
ensure_subscribe_set_backend_success
Interpret backend SubscribeSetRsp status fields without taking a dependency on the generated proto type.
ftapi_market_to_quote_mkt
is_depth_sub_type
plan_empty_subscribe_set_commands
plan_subscribe_set_commands
pull_latest_ticker
拉取最新逐笔,用于对齐 C++ Qot_Sub 成功后“订阅逐笔要提前拉一根”。
pull_ticker_page
Pull one exact CMD6128 page. The backend wire caps ordinary pages at 750; callers requesting more must continue with response next_ticker_key and date_time_s, matching C++ OnReply_PullTickerList.
sub_type_to_bit_infos_with_options
sub_type_to_bits
sub_type_to_bits_with_options
submit_cached_keep_wire
Submit one immutable cached keep request.
submit_empty_desired_set_for_markets
submit_empty_desired_set_for_markets_with_retry_policy
submit_empty_desired_set_for_markets 的显式重试归属版本。
submit_global_desired_set
v1.4.106 codex 1131 F1+F2: 给 caller (SubHandler) 的 set-state 接口.
submit_global_desired_set_with_retry_policy
submit_global_desired_set 的显式重试归属版本,见 Cmd6211RetryPolicy

Type Aliases§

SecuritySubscribeInput
v1.4.110 Phase 2 Slice 4: per-security 输入 — (stock_id, broker_id, sub_types_with_opts) 3-tuple. broker_id = None 走 no-broker 路径 (普通股, Phase 2 默认), Some(NonZeroU32) 走 broker-aware 路径 (crypto multi-broker).
SubscribeSetSecurityPlan
Per-security input for one backend CMD6211 SubscribeSetReq.