banditprobe

package
v0.0.191 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 3, 2026 License: GPL-3.0 Imports: 27 Imported by: 0

Documentation

Overview

Package banditprobe answers bandit callback probes on the proxy itself.

A censor can freeze a flow after a few kilobytes while still letting the small request through. The API cannot see that from where it sits, because its TCP peer is a load balancer. The proxy is the sender on the leg that freezes, so it can watch the client acknowledge (or not acknowledge) a body large enough to cross the freeze point, and report what it saw.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewOutbound 

func NewOutbound(ctx context.Context, router adapter.Router, lg log.ContextLogger, tag string, options option.BanditProbeOutboundOptions) (adapter.Outbound, error)

func RegisterOutbound 

func RegisterOutbound(registry *outbound.Registry)

Types

type Outbound 

type Outbound struct {
	outbound.Adapter
	// contains filtered or unexported fields
}

Outbound only handles connections the router hands it; it never dials.

func (*Outbound) DialContext 

func (o *Outbound) DialContext(ctx context.Context, network string, destination M.Socksaddr) (net.Conn, error)

func (*Outbound) ListenPacket 

func (o *Outbound) ListenPacket(ctx context.Context, destination M.Socksaddr) (net.PacketConn, error)

func (*Outbound) NewConnectionEx 

func (o *Outbound) NewConnectionEx(ctx context.Context, conn net.Conn, metadata adapter.InboundContext, onClose N.CloseHandlerFunc)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.