smux

Dec 26, 2019

Changes in this version

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

+ var ErrInvalidOperation = errors.New("invalid parameters on poll")

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

type Session

+ func (s *Session) PollWait(events []*Stream) (int, error)

type Stream

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

Nov 26, 2019

Changes in this version

type Stream

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

Sep 22, 2019

Changes in this version

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

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

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

Sep 21, 2019

Changes in this version

+ func VerifyConfig(config *Config) error

+ type Allocator struct

+ func NewAllocator() *Allocator

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

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

+ type Config struct

+ KeepAliveInterval time.Duration

+ KeepAliveTimeout time.Duration

+ MaxFrameSize int

+ MaxReceiveBuffer int

+ MaxStreamBuffer int

+ Version int

+ func DefaultConfig() *Config

+ type Frame struct

+ type Session struct

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

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

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

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

+ func (s *Session) Close() error

+ func (s *Session) IsClosed() bool

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

+ func (s *Session) NumStreams() int

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

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

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

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

+ type Stream struct

+ func (s *Stream) Close() error

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

+ func (s *Stream) ID() uint32

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

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

+ 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

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