conn

Documentation

Index

• func GetIsProxyAddr(addr string) bool
• func GetProxyAddr() string
• func NewTcpConn(ctx context.Context, metadata *C.Metadata, rule constants.IpRule, ...) (net.Conn, error)
• func NewUdpConn(ctx context.Context, metadata *C.Metadata, rule constants.IpRule, ...) (net.PacketConn, error)
• func UpdateMatcher(c Matcher)
• func UpdateProxy(remoteProxy C.Proxy)
• type Matcher
  • func GetMatcher() Matcher
• type ProxyAddr
  • func (p ProxyAddr) Addr() string
  • func (p ProxyAddr) Type() ProxyAddrType
• type ProxyAddrType
• type TcpConnContext
  • func NewTcpConnContext(ctx context.Context, conn net.Conn, metadata *constant.Metadata, ...) *TcpConnContext
  • func (t *TcpConnContext) Conn() net.Conn
  • func (t *TcpConnContext) Ctx() context.Context
  • func (t *TcpConnContext) ID() uuid.UUID
  • func (t *TcpConnContext) Metadata() *constant.Metadata
  • func (t *TcpConnContext) Rule() constants.IpRule
  • func (t *TcpConnContext) Wg() *sync.WaitGroup
• type UdpConn
• type UdpConnContext
  • func NewUdpConnContext(ctx context.Context, conn UdpConn, metadata *constant.Metadata, ...) (*UdpConnContext, error)
  • func (u *UdpConnContext) Conn() UdpConn
  • func (u *UdpConnContext) Ctx() context.Context
  • func (u *UdpConnContext) ID() uuid.UUID
  • func (u *UdpConnContext) Metadata() *constant.Metadata
  • func (u *UdpConnContext) Rule() constants.IpRule
  • func (u *UdpConnContext) Wg() *sync.WaitGroup

Functions

func GetIsProxyAddr

func GetIsProxyAddr(addr string) bool

func GetProxyAddr

func GetProxyAddr() string

func NewTcpConn

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

func NewUdpConn

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

func UpdateMatcher

func UpdateMatcher(c Matcher)

func UpdateProxy

func UpdateProxy(remoteProxy C.Proxy)

Types

type Matcher

type Matcher interface {
	GetRule(ip string) constants.IpRule
}

func GetMatcher

func GetMatcher() Matcher

type ProxyAddr

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

func (ProxyAddr) Addr

func (p ProxyAddr) Addr() string

func (ProxyAddr) Type

func (p ProxyAddr) Type() ProxyAddrType

type ProxyAddrType

type ProxyAddrType int

const (
	ProxyAddrDomain ProxyAddrType = 0
	ProxyAddrIp     ProxyAddrType = 1
)

type TcpConnContext

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

func NewTcpConnContext

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

func (*TcpConnContext) Conn

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

func (*TcpConnContext) Ctx

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

func (*TcpConnContext) ID

func (t *TcpConnContext) ID() uuid.UUID

func (*TcpConnContext) Metadata

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

func (*TcpConnContext) Rule

func (t *TcpConnContext) Rule() constants.IpRule

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
}

type UdpConnContext

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

func NewUdpConnContext

func NewUdpConnContext(ctx context.Context, conn UdpConn, metadata *constant.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) ID

func (u *UdpConnContext) ID() uuid.UUID

func (*UdpConnContext) Metadata

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

func (*UdpConnContext) Rule

func (u *UdpConnContext) Rule() constants.IpRule

func (*UdpConnContext) Wg

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