mux

Documentation

Index

• Constants
• func NewStreamReader(reader *buf.BufferedReader) buf.Reader
• type Client
  • func NewClient(pctx context.Context, p proxy.Outbound, dialer proxy.Dialer, m *ClientManager) (*Client, error)
  • func (m *Client) Closed() bool
  • func (m *Client) Dispatch(ctx context.Context, link *core.Link) bool
• type ClientManager
  • func NewClientManager(p proxy.Outbound, d proxy.Dialer, c *proxyman.MultiplexingConfig) *ClientManager
  • func (m *ClientManager) Dispatch(ctx context.Context, link *core.Link) error
• type FrameMetadata
  • func ReadFrameFrom(b *buf.Buffer) (*FrameMetadata, error)
  • func ReadMetadata(reader io.Reader) (*FrameMetadata, error)
  • func (f FrameMetadata) WriteTo(b *buf.Buffer) error
• type PacketReader
  • func NewPacketReader(reader io.Reader) *PacketReader
  • func (r *PacketReader) ReadMultiBuffer() (buf.MultiBuffer, error)
• type Server
  • func NewServer(ctx context.Context) *Server
  • func (s *Server) Close() error
  • func (s *Server) Dispatch(ctx context.Context, dest net.Destination) (*core.Link, error)
  • func (s *Server) Start() error
• type ServerWorker
• type Session
  • func (s *Session) Close() error
  • func (s *Session) NewReader(reader *buf.BufferedReader) buf.Reader
• type SessionManager
  • func NewSessionManager() *SessionManager
  • func (m *SessionManager) Add(s *Session)
  • func (m *SessionManager) Allocate() *Session
  • func (m *SessionManager) Close() error
  • func (m *SessionManager) CloseIfNoSession() bool
  • func (m *SessionManager) Count() int
  • func (m *SessionManager) Get(id uint16) (*Session, bool)
  • func (m *SessionManager) Remove(id uint16)
  • func (m *SessionManager) Size() int
• type SessionStatus
• type TargetNetwork
• type Writer
  • func NewResponseWriter(id uint16, writer buf.Writer, transferType protocol.TransferType) *Writer
  • func NewWriter(id uint16, dest net.Destination, writer buf.Writer, ...) *Writer
  • func (w *Writer) Close() error
  • func (w *Writer) WriteMultiBuffer(mb buf.MultiBuffer) error

Constants

const (
	OptionData  bitmask.Byte = 0x01
	OptionError bitmask.Byte = 0x02
)

Functions

func NewStreamReader

func NewStreamReader(reader *buf.BufferedReader) buf.Reader

NewStreamReader creates a new StreamReader.

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(pctx context.Context, p proxy.Outbound, dialer proxy.Dialer, m *ClientManager) (*Client, error)

NewClient creates a new mux.Client.

func (*Client) Closed

func (m *Client) Closed() bool

Closed returns true if this Client is closed.

func (*Client) Dispatch

func (m *Client) Dispatch(ctx context.Context, link *core.Link) bool

type ClientManager

type ClientManager struct {
	// contains filtered or unexported fields
}

func NewClientManager

func NewClientManager(p proxy.Outbound, d proxy.Dialer, c *proxyman.MultiplexingConfig) *ClientManager

func (*ClientManager) Dispatch

func (m *ClientManager) Dispatch(ctx context.Context, link *core.Link) error

type FrameMetadata

type FrameMetadata struct {
	Target        net.Destination
	SessionID     uint16
	Option        bitmask.Byte
	SessionStatus SessionStatus
}

func ReadFrameFrom

func ReadFrameFrom(b *buf.Buffer) (*FrameMetadata, error)

ReadFrameFrom reads a FrameMetadata from the given buffer. Visible for testing only.

func ReadMetadata

func ReadMetadata(reader io.Reader) (*FrameMetadata, error)

ReadMetadata reads FrameMetadata from the given reader.

func (FrameMetadata) WriteTo

func (f FrameMetadata) WriteTo(b *buf.Buffer) error

type PacketReader

type PacketReader struct {
	// contains filtered or unexported fields
}

PacketReader is an io.Reader that reads whole chunk of Mux frames every time.

func NewPacketReader

func NewPacketReader(reader io.Reader) *PacketReader

NewPacketReader creates a new PacketReader.

func (*PacketReader) ReadMultiBuffer

func (r *PacketReader) ReadMultiBuffer() (buf.MultiBuffer, error)

ReadMultiBuffer implements buf.Reader.

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context) *Server

NewServer creates a new mux.Server.

func (*Server) Close

func (s *Server) Close() error

Close implements common.Closable.

func (*Server) Dispatch

func (s *Server) Dispatch(ctx context.Context, dest net.Destination) (*core.Link, error)

func (*Server) Start

func (s *Server) Start() error

Start implements common.Runnable.

type ServerWorker

type ServerWorker struct {
	// contains filtered or unexported fields
}

type Session

type Session struct {
	ID uint16
	// contains filtered or unexported fields
}

Session represents a client connection in a Mux connection.

func (*Session) Close

func (s *Session) Close() error

Close closes all resources associated with this session.

func (*Session) NewReader

func (s *Session) NewReader(reader *buf.BufferedReader) buf.Reader

NewReader creates a buf.Reader based on the transfer type of this Session.

type SessionManager

type SessionManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewSessionManager

func NewSessionManager() *SessionManager

func (*SessionManager) Add

func (m *SessionManager) Add(s *Session)

func (*SessionManager) Allocate

func (m *SessionManager) Allocate() *Session

func (*SessionManager) Close

func (m *SessionManager) Close() error

func (*SessionManager) CloseIfNoSession

func (m *SessionManager) CloseIfNoSession() bool

func (*SessionManager) Count

func (m *SessionManager) Count() int

func (*SessionManager) Get

func (m *SessionManager) Get(id uint16) (*Session, bool)

func (*SessionManager) Remove

func (m *SessionManager) Remove(id uint16)

func (*SessionManager) Size

func (m *SessionManager) Size() int

type SessionStatus

type SessionStatus byte

const (
	SessionStatusNew       SessionStatus = 0x01
	SessionStatusKeep      SessionStatus = 0x02
	SessionStatusEnd       SessionStatus = 0x03
	SessionStatusKeepAlive SessionStatus = 0x04
)

type TargetNetwork

type TargetNetwork byte

const (
	TargetNetworkTCP TargetNetwork = 0x01
	TargetNetworkUDP TargetNetwork = 0x02
)

type Writer

type Writer struct {
	// contains filtered or unexported fields
}

func NewResponseWriter

func NewResponseWriter(id uint16, writer buf.Writer, transferType protocol.TransferType) *Writer

func NewWriter

func NewWriter(id uint16, dest net.Destination, writer buf.Writer, transferType protocol.TransferType) *Writer

func (*Writer) Close

func (w *Writer) Close() error

Close implements common.Closable.

func (*Writer) WriteMultiBuffer

func (w *Writer) WriteMultiBuffer(mb buf.MultiBuffer) error

WriteMultiBuffer implements buf.Writer.