conn

Documentation

Index

• func GetIsDNSConn(metadata *C.Metadata) bool
• func GetProxy(rule constants.Policy) (C.Proxy, error)
• func NewTcpConn(ctx context.Context, metadata *C.Metadata, rule rule_engine.Rule, ...) (net.Conn, error)
• func PrintPacketError(err error, msg string)
• func RejectQuicMather(metadata *C.Metadata, prevRule rule_engine.Rule) (rule_engine.Rule, error)
• func UpdateConnMatcher(matchers []Matcher)
• func UpdateProxy(remoteProxy C.Proxy)
• type CopyablePacketConn
  • func NewUdpConn(ctx context.Context, metadata *C.Metadata, rule rule_engine.Rule, ...) (*CopyablePacketConn, error)
  • func (c *CopyablePacketConn) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)
  • func (c *CopyablePacketConn) WritePacket(buffer *buf.Buffer, destination M.Socksaddr) error
• type CopyableReaderWriterConn
  • func (uc *CopyableReaderWriterConn) ReadFrom(data []byte) (int, net.Addr, error)
  • func (uc *CopyableReaderWriterConn) WriteTo(data []byte, addr net.Addr) (int, error)
• type Matcher
  • func GetConnMatcher() []Matcher
• type TcpConnContext
  • func NewTcpConnContext(ctx context.Context, conn net.Conn, metadata *C.Metadata, wg *sync.WaitGroup) (*TcpConnContext, error)
  • func (t *TcpConnContext) Conn() net.Conn
  • func (t *TcpConnContext) Ctx() context.Context
  • func (t *TcpConnContext) Metadata() *C.Metadata
  • func (t *TcpConnContext) Rule() rule_engine.Rule
  • func (t *TcpConnContext) Wg() *sync.WaitGroup
• type UdpConnContext
  • func NewUdpConnContext(ctx context.Context, conn network.PacketConn, metadata *C.Metadata, ...) (*UdpConnContext, error)
  • func (u *UdpConnContext) Conn() network.PacketConn
  • func (u *UdpConnContext) Ctx() context.Context
  • func (u *UdpConnContext) Metadata() *C.Metadata
  • func (u *UdpConnContext) Rule() rule_engine.Rule
  • func (u *UdpConnContext) Wg() *sync.WaitGroup

Functions

func GetIsDNSConn

func GetIsDNSConn(metadata *C.Metadata) bool

func GetProxy

func GetProxy(rule constants.Policy) (C.Proxy, error)

func NewTcpConn

func NewTcpConn(ctx context.Context, metadata *C.Metadata, rule rule_engine.Rule, defaultInterface string) (net.Conn, error)

func PrintPacketError

func PrintPacketError(err error, msg string)

func RejectQuicMather

func RejectQuicMather(metadata *C.Metadata, prevRule rule_engine.Rule) (rule_engine.Rule, error)

func UpdateConnMatcher

func UpdateConnMatcher(matchers []Matcher)

func UpdateProxy

func UpdateProxy(remoteProxy C.Proxy)

Types

type CopyablePacketConn

type CopyablePacketConn struct {
	net.PacketConn
}

func NewUdpConn

func NewUdpConn(ctx context.Context, metadata *C.Metadata, rule rule_engine.Rule, defaultInterface string) (*CopyablePacketConn, error)

func (*CopyablePacketConn) ReadPacket

func (c *CopyablePacketConn) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)

func (*CopyablePacketConn) WritePacket

func (c *CopyablePacketConn) WritePacket(buffer *buf.Buffer, destination M.Socksaddr) error

type CopyableReaderWriterConn

type CopyableReaderWriterConn struct {
	network.PacketConn
}

func (*CopyableReaderWriterConn) ReadFrom

func (uc *CopyableReaderWriterConn) ReadFrom(data []byte) (int, net.Addr, error)

func (*CopyableReaderWriterConn) WriteTo

func (uc *CopyableReaderWriterConn) WriteTo(data []byte, addr net.Addr) (int, error)

type Matcher

type Matcher func(metadata *C.Metadata, rule rule_engine.Rule) (rule_engine.Rule, error)

func GetConnMatcher

func GetConnMatcher() []Matcher

type TcpConnContext

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

func NewTcpConnContext

func NewTcpConnContext(ctx context.Context, conn net.Conn, metadata *C.Metadata, wg *sync.WaitGroup) (*TcpConnContext, error)

func (*TcpConnContext) Conn

func (t *TcpConnContext) Conn() net.Conn

func (*TcpConnContext) Ctx

func (t *TcpConnContext) Ctx() context.Context

func (*TcpConnContext) Metadata

func (t *TcpConnContext) Metadata() *C.Metadata

func (*TcpConnContext) Rule

func (t *TcpConnContext) Rule() rule_engine.Rule

func (*TcpConnContext) Wg

func (t *TcpConnContext) Wg() *sync.WaitGroup

type UdpConnContext

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

func NewUdpConnContext

func NewUdpConnContext(ctx context.Context, conn network.PacketConn, metadata *C.Metadata, wg *sync.WaitGroup) (*UdpConnContext, error)

func (*UdpConnContext) Conn

func (u *UdpConnContext) Conn() network.PacketConn

func (*UdpConnContext) Ctx

func (u *UdpConnContext) Ctx() context.Context

func (*UdpConnContext) Metadata

func (u *UdpConnContext) Metadata() *C.Metadata

func (*UdpConnContext) Rule

func (u *UdpConnContext) Rule() rule_engine.Rule

func (*UdpConnContext) Wg

func (u *UdpConnContext) Wg() *sync.WaitGroup