conn

Documentation

Index

• 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 UpdateProxy(proxy C.Proxy)
• type TcpConnContext
  • func NewTcpConnContext(ctx context.Context, conn net.Conn, metadata *constant.Metadata, ...) *TcpConnContext
  • func (t *TcpConnContext) Conn() net.Conn
  • func (t *TcpConnContext) ID() uuid.UUID
  • func (t *TcpConnContext) Metadata() *constant.Metadata
• type UdpConn
• type UdpConnContext
  • func NewUdpConnContext(ctx context.Context, conn UdpConn, metadata *constant.Metadata, ...) (*UdpConnContext, error)
  • func (u *UdpConnContext) Conn() UdpConn
  • func (u *UdpConnContext) ID() uuid.UUID
  • func (u *UdpConnContext) Metadata() *constant.Metadata

Functions

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 UpdateProxy

func UpdateProxy(proxy C.Proxy)

Types

type TcpConnContext

type TcpConnContext struct {
	Wg *sync.WaitGroup

	Rule constants.IpRule
	Ctx  context.Context
	// 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) ID

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

func (*TcpConnContext) Metadata

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

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 {
	Wg *sync.WaitGroup

	Rule      constants.IpRule
	Ctx       context.Context
	ProxyAddr string
	// 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) ID

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

func (*UdpConnContext) Metadata

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