1 Star 0 Fork 0

sqos/beats

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
socks5.go 948 Bytes
一键复制 编辑 原始数据 按行查看 历史
Steffen Siering 提交于 2017-04-28 09:08 . Heartbeat event format (#4091)
package dialchain
import (
"net"
"github.com/elastic/beats/heartbeat/look"
"github.com/elastic/beats/libbeat/common"
"github.com/elastic/beats/libbeat/outputs/transport"
)
// SOCKS5Layer configures a SOCKS5 proxy layer in a DialerChain.
//
// The layer will update the active event with:
//
// {
// "socks5": {
// "rtt": { "connect": { "us": ... }}
// }
// }
func SOCKS5Layer(config *transport.ProxyConfig) Layer {
return func(event common.MapStr, next transport.Dialer) (transport.Dialer, error) {
var timer timer
dialer, err := transport.ProxyDialer(config, startTimerAfterDial(&timer, next))
if err != nil {
return nil, err
}
return afterDial(dialer, func(conn net.Conn) (net.Conn, error) {
// TODO: extract connection parameter from connection object?
// TODO: add proxy url to event?
timer.stop()
event.Put("socks5.rtt.connect", look.RTT(timer.duration()))
return conn, nil
}), nil
}
}
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/sqos/beats.git
git@gitee.com:sqos/beats.git
sqos
beats
beats
v6.0.0-rc2

搜索帮助

0d507c66 1850385 C8b1a773 1850385