mux

package

v0.3.5 Latest Latest Go to latest Published: May 1, 2024 License: MIT Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

func NewClient(config *protocol.Protocol_Mux) point.WrapProxy

func NewRangeSelector(cap int) *rangeSelector

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

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

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

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 struct {
	Addr net.Addr
	ID   uint32
}

func (q *MuxAddr) Network() string

func (q *MuxAddr) String() string

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

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

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

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

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

func (m *MuxServer) Close() error

func (m *MuxServer) Run() error