conn

Documentation

Index

• func GetProxy(rule constants.RuleType) (C.Proxy, error)
• func NewTcpConn(ctx context.Context, metadata *C.Metadata, rule constants.RuleType, ...) (net.Conn, error)
• func NewUdpConn(ctx context.Context, metadata *C.Metadata, rule constants.RuleType, ...) (net.PacketConn, error)
• func RejectQuicMather(metadata *C.Metadata, prevRule constants.RuleType) (constants.RuleType, error)
• func UpdateConnMatcher(matchers []Matcher)
• func UpdateProxy(remoteProxy C.Proxy)
• 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() constants.RuleType
  • func (t *TcpConnContext) Wg() *sync.WaitGroup
• type UdpConn
• type UdpConnContext
  • func NewUdpConnContext(ctx context.Context, conn UdpConn, metadata *C.Metadata, wg *sync.WaitGroup) (*UdpConnContext, error)
  • func (u *UdpConnContext) Conn() UdpConn
  • func (u *UdpConnContext) Ctx() context.Context
  • func (u *UdpConnContext) Metadata() *C.Metadata
  • func (u *UdpConnContext) Rule() constants.RuleType
  • func (u *UdpConnContext) Wg() *sync.WaitGroup

Functions

func GetProxy

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

func NewTcpConn

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

func NewUdpConn

func NewUdpConn(ctx context.Context, metadata *C.Metadata, rule constants.RuleType, defaultInterface string) (net.PacketConn, error)

func RejectQuicMather

func RejectQuicMather(metadata *C.Metadata, prevRule constants.RuleType) (constants.RuleType, error)

func UpdateConnMatcher

func UpdateConnMatcher(matchers []Matcher)

func UpdateProxy

func UpdateProxy(remoteProxy C.Proxy)

Types

type Matcher

type Matcher func(metadata *C.Metadata, prevRule constants.RuleType) (constants.RuleType, 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() constants.RuleType

func (*TcpConnContext) Wg

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

type UdpConn

type UdpConn interface {
	ReadFrom([]byte) (int, net.Addr, error)
	WriteTo([]byte, net.Addr) (int, error)
	Close() error
	SetDeadline(t time.Time) error
	SetReadDeadline(t time.Time) error
	SetWriteDeadline(t time.Time) error
}

type UdpConnContext

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

func NewUdpConnContext

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

func (*UdpConnContext) Conn

func (u *UdpConnContext) Conn() UdpConn

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() constants.RuleType

func (*UdpConnContext) Wg

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