singbridge

Documentation

Index

• func CopyConn(ctx context.Context, inboundConn net.Conn, link *transport.Link, ...) error
• func CopyPacketConn(ctx context.Context, inboundConn net.Conn, link *transport.Link, ...) error
• func ReturnError(err error) error
• func ToDestination(socksaddr M.Socksaddr, network net.Network) net.Destination
• func ToNetwork(network string) net.Network
• func ToSocksaddr(destination net.Destination) M.Socksaddr
• type Conn
  • func NewConn(conn net.Conn) *Conn
  • func (c *Conn) ReadMultiBuffer() (buf.MultiBuffer, error)
  • func (c *Conn) ReadMultiBufferTimeout(duration time.Duration) (buf.MultiBuffer, error)
  • func (c *Conn) WriteMultiBuffer(bufferList buf.MultiBuffer) error
• type Dispatcher
  • func NewDispatcher(dispatcher routing.Dispatcher, newErrorFunc func(values ...any) *errors.Error) *Dispatcher
  • func (d *Dispatcher) NewConnection(ctx context.Context, conn net.Conn, metadata M.Metadata) error
  • func (d *Dispatcher) NewError(ctx context.Context, err error)
  • func (d *Dispatcher) NewPacketConnection(ctx context.Context, conn N.PacketConn, metadata M.Metadata) error
• type PacketConnWrapper
  • func (w *PacketConnWrapper) Close() error
  • func (w *PacketConnWrapper) ReadPacket(buffer *B.Buffer) (M.Socksaddr, error)
  • func (w *PacketConnWrapper) WritePacket(buffer *B.Buffer, destination M.Socksaddr) error
• type PipeConnWrapper
  • func (w *PipeConnWrapper) Close() error
  • func (w *PipeConnWrapper) Read(b []byte) (n int, err error)
  • func (w *PipeConnWrapper) Write(p []byte) (n int, err error)
• type XrayDialer
  • func NewDialer(dialer internet.Dialer) *XrayDialer
  • func (d *XrayDialer) DialContext(ctx context.Context, network string, destination M.Socksaddr) (net.Conn, error)
  • func (d *XrayDialer) ListenPacket(ctx context.Context, destination M.Socksaddr) (net.PacketConn, error)
• type XrayLogger
  • func NewLogger(newErrorFunc func(values ...any) *errors.Error) *XrayLogger
  • func (l *XrayLogger) Debug(args ...any)
  • func (l *XrayLogger) DebugContext(ctx context.Context, args ...any)
  • func (l *XrayLogger) Error(args ...any)
  • func (l *XrayLogger) ErrorContext(ctx context.Context, args ...any)
  • func (l *XrayLogger) Fatal(args ...any)
  • func (l *XrayLogger) FatalContext(ctx context.Context, args ...any)
  • func (l *XrayLogger) Info(args ...any)
  • func (l *XrayLogger) InfoContext(ctx context.Context, args ...any)
  • func (l *XrayLogger) Panic(args ...any)
  • func (l *XrayLogger) PanicContext(ctx context.Context, args ...any)
  • func (l *XrayLogger) Trace(args ...any)
  • func (l *XrayLogger) TraceContext(ctx context.Context, args ...any)
  • func (l *XrayLogger) Warn(args ...any)
  • func (l *XrayLogger) WarnContext(ctx context.Context, args ...any)
• type XrayOutboundDialer
  • func NewOutboundDialer(outbound proxy.Outbound, dialer internet.Dialer) *XrayOutboundDialer
  • func (d *XrayOutboundDialer) DialContext(ctx context.Context, network string, destination M.Socksaddr) (net.Conn, error)
  • func (d *XrayOutboundDialer) ListenPacket(ctx context.Context, destination M.Socksaddr) (net.PacketConn, error)

Functions

func CopyConn

func CopyConn(ctx context.Context, inboundConn net.Conn, link *transport.Link, serverConn net.Conn) error

func CopyPacketConn

func CopyPacketConn(ctx context.Context, inboundConn net.Conn, link *transport.Link, destination net.Destination, serverConn net.PacketConn) error

func ReturnError

func ReturnError(err error) error

func ToDestination

func ToDestination(socksaddr M.Socksaddr, network net.Network) net.Destination

func ToNetwork

func ToNetwork(network string) net.Network

func ToSocksaddr

func ToSocksaddr(destination net.Destination) M.Socksaddr

Types

type Conn

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

func NewConn

func NewConn(conn net.Conn) *Conn

func (*Conn) ReadMultiBuffer

func (c *Conn) ReadMultiBuffer() (buf.MultiBuffer, error)

