mux

package

Go to main page

Versions in this module

v0

v0.30.0

Oct 29, 2017

Changes in this version

type ConnectRequest

+ DialTimeout int

+ Hops []string

+ ReadTimeout int

+ type StreamOptions struct

+ DialTimeout int

+ Hops []string

+ ReadTimeout int

v0.29.0

Oct 18, 2017

Changes in this version

type MuxStream

+ SetReadDeadline func(t time.Time) error

+ SetWriteDeadline func(t time.Time) error

+ type TimeoutReadWriteCloser interface

+ SetReadDeadline func(t time.Time) error

+ SetWriteDeadline func(t time.Time) error

v0.28.0

Sep 10, 2017

v0.27.3

Sep 5, 2017

v0.27.2

Sep 3, 2017

Changes in this version

+ type HTTP2MuxSession struct

+ AcceptCh chan MuxStream

+ ServerHost string

+ func NewHTTP2ServerMuxSession(conn net.Conn) *HTTP2MuxSession

+ func (q *HTTP2MuxSession) AcceptStream() (MuxStream, error)

+ func (q *HTTP2MuxSession) Close() error

+ func (q *HTTP2MuxSession) CloseStream(stream MuxStream) error

+ func (q *HTTP2MuxSession) NumStreams() int

+ func (q *HTTP2MuxSession) OfferStream(stream io.ReadWriteCloser) error

+ func (q *HTTP2MuxSession) OpenStream() (MuxStream, error)

+ func (q *HTTP2MuxSession) Ping() (time.Duration, error)

type MuxSession

+ func NewHTTP2ClientMuxSession(conn net.Conn, host string) (MuxSession, error)

+ Ping func() (time.Duration, error)

type QUICMuxSession

+ func (q *QUICMuxSession) Ping() (time.Duration, error)

v0.27.0

Aug 27, 2017

Changes in this version

+ const AuthOK

+ const DefaultMuxCipherMethod

+ const DefaultMuxInitialCipherCounter

+ const HTTPMuxPullPeriodHeader

+ const HTTPMuxSessionACKIDHeader

+ const HTTPMuxSessionIDHeader

+ const NoneCompressor

+ const SnappyCompressor

+ var ErrAuthFailed = errors.New("auth failed")

+ var ErrDataReadMissing = errors.New("auth failed")

+ var ErrToolargeMessage = errors.New("too large message length")

+ func GetCompressStreamReaderWriter(stream MuxStream, method string) (io.Reader, io.Writer)

+ func IsValidCompressor(method string) bool

+ func ReadMessage(stream io.Reader, res interface{}) error

+ func WriteMessage(stream io.Writer, req interface{}) error

+ type AuthRequest struct

+ CipherCounter uint64

+ CipherMethod string

+ CompressMethod string

+ Rand string

+ User string

+ func ReadAuthRequest(stream io.Reader) (*AuthRequest, error)

+ type AuthResponse struct

+ Code int

+ type ConnectRequest struct

+ Addr string

+ Network string

+ func ReadConnectRequest(stream io.Reader) (*ConnectRequest, error)

+ type MuxSession interface

+ AcceptStream func() (MuxStream, error)

+ Close func() error

+ CloseStream func(stream MuxStream) error

+ NumStreams func() int

+ OpenStream func() (MuxStream, error)

+ type MuxStream interface

+ Auth func(req *AuthRequest) error

+ Connect func(network string, addr string) error

+ StreamID func() uint32

+ type ProxyMuxSession struct

+ func (s *ProxyMuxSession) AcceptStream() (MuxStream, error)

+ func (s *ProxyMuxSession) CloseStream(stream MuxStream) error

+ func (s *ProxyMuxSession) OpenStream() (MuxStream, error)

+ type ProxyMuxStream struct

+ func (s *ProxyMuxStream) Auth(req *AuthRequest) error

+ func (s *ProxyMuxStream) Close() error

+ func (s *ProxyMuxStream) Connect(network string, addr string) error

+ func (s *ProxyMuxStream) StreamID() uint32

+ type QUICMuxSession struct

+ func (q *QUICMuxSession) AcceptStream() (MuxStream, error)

+ func (q *QUICMuxSession) Close() error

+ func (q *QUICMuxSession) CloseStream(stream MuxStream) error

+ func (q *QUICMuxSession) NumStreams() int

+ func (q *QUICMuxSession) OpenStream() (MuxStream, error)

+ type WsConn struct

+ func (ws *WsConn) Read(p []byte) (int, error)

+ func (ws *WsConn) Write(p []byte) (int, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL