MCPcopy Create free account

hub / github.com/cppla/moto / functions

Functions35 in github.com/cppla/moto

⨍ Functions 35◇ Types & classes 9
↓ 6 callersFunctionoutboundDial
outboundDial 先尝试预热池，失败再发起新建连接。 之前返回 (conn, usedFlag, error)，由于当前不再区分来源，精简为 (conn, error)。
controller/prewarm.go:148
↓ 5 callersMethodensureLocked
ensureLocked 会持续补齐预热连接直到达到期望值。
controller/prewarm.go:59
↓ 3 callersFunctionfmt_perc
(vals, name)
test/bench.py:178
↓ 3 callersFunctionstoreBoostWinner
(ruleName, addr string)
controller/boost.go:45
↓ 2 callersFunctionDialFast
DialFast 实现简化版的 Happy Eyeballs，并记录拨号延迟。
controller/direct.go:19
↓ 2 callersFunctionHandleBoost
HandleBoost 同时发起多路拨号，挑选最先成功的连接并套上单边加速。
controller/boost.go:105
↓ 2 callersFunctionfmt_dist
(c: Counter, top=5)
test/bench.py:175
↓ 2 callersFunctionrun_phase
(phase_name: str, concurrency: int, total: int, timeout: float, jitter: float, results: Li
test/bench.py:145
↓ 2 callersMethodverify
verify 校验规则配置，并在需要时编译正则。
config/setting.go:93
↓ 1 callersFunctionHandleNormal
HandleNormal 会依次尝试各个目标，并在成功的连接上挂载自适应的单边加速。
controller/normal.go:14
↓ 1 callersFunctionHandleRegexp
HandleRegexp 通过正则检测首包选出目标，再转发后续数据流。
controller/regex.go:15
↓ 1 callersFunctionHandleRoundrobin
HandleRoundrobin 顺序轮转目标，失败时回退到 boost 模式。
controller/roundrobin.go:17
↓ 1 callersFunctionListen
Listen 根据规则启动 TCP 监听，做基础限流并分发到对应模式。
controller/server.go:13
↓ 1 callersFunctionReload
Reload 从指定路径重载配置，并执行默认值填充与校验。
config/setting.go:71
↓ 1 callersFunctionacquirePrewarmed
acquirePrewarmed 优先从预热池取出可用连接。
controller/prewarm.go:98
↓ 1 callersMethoddialOne
dialOne 拨号一个连接并加入空闲池。
controller/prewarm.go:71
↓ 1 callersFunctionensurePrewarmPool
(addr string, desired int)
controller/prewarm.go:46
↓ 1 callersFunctioninitPrewarm
initPrewarm 会为规则中的每个目标开启后台保温。
controller/prewarm.go:36
↓ 1 callersFunctionlazyRevalidate
不再单独提供显式 drop 接口，超时或拨号失败自动失效。 lazyRevalidate 在后台重新跑一次竞速，不打断现有请求；若发现更快线路则更新缓存。
controller/boost.go:63
↓ 1 callersFunctionloadBoostWinner
(ruleName string)
controller/boost.go:34
↓ 1 callersFunctionmain
()
test/bench.py:221
↓ 1 callersFunctionparse_args
()
test/bench.py:203
↓ 1 callersFunctionpercentiles
(values: List[float], ps=(50,90,95,99))
test/bench.py:134
↓ 1 callersFunctionprint_header
()
test/bench.py:216
↓ 1 callersFunctionsocks5_http_get
(timeout: float, phase: str)
test/bench.py:39
↓ 1 callersFunctionsummarize
(results: List[Result])
test/bench.py:164
↓ 1 callersFunctionworker
(idx: int)
test/bench.py:150
MethodDialLatency
()
controller/direct.go:16
FunctionTimeEncoder
(t time.Time, enc zapcore.PrimitiveArrayEncoder)
utils/log.go:76
FunctionZapErr
(err error)
utils/log.go:82
FunctionZapString
optional helpers for structured fields (used in some modules)
utils/log.go:81
Method__init__
(self, ok: bool, error: Optional[str], connect_ms: float, first_byte_ms: float, total_ms: flo
test/bench.py:29
Functioninit
()
utils/log.go:16
Functioninit
()
config/setting.go:44
Functionmain
()
run.go:13