sniffing

Documentation

Index

• Constants
• Variables
• func Sniff(ctx context.Context, r *bufio.Reader) (proto string, err error)
• type HandleOption
  • func WithBypass(bypass bypass.Bypass) HandleOption
  • func WithDial(dial func(ctx context.Context, network, address string) (net.Conn, error)) HandleOption
  • func WithDialTLS(...) HandleOption
  • func WithLog(log logger.Logger) HandleOption
  • func WithRecorderObject(ro *xrecorder.HandlerRecorderObject) HandleOption
• type HandleOptions
• type Sniffer
  • func (h *Sniffer) HandleHTTP(ctx context.Context, conn net.Conn, opts ...HandleOption) error
  • func (h *Sniffer) HandleTLS(ctx context.Context, conn net.Conn, opts ...HandleOption) error

Constants

const (
	ProtoHTTP = "http"
	ProtoTLS  = "tls"
	ProtoSSH  = "ssh"
)

const (
	// DefaultBodySize is the default HTTP body or websocket frame size to record.
	DefaultBodySize = 64 * 1024 // 64KB
	// MaxBodySize is the maximum HTTP body or websocket frame size to record.
	MaxBodySize = 1024 * 1024 // 1MB
	// DeafultSampleRate is the default websocket sample rate (samples per second).
	DefaultSampleRate = 10.0
)

Variables

var (
	DefaultCertPool = tls_util.NewMemoryCertPool()
)

Functions

func Sniff

func Sniff(ctx context.Context, r *bufio.Reader) (proto string, err error)

Types

type HandleOption

type HandleOption func(opts *HandleOptions)

func WithBypass

func WithBypass(bypass bypass.Bypass) HandleOption

func WithDial

func WithDial(dial func(ctx context.Context, network, address string) (net.Conn, error)) HandleOption

func WithDialTLS

func WithDialTLS(dialTLS func(ctx context.Context, network, address string, cfg *tls.Config) (net.Conn, error)) HandleOption

func WithLog

func WithLog(log logger.Logger) HandleOption

func WithRecorderObject

func WithRecorderObject(ro *xrecorder.HandlerRecorderObject) HandleOption

type HandleOptions

type HandleOptions struct {
	Dial    func(ctx context.Context, network, address string) (net.Conn, error)
	DialTLS func(ctx context.Context, network, address string, cfg *tls.Config) (net.Conn, error)

	Bypass         bypass.Bypass
	RecorderObject *xrecorder.HandlerRecorderObject
	Log            logger.Logger
}

type Sniffer

type Sniffer struct {
	Websocket           bool
	WebsocketSampleRate float64

	Recorder        recorder.Recorder
	RecorderOptions *recorder.Options

	// MITM TLS termination
	Certificate        *x509.Certificate
	PrivateKey         crypto.PrivateKey
	NegotiatedProtocol string
	CertPool           tls_util.CertPool
	MitmBypass         bypass.Bypass

	ReadTimeout time.Duration
}

func (*Sniffer) HandleHTTP

func (h *Sniffer) HandleHTTP(ctx context.Context, conn net.Conn, opts ...HandleOption) error

func (*Sniffer) HandleTLS

func (h *Sniffer) HandleTLS(ctx context.Context, conn net.Conn, opts ...HandleOption) error