smux

Oct 22, 2024

Changes in this version

+ func Copy(dst io.Writer, src io.Reader) (written int64, err error)

+ func Pipe(alice, bob io.ReadWriteCloser, closeWait int) (errA, errB error)

Oct 12, 2024

Changes in this version

+ var ErrInvalidHeader = errors.New("header decryption failed")

+ func Abs(i int) int

+ func KPipe(alice, bob io.ReadWriteCloser, closeWait int) (errA, errB error)

+ func NPipe(src, dst io.ReadWriteCloser)

Sep 29, 2024

Changes in this version

type Session

+ UnlockKA bool

Apr 23, 2024

Changes in this version

type Session

+ func (s *Session) Recycler()

Jan 15, 2024

Changes in this version

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

+ var ErrDecryptFailed = errors.New("data decryption failed")

+ 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")

+ func ChunkBytes(b []byte, chunkSize int) [][]byte

+ func NewEncryptedHeader(k *Keyring) *encryptedHeader

+ func SHA256(b []byte) []byte

+ func VerifyConfig(config *Config) error

+ func XORBytes(a, b []byte) []byte

+ type Allocator struct

+ func NewAllocator() *Allocator

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

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

+ type CLASSID int

+ const CLSCTRL

+ const CLSDATA

+ type Config struct

+ KeepAliveDisabled bool

+ KeepAliveInterval time.Duration

+ KeepAliveTimeout time.Duration

+ MaxFrameSize int

+ MaxReceiveBuffer int

+ MaxStreamBuffer int

+ Version int

+ func DefaultConfig() *Config

+ type Frame struct

+ type Keyring struct

+ func NewKeyring(s string) *Keyring

+ func (k *Keyring) Extract(iv []byte, s string) []byte

+ type Session struct

+ ClientRN [24]byte

+ ClientSN [24]byte

+ NaclKey [32]byte

+ ServerRN [24]byte

+ ServerSN [24]byte

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

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

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

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

+ func (s *Session) Close() error

+ func (s *Session) CloseChan() <-chan struct{}

+ 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)

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