smux

Nov 25, 2021

Changes in this version

+ var ErrConsumed = errors.New("peer consumed more than sent")

+ var ErrGoAway = errors.New("stream id overflows, should start a new connection")

+ var ErrInvalidProtocol = errors.New("invalid protocol")

+ var ErrTimeout = errors.New("timeout")

+ var ErrWouldBlock = errors.New("operation would block on IO")

type Config

+ IdleTimeout time.Duration

+ KeepAliveDisabled bool

+ MaxStreamBuffer int

+ Version int

type Stream

+ func (s *Stream) WriteTo(w io.Writer) (n int64, err error)

Sep 21, 2019

Changes in this version

type Session

+ func (s *Session) Open() (io.ReadWriteCloser, error)

Sep 21, 2019

Changes in this version

type Session

+ func (s *Session) Accept() (io.ReadWriteCloser, error)

May 14, 2019

Changes in this version

type Session

+ func (s *Session) LocalAddr() net.Addr

+ func (s *Session) RemoteAddr() net.Addr

May 14, 2019

Changes in this version

+ type Allocator struct

+ func NewAllocator() *Allocator

+ func (alloc *Allocator) Get(size int) []byte

+ func (alloc *Allocator) Put(buf []byte) error

Feb 12, 2019

Changes in this version

type Stream

+ func (s *Stream) GetDieCh() <-chan struct{}

Mar 22, 2017

Changes in this version

type Stream

+ func (s *Stream) ID() uint32

Nov 29, 2016

Changes in this version

type Session

+ func (s *Session) SetDeadline(t time.Time) error

type Stream

+ func (s *Stream) LocalAddr() net.Addr

+ func (s *Stream) RemoteAddr() net.Addr

+ func (s *Stream) SetDeadline(t time.Time) error

+ func (s *Stream) SetReadDeadline(t time.Time) error

+ func (s *Stream) SetWriteDeadline(t time.Time) error

Sep 7, 2016

Changes in this version

+ func VerifyConfig(config *Config) error

+ type Config struct

+ KeepAliveInterval time.Duration

+ KeepAliveTimeout time.Duration

+ MaxFrameSize int

+ MaxReceiveBuffer int

+ func DefaultConfig() *Config

+ type Frame struct

+ func (f *Frame) MarshalBinary() ([]byte, error)

+ func (f *Frame) UnmarshalBinary(bts []byte) error

+ type Session struct

+ func Client(conn io.ReadWriteCloser, config *Config) (*Session, error)

+ func Server(conn io.ReadWriteCloser, config *Config) (*Session, error)

+ func (s *Session) AcceptStream() (*Stream, error)

+ func (s *Session) Close() (err error)

+ func (s *Session) IsClosed() bool

+ func (s *Session) NumStreams() int

+ func (s *Session) OpenStream() (*Stream, error)

+ type Stream struct

+ func (s *Stream) Close() error

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

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