emux

Dec 13, 2021

Changes in this version

+ func NewConn(stm io.ReadWriteCloser, localAddr net.Addr, remoteAddr net.Addr) net.Conn

Dec 5, 2021

Changes in this version

+ var DefaultIdleTimeout = 600 * time.Second

type Client

+ func (s Client) Clear()

+ func (s Client) IsClear() bool

type DialerSession

+ IdleTimeout time.Duration

+ func (d *DialerSession) Close() error

type Instruction

+ func (i Instruction) Info(cmd uint8) string

type ListenConfigSession

+ IdleTimeout time.Duration

type ListenerSession

+ IdleTimeout time.Duration

type Server

+ func (s Server) Clear()

+ func (s Server) IsClear() bool

Nov 20, 2021

Changes in this version

+ var ErrAlreadyStarted = fmt.Errorf("session already started")

type Server

+ func (s *Server) AcceptTo(acceptChan chan io.ReadWriteCloser) error

Nov 16, 2021

Changes in this version

type ListenerSession

+ func (l *ListenerSession) IsClosed() bool

Nov 16, 2021

Changes in this version

+ var DefaultTimeout = 10 * time.Second

type DialerSession

+ Timeout time.Duration

type ListenConfigSession

+ Timeout time.Duration

type ListenerSession

+ Timeout time.Duration

Nov 13, 2021

Changes in this version

+ type DecodeReader interface

type DialerSession

+ Retry int

+ type EncodeWriter interface

+ Flush func() error

type ListenConfigSession

+ func NewListenConfig(listener ListenConfig) *ListenConfigSession

Nov 12, 2021

Changes in this version

+ var DefaultInstruction = Instruction

type DialerSession

+ Instruction Instruction

+ type Instruction struct

+ Close uint8

+ Connect uint8

+ Connected uint8

+ Data uint8

+ Disconnect uint8

+ Disconnected uint8

+ MaxDataPacketSize uint64

type ListenConfigSession

+ Instruction Instruction

type ListenerSession

+ Instruction Instruction

Nov 10, 2021

Changes in this version

+ type Client struct

+ func NewClient(s io.ReadWriteCloser) *Client

+ func (c *Client) Dial(ctx context.Context) (io.ReadWriteCloser, error)

+ func (s *Client) Close() error

+ func (s *Client) IsClosed() bool

+ type Server struct

+ func NewServer(s io.ReadWriteCloser) *Server

+ func (s *Server) Accept(ctx context.Context) (io.ReadWriteCloser, error)

+ func (s *Server) Close() error

+ func (s *Server) IsClosed() bool

Nov 10, 2021

Changes in this version

+ var DefaultClientHandshake = NewHandshake(HandshakeData, true)

+ var DefaultServerHandshake = NewHandshake(HandshakeData, false)

Nov 9, 2021

Changes in this version

type Cmd

+ const CmdClose

Nov 9, 2021

Changes in this version

+ var ErrClosed = errors.New("closed")

type Session

+ Timeout time.Duration

Nov 9, 2021

Changes in this version

+ var ErrInvalidStream = fmt.Errorf("invalid stream")

Nov 8, 2021

Changes in this version

+ var DefaultHandshake = NewHandshake(HandshakeData)

+ var ErrTimeout = fmt.Errorf("timeout")

+ var HandshakeData = []byte("EMUX ")

+ type BytesPool interface

+ Get func() []byte

+ Put func([]byte)

+ type Cmd uint8

+ const CmdConnect

+ const CmdConnected

+ const CmdData

+ const CmdDisconnect

+ const CmdDisconnected

+ func (i Cmd) String() string

+ type Decode struct

+ func NewDecode(r io.Reader) *Decode

+ func (d *Decode) ReadByte() (byte, error)

+ func (d *Decode) ReadBytes() ([]byte, error)

+ func (d *Decode) ReadUvarint() (uint64, error)

+ func (d *Decode) WriteTo(w io.Writer, buf []byte) (int64, error)

+ type Dialer interface

+ DialContext func(ctx context.Context, network, address string) (net.Conn, error)

+ type DialerSession struct

+ BytesPool BytesPool

+ Handshake Handshake

+ Logger Logger

+ func NewDialer(dialer Dialer) *DialerSession

+ func (d *DialerSession) DialContext(ctx context.Context, network, address string) (net.Conn, error)

+ type Encode struct

+ func NewEncode(w io.Writer) *Encode

+ func (e *Encode) Flush() error

+ func (e *Encode) WriteByte(b byte) error

+ func (e *Encode) WriteBytes(b []byte) error

+ func (e *Encode) WriteCmd(cmd Cmd, sid uint64) error

+ func (e *Encode) WriteUvarint(v uint64) error

+ type Handshake interface

+ Handshake func(rw io.ReadWriter) error

+ func NewHandshake(h []byte) Handshake

+ type ListenConfig interface

+ Listen func(ctx context.Context, network, address string) (net.Listener, error)

+ type ListenConfigSession struct

+ BytesPool BytesPool

+ Handshake Handshake

+ Logger Logger

+ func NewListenerConfig(listener ListenConfig) *ListenConfigSession

+ func (l *ListenConfigSession) Listen(ctx context.Context, network, address string) (net.Listener, error)

+ type ListenerSession struct

+ BytesPool BytesPool

+ Handshake Handshake

+ Logger Logger

+ func NewListener(ctx context.Context, listener net.Listener) *ListenerSession

+ func (l *ListenerSession) Accept() (net.Conn, error)

+ func (l *ListenerSession) Addr() net.Addr

+ func (l *ListenerSession) Close() error

+ type Logger interface

+ Println func(v ...interface{})

+ type Session struct

+ BytesPool BytesPool

+ Logger Logger

+ func NewSession(s io.ReadWriteCloser) *Session

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

+ func (s *Session) Close() error

+ func (s *Session) IsClosed() bool

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