mux

Documentation

Index

• func NewClient(config *protocol.Mux, dialer netapi.Proxy) (netapi.Proxy, error)
• func NewRangeSelector(cap int) *rangeSelector
• func NewServer(config *listener.Mux, ii netapi.Listener) (netapi.Listener, error)
• type IdleSession
  • func NewIdleSession(session *yamux.Session, IdleTimeout time.Duration) *IdleSession
  • func (i *IdleSession) Close() error
  • func (i *IdleSession) IsClosed() bool
  • func (i *IdleSession) Open(ctx context.Context) (net.Conn, error)
  • func (i *IdleSession) OpenStream(ctx context.Context) (*yamux.Stream, error)
• type MuxAddr
  • func (q *MuxAddr) Network() string
  • func (q *MuxAddr) String() string
• type MuxClient
  • func (m *MuxClient) Conn(ctx context.Context, addr netapi.Address) (net.Conn, error)
• type MuxConn
• type MuxServer
  • func (m *MuxServer) Accept() (net.Conn, error)
  • func (m *MuxServer) Close() error
  • func (m *MuxServer) Run() error

Functions

func NewClient

func NewClient(config *protocol.Mux, dialer netapi.Proxy) (netapi.Proxy, error)

func NewRangeSelector

func NewRangeSelector(cap int) *rangeSelector

func NewServer

func NewServer(config *listener.Mux, ii netapi.Listener) (netapi.Listener, error)

Types

type IdleSession

type IdleSession struct {
	*yamux.Session
	// contains filtered or unexported fields
}

func NewIdleSession

func NewIdleSession(session *yamux.Session, IdleTimeout time.Duration) *IdleSession

func (*IdleSession) Close

func (i *IdleSession) Close() error

func (*IdleSession) IsClosed

func (i *IdleSession) IsClosed() bool

func (*IdleSession) Open

func (i *IdleSession) Open(ctx context.Context) (net.Conn, error)

func (*IdleSession) OpenStream

func (i *IdleSession) OpenStream(ctx context.Context) (*yamux.Stream, error)

type MuxAddr

type MuxAddr struct {
	Addr net.Addr
	ID   uint32
}

func (*MuxAddr) Network

func (q *MuxAddr) Network() string

func (*MuxAddr) String

func (q *MuxAddr) String() string

type MuxClient

type MuxClient struct {
	netapi.Proxy
	// contains filtered or unexported fields
}

func (*MuxClient) Conn

func (m *MuxClient) Conn(ctx context.Context, addr netapi.Address) (net.Conn, error)

type MuxConn

type MuxConn interface {
	net.Conn
	StreamID() uint32
}

type MuxServer

type MuxServer struct {
	net.Listener
	// contains filtered or unexported fields
}

func (*MuxServer) Accept

func (m *MuxServer) Accept() (net.Conn, error)

func (*MuxServer) Close

func (m *MuxServer) Close() error

func (*MuxServer) Run

func (m *MuxServer) Run() error