udpnat

Documentation

Index

• type DirectBackWriter
  • func (w *DirectBackWriter) Upstream() any
  • func (w *DirectBackWriter) WritePacket(buffer *buf.Buffer, addr M.Socksaddr) error
• type Handler
• type Service
  • func New[K comparable](maxAge int64, handler Handler) *Service[K]
  • func NewEx[K comparable](maxAge int64, handler N.UDPConnectionHandlerEx) *Service[K]
  • func (s *Service[T]) NewContextPacket(ctx context.Context, key T, buffer *buf.Buffer, metadata M.Metadata, ...)
  • func (s *Service[T]) NewContextPacketEx(ctx context.Context, key T, buffer *buf.Buffer, source M.Socksaddr, ...)
  • func (s *Service[T]) NewPacket(ctx context.Context, key T, buffer *buf.Buffer, metadata M.Metadata, ...)
  • func (s *Service[T]) NewPacketDirect(ctx context.Context, key T, conn N.PacketConn, buffer *buf.Buffer, ...)
  • func (s *Service[T]) NewPacketEx(ctx context.Context, key T, buffer *buf.Buffer, source M.Socksaddr, ...)
  • func (s *Service[T]) WriteIsThreadUnsafe()

Types

type DirectBackWriter

type DirectBackWriter struct {
	Source N.PacketConn
	Nat    N.PacketConn
}

func (*DirectBackWriter) Upstream

func (w *DirectBackWriter) Upstream() any

func (*DirectBackWriter) WritePacket

func (w *DirectBackWriter) WritePacket(buffer *buf.Buffer, addr M.Socksaddr) error

type Handler

type Handler interface {
	N.UDPConnectionHandler
	E.Handler
}

Deprecated: Use N.UDPConnectionHandler instead.

type Service

type Service[K comparable] struct {
	// contains filtered or unexported fields
}

func New

func New[K comparable](maxAge int64, handler Handler) *Service[K]

Deprecated: Use NewEx instead.

func NewEx

func NewEx[K comparable](maxAge int64, handler N.UDPConnectionHandlerEx) *Service[K]

func (*Service[T]) NewContextPacket

func (s *Service[T]) NewContextPacket(ctx context.Context, key T, buffer *buf.Buffer, metadata M.Metadata, init func(natConn N.PacketConn) (context.Context, N.PacketWriter))

Deprecated: Use NewPacketConnectionEx instead.

func (*Service[T]) NewContextPacketEx

func (s *Service[T]) NewContextPacketEx(ctx context.Context, key T, buffer *buf.Buffer, source M.Socksaddr, destination M.Socksaddr, init func(natConn N.PacketConn) (context.Context, N.PacketWriter))

func (*Service[T]) NewPacket

func (s *Service[T]) NewPacket(ctx context.Context, key T, buffer *buf.Buffer, metadata M.Metadata, init func(natConn N.PacketConn) N.PacketWriter)

Deprecated: use NewPacketEx instead.

func (*Service[T]) NewPacketDirect

func (s *Service[T]) NewPacketDirect(ctx context.Context, key T, conn N.PacketConn, buffer *buf.Buffer, metadata M.Metadata)

Deprecated: don't use

func (*Service[T]) NewPacketEx

func (s *Service[T]) NewPacketEx(ctx context.Context, key T, buffer *buf.Buffer, source M.Socksaddr, destination M.Socksaddr, init func(natConn N.PacketConn) N.PacketWriter)

func (*Service[T]) WriteIsThreadUnsafe

func (s *Service[T]) WriteIsThreadUnsafe()