internal

Documentation

Index

• func NewMuxHandler(relayType string) *muxHandler
• type HandshakeMsg
  • func UnmarshalHandshakeMsg(r io.Reader) (*HandshakeMsg, error)
  • func (m *HandshakeMsg) WriteTo(w io.Writer) error
• type LocalProxy
  • func NewLocalProxy(serverAddr string) *LocalProxy
  • func (lp *LocalProxy) BitwiseCopy(cc, sc net.Conn) error
  • func (lp *LocalProxy) DialNormalStream(host string) (net.Conn, error)
  • func (lp *LocalProxy) H2ServerCopy(cc net.Conn) error
• type MuxServerConnDialer
  • func NewMuxServerConnDialer(serverAddr, protocol string, maxConnections int) *MuxServerConnDialer
  • func (d *MuxServerConnDialer) DialNormalStream(host string) (net.Conn, error)
  • func (d *MuxServerConnDialer) DialPrefetchStream(host string) (net.Conn, error)
• type StreamType

Functions

func NewMuxHandler

func NewMuxHandler(relayType string) *muxHandler

Types

type HandshakeMsg

type HandshakeMsg struct {
	StreamType StreamType
}

func UnmarshalHandshakeMsg

func UnmarshalHandshakeMsg(r io.Reader) (*HandshakeMsg, error)

func (*HandshakeMsg) WriteTo

func (m *HandshakeMsg) WriteTo(w io.Writer) error

type LocalProxy

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

func NewLocalProxy

func NewLocalProxy(serverAddr string) *LocalProxy

func (*LocalProxy) BitwiseCopy

func (lp *LocalProxy) BitwiseCopy(cc, sc net.Conn) error

func (*LocalProxy) DialNormalStream

func (lp *LocalProxy) DialNormalStream(host string) (net.Conn, error)

func (*LocalProxy) H2ServerCopy

func (lp *LocalProxy) H2ServerCopy(cc net.Conn) error

type MuxServerConnDialer

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

func NewMuxServerConnDialer

func NewMuxServerConnDialer(serverAddr, protocol string, maxConnections int) *MuxServerConnDialer

func (*MuxServerConnDialer) DialNormalStream

func (d *MuxServerConnDialer) DialNormalStream(host string) (net.Conn, error)

func (*MuxServerConnDialer) DialPrefetchStream

func (d *MuxServerConnDialer) DialPrefetchStream(host string) (net.Conn, error)

type StreamType

type StreamType int

const (
	StreamTypeNormal StreamType = iota
	StreamTypePrefetch
)