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 (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
- type Link
- type Option
- type Options
- type Secret
- type SnappyConn
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CopyWaitGroup ¶ added in v0.18.0
func CopyWaitGroup(conn1, conn2 net.Conn, crypt bool, snappy bool, rate *rate.Rate, flow *file.Flow, isServer bool, rb []byte)
conn1 mux conn
func GetLenBytes ¶
get the assembled amount data(len 4 and content)
func NewKcpListenerAndProcess ¶ added in v0.19.0
func NewTcpListenerAndProcess ¶ added in v0.19.0
Types ¶
type Conn ¶
func (*Conn) GetAddStatus ¶ added in v0.0.15
get task or host result of add
func (*Conn) GetConfigInfo ¶ added in v0.0.15
get task info
func (*Conn) GetHealthInfo ¶ added in v0.18.1
get health info from conn
func (*Conn) GetHostInfo ¶ added in v0.0.15
get task info
func (*Conn) GetLinkInfo ¶
get link info from conn
func (*Conn) GetShortContent ¶ added in v0.18.0
func (*Conn) GetShortLenContent ¶ added in v0.18.0
func (*Conn) RemoteAddr ¶ added in v0.21.0
func (*Conn) SendHealthInfo ¶ added in v0.18.1
send info for link
func (*Conn) SetReadDeadlineBySecond ¶ added in v0.21.0
set read deadline
func (*Conn) WriteAddFail ¶ added in v0.0.15
func (*Conn) WriteAddOk ¶ added in v0.0.15
func (*Conn) WriteLenContent ¶ added in v0.18.0
type LenConn ¶ added in v0.22.3
type LenConn struct { Len int // contains filtered or unexported fields }
func NewLenConn ¶ added in v0.22.3
type Link ¶
type SnappyConn ¶
type SnappyConn struct {
// contains filtered or unexported fields
}
func NewSnappyConn ¶
func NewSnappyConn(conn io.ReadWriteCloser) *SnappyConn
func (*SnappyConn) Close ¶ added in v0.18.0
func (s *SnappyConn) Close() error
Click to show internal directories.
Click to hide internal directories.