client

Documentation

Index

• Variables
• func LoadConf(confFile string) (err error)
• type ProxyClient
  • func (pc *ProxyClient) CloseUdpTunnel()
  • func (pc *ProxyClient) GetLocalConn() (c *conn.Conn, err error)
  • func (pc *ProxyClient) GetRemoteConn(addr string, port int64) (c *conn.Conn, err error)
  • func (pc *ProxyClient) IsClosed() bool
  • func (pc *ProxyClient) SetCloseFlag(closeFlag bool)
  • func (pc *ProxyClient) StartTunnel(serverAddr string, serverPort int64) (err error)
  • func (pc *ProxyClient) StartUdpTunnelOnce(addr string, port int64)
• type UdpProcesser
  • func NewUdpProcesser(c *conn.Conn, localIp string, localPort int64) *UdpProcesser
  • func (up *UdpProcesser) Forward(udpPacket *msg.UdpPacket, singleConn *net.UDPConn)
  • func (up *UdpProcesser) GetUdpConn(addr string) (singleConn *net.UDPConn, ok bool)
  • func (up *UdpProcesser) ReadLoop()
  • func (up *UdpProcesser) RemoveUdpConn(addr string)
  • func (up *UdpProcesser) Run()
  • func (up *UdpProcesser) SetUdpConn(addr string, conn *net.UDPConn)
  • func (up *UdpProcesser) UpdateTcpConn(c *conn.Conn)

Variables

var (
	ServerAddr        string = "0.0.0.0"
	ServerPort        int64  = 7000
	HttpProxy         string = ""
	LogFile           string = "console"
	LogWay            string = "console"
	LogLevel          string = "info"
	LogMaxDays        int64  = 3
	PrivilegeToken    string = ""
	HeartBeatInterval int64  = 10
	HeartBeatTimeout  int64  = 30
)

common config

var ProxyClients map[string]*ProxyClient = make(map[string]*ProxyClient)

Functions

func LoadConf

func LoadConf(confFile string) (err error)

Types

type ProxyClient

type ProxyClient struct {
	config.BaseConf
	LocalIp   string
	LocalPort int64

	RemotePort    int64
	CustomDomains []string
	Locations     []string
	// contains filtered or unexported fields
}

func (*ProxyClient) CloseUdpTunnel

func (pc *ProxyClient) CloseUdpTunnel()

func (*ProxyClient) GetLocalConn

func (pc *ProxyClient) GetLocalConn() (c *conn.Conn, err error)

func (*ProxyClient) GetRemoteConn

func (pc *ProxyClient) GetRemoteConn(addr string, port int64) (c *conn.Conn, err error)

func (*ProxyClient) IsClosed

func (pc *ProxyClient) IsClosed() bool

func (*ProxyClient) SetCloseFlag

func (pc *ProxyClient) SetCloseFlag(closeFlag bool)

func (*ProxyClient) StartTunnel

func (pc *ProxyClient) StartTunnel(serverAddr string, serverPort int64) (err error)

func (*ProxyClient) StartUdpTunnelOnce

func (pc *ProxyClient) StartUdpTunnelOnce(addr string, port int64)

if proxy type is udp, keep a tcp connection for transferring udp packages

type UdpProcesser

type UdpProcesser struct {
	// contains filtered or unexported fields
}

func NewUdpProcesser

func NewUdpProcesser(c *conn.Conn, localIp string, localPort int64) *UdpProcesser

func (*UdpProcesser) Forward

func (up *UdpProcesser) Forward(udpPacket *msg.UdpPacket, singleConn *net.UDPConn)

func (*UdpProcesser) GetUdpConn

func (up *UdpProcesser) GetUdpConn(addr string) (singleConn *net.UDPConn, ok bool)

func (*UdpProcesser) ReadLoop

func (up *UdpProcesser) ReadLoop()

func (*UdpProcesser) RemoveUdpConn

func (up *UdpProcesser) RemoveUdpConn(addr string)

func (*UdpProcesser) Run

func (up *UdpProcesser) Run()

func (*UdpProcesser) SetUdpConn

func (up *UdpProcesser) SetUdpConn(addr string, conn *net.UDPConn)

func (*UdpProcesser) UpdateTcpConn

func (up *UdpProcesser) UpdateTcpConn(c *conn.Conn)