conn

Documentation

Index

• func Accept(l net.Listener, f func(c net.Conn))
• func CopyWaitGroup(conn1, conn2 net.Conn, crypt bool, snappy bool, rate *rate.Rate, ...)
• func GetConn(conn net.Conn, cpt, snappy bool, rt *rate.Rate, isServer bool) io.ReadWriteCloser
• func GetLenBytes(buf []byte) (b []byte, err error)
• func NewKcpListenerAndProcess(addr string, f func(c net.Conn)) error
• func NewTcpListenerAndProcess(addr string, f func(c net.Conn), listener *net.Listener) error
• func SetUdpSession(sess *kcp.UDPSession)
• type Conn
  • func NewConn(conn net.Conn) *Conn
  • func (s *Conn) Close() error
  • func (s *Conn) GetAddStatus() (b bool)
  • func (s *Conn) GetConfigInfo() (c *file.Client, err error)
  • func (s *Conn) GetHealthInfo() (info string, status bool, err error)
  • func (s *Conn) GetHost() (method, address string, rb []byte, err error, r *http.Request)
  • func (s *Conn) GetHostInfo() (h *file.Host, err error)
  • func (s *Conn) GetLen() (int, error)
  • func (s *Conn) GetLinkInfo() (lk *Link, err error)
  • func (s *Conn) GetShortContent(l int) (b []byte, err error)
  • func (s *Conn) GetShortLenContent() (b []byte, err error)
  • func (s *Conn) GetTaskInfo() (t *file.Tunnel, err error)
  • func (s *Conn) LocalAddr() net.Addr
  • func (s *Conn) Read(b []byte) (n int, err error)
  • func (s *Conn) ReadFlag() (string, error)
  • func (s *Conn) ReadLen(cLen int, buf []byte) (int, error)
  • func (s *Conn) RemoteAddr() net.Addr
  • func (s *Conn) SendHealthInfo(info, status string) (int, error)
  • func (s *Conn) SendInfo(t interface{}, flag string) (int, error)
  • func (s *Conn) SetAlive(tp string)
  • func (s *Conn) SetDeadline(t time.Time) error
  • func (s *Conn) SetReadDeadline(t time.Time) error
  • func (s *Conn) SetReadDeadlineBySecond(t time.Duration)
  • func (s *Conn) SetWriteDeadline(t time.Time) error
  • func (s *Conn) Write(b []byte) (int, error)
  • func (s *Conn) WriteAddFail() error
  • func (s *Conn) WriteAddOk() error
  • func (s *Conn) WriteChan() (int, error)
  • func (s *Conn) WriteClose() (int, error)
  • func (s *Conn) WriteConfig() (int, error)
  • func (s *Conn) WriteLenContent(buf []byte) (err error)
  • func (s *Conn) WriteMain() (int, error)
• type LenConn
  • func NewLenConn(conn io.Writer) *LenConn
  • func (c *LenConn) Write(p []byte) (n int, err error)
• type Link
  • func NewLink(connType string, host string, crypt bool, compress bool, remoteAddr string, ...) *Link
• type Option
  • func LinkTimeout(t time.Duration) Option
• type Options
• type Secret
  • func NewSecret(p string, conn *Conn) *Secret
• type SnappyConn
  • func NewSnappyConn(conn io.ReadWriteCloser) *SnappyConn
  • func (s *SnappyConn) Close() error
  • func (s *SnappyConn) Read(b []byte) (n int, err error)
  • func (s *SnappyConn) Write(b []byte) (n int, err error)

Functions

func Accept

func Accept(l net.Listener, f func(c net.Conn))

func CopyWaitGroup

func CopyWaitGroup(conn1, conn2 net.Conn, crypt bool, snappy bool, rate *rate.Rate, flow *file.Flow, isServer bool, rb []byte)

conn1 mux conn

func GetConn

func GetConn(conn net.Conn, cpt, snappy bool, rt *rate.Rate, isServer bool) io.ReadWriteCloser

get crypt or snappy conn

func GetLenBytes

func GetLenBytes(buf []byte) (b []byte, err error)

get the assembled amount data(len 4 and content)

func NewKcpListenerAndProcess

func NewKcpListenerAndProcess(addr string, f func(c net.Conn)) error

func NewTcpListenerAndProcess

func NewTcpListenerAndProcess(addr string, f func(c net.Conn), listener *net.Listener) error

func SetUdpSession

func SetUdpSession(sess *kcp.UDPSession)

udp connection setting

Types

type Conn

type Conn struct {
	Conn net.Conn
	Rb   []byte
}

func NewConn

func NewConn(conn net.Conn) *Conn

new conn

