starainrt
98ef9e7fcc
- 新增 managed/external/nested 三种传输保护模式 - 新增 peer attach 显式认证、抗重放、channel binding 和可选前向保密协商 - 明确单连接注入与可重拨连接源的语义边界 - 禁止 ConnectByConn 场景下 dedicated bulk 走 sidecar，auto 模式自动回退 shared - 修正 dedicated attach 在 bootstrap/steady profile 切换下的处理逻辑 - 优化 shared bulk super-batch 与批量 framed write 路径 - 降低 stream/bulk fast path 的复制和分发损耗 - 补齐 benchmark、回归测试、运行时快照和 README 文档
43 lines
1.6 KiB
Go
43 lines
1.6 KiB
Go
package notify
|
|
|
|
import "testing"
|
|
|
|
type benchmarkTransportSecurityMode string
|
|
|
|
const (
|
|
benchmarkTransportSecurityModernPSK benchmarkTransportSecurityMode = "modern_psk"
|
|
benchmarkTransportSecurityTrustedRaw benchmarkTransportSecurityMode = "trusted_raw"
|
|
)
|
|
|
|
func benchmarkApplyServerTransportSecurity(tb testing.TB, server *ServerCommon, mode benchmarkTransportSecurityMode) {
|
|
tb.Helper()
|
|
switch mode {
|
|
case benchmarkTransportSecurityModernPSK:
|
|
if err := UseModernPSKServer(server, integrationSharedSecret, integrationModernPSKOptions()); err != nil {
|
|
tb.Fatalf("UseModernPSKServer failed: %v", err)
|
|
}
|
|
case benchmarkTransportSecurityTrustedRaw:
|
|
if err := UsePSKOverExternalTransportServer(server, integrationSharedSecret, integrationModernPSKOptions()); err != nil {
|
|
tb.Fatalf("UsePSKOverExternalTransportServer failed: %v", err)
|
|
}
|
|
default:
|
|
tb.Fatalf("unsupported benchmark transport security mode %q", mode)
|
|
}
|
|
}
|
|
|
|
func benchmarkApplyClientTransportSecurity(tb testing.TB, client *ClientCommon, mode benchmarkTransportSecurityMode) {
|
|
tb.Helper()
|
|
switch mode {
|
|
case benchmarkTransportSecurityModernPSK:
|
|
if err := UseModernPSKClient(client, integrationSharedSecret, integrationModernPSKOptions()); err != nil {
|
|
tb.Fatalf("UseModernPSKClient failed: %v", err)
|
|
}
|
|
case benchmarkTransportSecurityTrustedRaw:
|
|
if err := UsePSKOverExternalTransportClient(client, integrationSharedSecret, integrationModernPSKOptions()); err != nil {
|
|
tb.Fatalf("UsePSKOverExternalTransportClient failed: %v", err)
|
|
}
|
|
default:
|
|
tb.Fatalf("unsupported benchmark transport security mode %q", mode)
|
|
}
|
|
}
|