func (*Conn) ReadMultiBufferTimeout

func (c *Conn) ReadMultiBufferTimeout(duration time.Duration) (buf.MultiBuffer, error)

func (*Conn) WriteMultiBuffer

func (c *Conn) WriteMultiBuffer(bufferList buf.MultiBuffer) error

type Dispatcher

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

func NewDispatcher

func NewDispatcher(dispatcher routing.Dispatcher, newErrorFunc func(values ...any) *errors.Error) *Dispatcher

func (*Dispatcher) NewConnection

func (d *Dispatcher) NewConnection(ctx context.Context, conn net.Conn, metadata M.Metadata) error

func (*Dispatcher) NewError

func (d *Dispatcher) NewError(ctx context.Context, err error)

func (*Dispatcher) NewPacketConnection

func (d *Dispatcher) NewPacketConnection(ctx context.Context, conn N.PacketConn, metadata M.Metadata) error

type PacketConnWrapper

type PacketConnWrapper struct {
	buf.Reader
	buf.Writer
	net.Conn
	Dest net.Destination
	// contains filtered or unexported fields
}

func (*PacketConnWrapper) Close

func (w *PacketConnWrapper) Close() error

func (*PacketConnWrapper) ReadPacket

func (w *PacketConnWrapper) ReadPacket(buffer *B.Buffer) (M.Socksaddr, error)

func (*PacketConnWrapper) WritePacket

func (w *PacketConnWrapper) WritePacket(buffer *B.Buffer, destination M.Socksaddr) error

type PipeConnWrapper

type PipeConnWrapper struct {
	R io.Reader
	W buf.Writer
	net.Conn
}

func (*PipeConnWrapper) Close

func (w *PipeConnWrapper) Close() error

func (*PipeConnWrapper) Read

func (w *PipeConnWrapper) Read(b []byte) (n int, err error)

func (*PipeConnWrapper) Write

func (w *PipeConnWrapper) Write(p []byte) (n int, err error)

type XrayDialer

type XrayDialer struct {
	internet.Dialer
}

func NewDialer

func NewDialer(dialer internet.Dialer) *XrayDialer

func (*XrayDialer) DialContext

func (d *XrayDialer) DialContext(ctx context.Context, network string, destination M.Socksaddr) (net.Conn, error)

func (*XrayDialer) ListenPacket

func (d *XrayDialer) ListenPacket(ctx context.Context, destination M.Socksaddr) (net.PacketConn, error)

type XrayLogger

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

func NewLogger

func NewLogger(newErrorFunc func(values ...any) *errors.Error) *XrayLogger

func (*XrayLogger) Debug

func (l *XrayLogger) Debug(args ...any)

func (*XrayLogger) DebugContext

func (l *XrayLogger) DebugContext(ctx context.Context, args ...any)

func (*XrayLogger) Error

func (l *XrayLogger) Error(args ...any)

func (*XrayLogger) ErrorContext

func (l *XrayLogger) ErrorContext(ctx context.Context, args ...any)

func (*XrayLogger) Fatal

func (l *XrayLogger) Fatal(args ...any)

func (*XrayLogger) FatalContext

func (l *XrayLogger) FatalContext(ctx context.Context, args ...any)

func (*XrayLogger) Info

func (l *XrayLogger) Info(args ...any)

func (*XrayLogger) InfoContext

func (l *XrayLogger) InfoContext(ctx context.Context, args ...any)

func (*XrayLogger) Panic

func (l *XrayLogger) Panic(args ...any)

func (*XrayLogger) PanicContext

func (l *XrayLogger) PanicContext(ctx context.Context, args ...any)

func (*XrayLogger) Trace

func (l *XrayLogger) Trace(args ...any)

func (*XrayLogger) TraceContext

func (l *XrayLogger) TraceContext(ctx context.Context, args ...any)

func (*XrayLogger) Warn

func (l *XrayLogger) Warn(args ...any)

func (*XrayLogger) WarnContext

func (l *XrayLogger) WarnContext(ctx context.Context, args ...any)

type XrayOutboundDialer

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

func NewOutboundDialer

func NewOutboundDialer(outbound proxy.Outbound, dialer internet.Dialer) *XrayOutboundDialer

func (*XrayOutboundDialer) DialContext

func (d *XrayOutboundDialer) DialContext(ctx context.Context, network string, destination M.Socksaddr) (net.Conn, error)

func (*XrayOutboundDialer) ListenPacket

func (d *XrayOutboundDialer) ListenPacket(ctx context.Context, destination M.Socksaddr) (net.PacketConn, error)