Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mux

package

Go to main page

Versions in this module

v0

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)