sniff

Documentation

Index

• func DomainNameQuery(ctx context.Context, packet []byte) (*adapter.InboundContext, error)
• func HTTPHost(ctx context.Context, reader io.Reader) (*adapter.InboundContext, error)
• func PeekPacket(ctx context.Context, packet []byte, sniffers ...PacketSniffer) (*adapter.InboundContext, error)
• func PeekStream(ctx context.Context, conn net.Conn, buffer *buf.Buffer, timeout time.Duration, ...) (*adapter.InboundContext, error)
• func QUICClientHello(ctx context.Context, packet []byte) (*adapter.InboundContext, error)
• func STUNMessage(ctx context.Context, packet []byte) (*adapter.InboundContext, error)
• func Skip(metadata adapter.InboundContext) bool
• func StreamDomainNameQuery(readCtx context.Context, reader io.Reader) (*adapter.InboundContext, error)
• func TLSClientHello(ctx context.Context, reader io.Reader) (*adapter.InboundContext, error)
• type PacketSniffer
• type StreamSniffer

Functions

func DomainNameQuery

func DomainNameQuery(ctx context.Context, packet []byte) (*adapter.InboundContext, error)

func HTTPHost

func HTTPHost(ctx context.Context, reader io.Reader) (*adapter.InboundContext, error)

func PeekPacket

func PeekPacket(ctx context.Context, packet []byte, sniffers ...PacketSniffer) (*adapter.InboundContext, error)

func PeekStream

func PeekStream(ctx context.Context, conn net.Conn, buffer *buf.Buffer, timeout time.Duration, sniffers ...StreamSniffer) (*adapter.InboundContext, error)

func QUICClientHello

func QUICClientHello(ctx context.Context, packet []byte) (*adapter.InboundContext, error)

func STUNMessage

func STUNMessage(ctx context.Context, packet []byte) (*adapter.InboundContext, error)

func Skip

func Skip(metadata adapter.InboundContext) bool

func StreamDomainNameQuery

func StreamDomainNameQuery(readCtx context.Context, reader io.Reader) (*adapter.InboundContext, error)

func TLSClientHello

func TLSClientHello(ctx context.Context, reader io.Reader) (*adapter.InboundContext, error)

Types

type PacketSniffer

type PacketSniffer = func(ctx context.Context, packet []byte) (*adapter.InboundContext, error)

type StreamSniffer

type StreamSniffer = func(ctx context.Context, reader io.Reader) (*adapter.InboundContext, error)