func (*Conn) Close

func (s *Conn) Close() error

close

func (*Conn) GetAddStatus

func (s *Conn) GetAddStatus() (b bool)

get task or host result of add

func (*Conn) GetConfigInfo

func (s *Conn) GetConfigInfo() (c *file.Client, err error)

get task info

func (*Conn) GetHealthInfo

func (s *Conn) GetHealthInfo() (info string, status bool, err error)

get health info from conn

func (*Conn) GetHost

func (s *Conn) GetHost() (method, address string, rb []byte, err error, r *http.Request)

get host 、connection type、method...from connection

func (*Conn) GetHostInfo

func (s *Conn) GetHostInfo() (h *file.Host, err error)

get task info

func (*Conn) GetLen

func (s *Conn) GetLen() (int, error)

func (*Conn) GetLinkInfo

func (s *Conn) GetLinkInfo() (lk *Link, err error)

get link info from conn

func (*Conn) GetShortContent

func (s *Conn) GetShortContent(l int) (b []byte, err error)

func (*Conn) GetShortLenContent

func (s *Conn) GetShortLenContent() (b []byte, err error)

func (*Conn) GetTaskInfo

func (s *Conn) GetTaskInfo() (t *file.Tunnel, err error)

get task info

func (*Conn) LocalAddr

func (s *Conn) LocalAddr() net.Addr

func (*Conn) Read

func (s *Conn) Read(b []byte) (n int, err error)

read

func (*Conn) ReadFlag

func (s *Conn) ReadFlag() (string, error)

read flag

func (*Conn) ReadLen

func (s *Conn) ReadLen(cLen int, buf []byte) (int, error)

读取指定长度内容

func (*Conn) RemoteAddr

func (s *Conn) RemoteAddr() net.Addr

func (*Conn) SendHealthInfo

func (s *Conn) SendHealthInfo(info, status string) (int, error)

send info for link

func (*Conn) SendInfo

func (s *Conn) SendInfo(t interface{}, flag string) (int, error)

send info

func (*Conn) SetAlive

func (s *Conn) SetAlive(tp string)

set alive

func (*Conn) SetDeadline

func (s *Conn) SetDeadline(t time.Time) error

func (*Conn) SetReadDeadline

func (s *Conn) SetReadDeadline(t time.Time) error

func (*Conn) SetReadDeadlineBySecond

func (s *Conn) SetReadDeadlineBySecond(t time.Duration)

set read deadline

func (*Conn) SetWriteDeadline

func (s *Conn) SetWriteDeadline(t time.Time) error

func (*Conn) Write

func (s *Conn) Write(b []byte) (int, error)

write

func (*Conn) WriteAddFail

func (s *Conn) WriteAddFail() error

func (*Conn) WriteAddOk

func (s *Conn) WriteAddOk() error

func (*Conn) WriteChan

func (s *Conn) WriteChan() (int, error)

write chan

func (*Conn) WriteClose

func (s *Conn) WriteClose() (int, error)

write sign flag

func (*Conn) WriteConfig

func (s *Conn) WriteConfig() (int, error)

write main

func (*Conn) WriteLenContent

func (s *Conn) WriteLenContent(buf []byte) (err error)

func (*Conn) WriteMain

func (s *Conn) WriteMain() (int, error)

write main

type LenConn

type LenConn struct {
	Len int
	// contains filtered or unexported fields
}

func NewLenConn

func NewLenConn(conn io.Writer) *LenConn

func (*LenConn) Write

func (c *LenConn) Write(p []byte) (n int, err error)

type Link

type Link struct {
	ConnType   string //连接类型
	Host       string //目标
	Crypt      bool   //加密
	Compress   bool
	LocalProxy bool
	RemoteAddr string
	Option     Options
}

func NewLink

func NewLink(connType string, host string, crypt bool, compress bool, remoteAddr string, localProxy bool, opts ...Option) *Link

type Option

type Option func(*Options)

func LinkTimeout

func LinkTimeout(t time.Duration) Option

type Options

type Options struct {
	Timeout time.Duration
}

type Secret

type Secret struct {
	Password string
	Conn     *Conn
}

func NewSecret

func NewSecret(p string, conn *Conn) *Secret

type SnappyConn

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

func NewSnappyConn

func NewSnappyConn(conn io.ReadWriteCloser) *SnappyConn

func (*SnappyConn) Close

func (s *SnappyConn) Close() error

func (*SnappyConn) Read

func (s *SnappyConn) Read(b []byte) (n int, err error)

snappy压缩读

func (*SnappyConn) Write

func (s *SnappyConn) Write(b []byte) (n int, err error)

snappy压缩写