mux

package

v2.21.3+incompatible Latest Latest Go to latest Published: Apr 5, 2017 License: MIT Imports: 14 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type AddressType byte

const (
	AddressTypeIPv4   AddressType = 0x01
	AddressTypeDomain AddressType = 0x02
	AddressTypeIPv6   AddressType = 0x03
)

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

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

func (m *Client) Closed() bool

func (m *Client) Dispatch(ctx context.Context, outboundRay ray.OutboundRay) bool

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

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

func (m *ClientManager) Dispatch(ctx context.Context, outboundRay ray.OutboundRay) error

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

func ReadFrameFrom(b []byte) (*FrameMetadata, error)

func (f FrameMetadata) AsSupplier() buf.Supplier

type Option byte

const (
	OptionData Option = 0x01
)

func (o *Option) Add(x Option)

func (o *Option) Clear(x Option)

func (o Option) Has(x Option) bool

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

func NewReader(reader buf.Reader) *Reader

func (r *Reader) Read() (*buf.Buffer, bool, error)

func (r *Reader) ReadMetadata() (*FrameMetadata, error)

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

func NewServer(ctx context.Context) *Server

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

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

type SessionStatus byte

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

type TargetNetwork byte

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

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

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

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

func (w *Writer) Close()

func (w *Writer) Write(b *buf.Buffer) error