Versions in this module Expand all Collapse all v0 v0.52.5 Dec 8, 2023 v0.52.4 Dec 8, 2023 Changes in this version + var ErrNoTunnelSession = errors.New("no tunnel session") + type BaseVisitor struct + func (v *BaseVisitor) AcceptConn(conn net.Conn) error + func (v *BaseVisitor) Close() + type Helper interface + ConnectServer func() (net.Conn, error) + MsgTransporter func() transport.MessageTransporter + RunID func() string + TransferConn func(string, net.Conn) error + type KCPTunnelSession struct + func (ks *KCPTunnelSession) Close() + func (ks *KCPTunnelSession) Init(listenConn *net.UDPConn, raddr *net.UDPAddr) error + func (ks *KCPTunnelSession) OpenConn(_ context.Context) (net.Conn, error) + type Manager struct + func NewManager(ctx context.Context, runID string, clientCfg *v1.ClientCommonConfig, ...) *Manager + func (vm *Manager) Close() + func (vm *Manager) Reload(cfgs []v1.VisitorConfigurer) + func (vm *Manager) Run() + func (vm *Manager) TransferConn(name string, conn net.Conn) error + type QUICTunnelSession struct + func (qs *QUICTunnelSession) Close() + func (qs *QUICTunnelSession) Init(listenConn *net.UDPConn, raddr *net.UDPAddr) error + func (qs *QUICTunnelSession) OpenConn(ctx context.Context) (net.Conn, error) + type STCPVisitor struct + func (sv *STCPVisitor) Close() + func (sv *STCPVisitor) Run() (err error) + type SUDPVisitor struct + func (sv *SUDPVisitor) Close() + func (sv *SUDPVisitor) Run() (err error) + type TunnelSession interface + Close func() + Init func(listenConn *net.UDPConn, raddr *net.UDPAddr) error + OpenConn func(context.Context) (net.Conn, error) + func NewKCPTunnelSession() TunnelSession + func NewQUICTunnelSession(clientCfg *v1.ClientCommonConfig) TunnelSession + type Visitor interface + AcceptConn func(conn net.Conn) error + Close func() + Run func() error + func NewVisitor(ctx context.Context, cfg v1.VisitorConfigurer, ...) (visitor Visitor) + type XTCPVisitor struct + func (sv *XTCPVisitor) Close() + func (sv *XTCPVisitor) Run() (err error)