forwarder

Documentation

Index

• Variables
• type HandleOption
  • func WithBypass(bypass bypass.Bypass) HandleOption
  • func WithDial(dial func(ctx context.Context, network, address string) (net.Conn, error)) HandleOption
  • func WithHTTPKeepalive(keepalive bool) HandleOption
  • func WithHop(hop hop.Hop) HandleOption
  • func WithLog(log logger.Logger) HandleOption
  • func WithNode(node *chain.Node) 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

Variables

var (
	DefaultCertPool = tls_util.NewMemoryCertPool()
)

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 WithHTTPKeepalive

func WithHTTPKeepalive(keepalive bool) HandleOption

func WithHop

func WithHop(hop hop.Hop) HandleOption

func WithLog

func WithLog(log logger.Logger) HandleOption

func WithNode

func WithNode(node *chain.Node) 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)

	HTTPKeepalive  bool
	Node           *chain.Node
	Hop            hop.Hop
	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