aoni

package module

Go to main page

Versions in this module

v0

v0.3.0

Jun 28, 2026

Changes in this version

+ var AmazonCDNHeaderPool = []string

+ var ChromeH2Settings = HTTP2Settings

+ var CloudflareHeaderPool = []string

+ var FirefoxH2Settings = HTTP2Settings

+ var GenericCDNHeaderPool = []string

+ func AppendContextModifier(ctx context.Context, mods ...RequestModifier) context.Context

+ func DecodeByContentType(r io.Reader, contentType string, target any) error

+ func DecodeJSON[T any](r io.Reader) (T, error)

+ func DecodeTo[T any](r io.Reader, d Decoder) (T, error)

+ func DecodeXML[T any](r io.Reader) (T, error)

+ func DecodeYAML[T any](r io.Reader) (T, error)

+ func DeleteJSONEx[Resp any](ctx context.Context, c Requester, path string, payload any, ...) (*Resp, *http.Response, error)

+ func ExportCookiesJSON(jar http.CookieJar, u *url.URL) (string, error)

+ func GetJSONEx[Resp any](ctx context.Context, c Requester, path string, mods ...RequestModifier) (*Resp, *http.Response, error)

+ func HostRewriteRules(ctx context.Context) map[string]string

+ func ImportCookiesJSON(jar http.CookieJar, u *url.URL, jsonStr string) error

+ func PatchJSONEx[Resp any](ctx context.Context, c Requester, path string, payload any, ...) (*Resp, *http.Response, error)

+ func PostFormJSONEx[Resp any](ctx context.Context, c Requester, path string, payload any, ...) (*Resp, *http.Response, error)

+ func PostFormJSON[Resp any](ctx context.Context, c Requester, path string, payload any, ...) (*Resp, error)

+ func PostJSONEx[Resp any](ctx context.Context, c Requester, path string, payload any, ...) (*Resp, *http.Response, error)

+ func PutJSONEx[Resp any](ctx context.Context, c Requester, path string, payload any, ...) (*Resp, *http.Response, error)

+ func ReadAllBytes(rb ReplayableBody) ([]byte, error)

+ func ReadAllString(rb ReplayableBody) (string, error)

+ func StreamChunks(ctx context.Context, resp *StreamResponse) (<-chan string, <-chan error)

+ type BackoffStrategy interface

+ Next func() time.Duration

+ Reset func()

type BoolInt

+ func (bi BoolInt) MarshalJSON() ([]byte, error)

+ type BridgeError struct

+ Err error

+ Metadata map[string]any

+ Op string

+ URL string

+ func (e *BridgeError) Error() string

+ func (e *BridgeError) Unwrap() error

type Client

+ func (c *Client) WithBrowserProfile(browser BrowserID, os profiles.OSKey) *Client

+ type DNSError struct

+ Endpoint string

+ Err error

+ Host string

+ IsTimeout bool

+ Resolver string

+ func (e *DNSError) Error() string

+ func (e *DNSError) Temporary() bool

+ func (e *DNSError) Timeout() bool

+ func (e *DNSError) Unwrap() error

type Decoder

+ func LimitDecoder(d Decoder, maxBytes int64) Decoder

+ func NewJSONDecoder(cfg JSONDecoderConfig) Decoder

type DoTResolver

+ TLSConfig *tls.Config

type FallbackFunc

+ func FallbackString(statusCode int, text string) FallbackFunc

+ type FallbackResolver struct

+ func NewFallbackResolver(resolvers ...DNSResolver) *FallbackResolver

+ func (r *FallbackResolver) LookupIPAddr(ctx context.Context, host string) ([]net.IPAddr, error)

+ type FastRaceResolver struct

+ func NewFastRaceResolver(resolvers ...DNSResolver) *FastRaceResolver

+ func (r *FastRaceResolver) LookupIPAddr(ctx context.Context, host string) ([]net.IPAddr, error)

type Float64String

+ func (f Float64String) MarshalJSON() ([]byte, error)

type FragmentConfig

+ LimitBytes int64

+ MaxChunkSize int

+ MinChunkSize int

+ MinDelay time.Duration

type HTTP2Settings

+ func ParseHTTP2Settings(jsonStr string) (HTTP2Settings, error)

+ type HealthStatus int

+ const StatusDegraded

+ const StatusHealthy

+ const StatusRecovering

+ const StatusUnhealthy

+ func (s HealthStatus) String() string

type HealthTracker

+ func (h *HealthTracker) CooldownRemaining() time.Duration

+ func (h *HealthTracker) FailCount() uint32

+ func (h *HealthTracker) Reset()

+ func (h *HealthTracker) Status() HealthStatus

type Int64String

+ func (i Int64String) MarshalJSON() ([]byte, error)

+ type JSONDecoderConfig struct

+ DisallowUnknownFields bool

+ UseNumber bool

type LoadBalancer

+ func (lb *LoadBalancer) Reset()

+ func (lb *LoadBalancer) SetWeight(backendURL string, weight int) bool

+ func (lb *LoadBalancer) Stats() LoadBalancerStats

+ type LoadBalancerStats struct

+ HealthyBackends int

+ TotalBackends int

+ UnhealthyBackends int

type NamespaceSocket

+ func (ns *NamespaceSocket) OnAny(handler func(event string, args []json.RawMessage))

+ type PaddingConfig struct

+ HeaderPool []string

+ MaxPaddingBytes int

+ MaxSegmentSize int

+ MinPaddingBytes int

+ PaddingHeader string

type ProxyAwareSessionCache

+ func (c *ProxyAwareSessionCache) Clear()

type ProxyIsolatedCookieJar

+ func (p *ProxyIsolatedCookieJar) CookiesForProxy(proxyURL string, u *url.URL) []*http.Cookie

+ func (p *ProxyIsolatedCookieJar) GetJar(ctx context.Context) http.CookieJar

+ func (p *ProxyIsolatedCookieJar) GetJarForProxy(proxyURL string) http.CookieJar

+ func (p *ProxyIsolatedCookieJar) SetCookiesForProxy(proxyURL string, u *url.URL, cookies []*http.Cookie)

type ProxyRotator

+ func NewProxyRotatorFromStrings(config ProxyRotatorConfig, proxyURLs ...string) (*ProxyRotator, error)

+ func (r *ProxyRotator) Reset()

+ func (r *ProxyRotator) Stats() ProxyRotatorStats

+ type ProxyRotatorStats struct

+ HealthyProxies int

+ TotalProxies int

+ UnhealthyProxies int

type RTTTracker

+ func (t *RTTTracker) AverageRTT() time.Duration

+ func (t *RTTTracker) MaxRTT() time.Duration

+ func (t *RTTTracker) Reset()

type RequestModifier

+ func AppendHostRewrite(rules map[string]string) RequestModifier

+ func TraceContext() RequestModifier

+ func WithJSONDecoder() RequestModifier

+ func WithPadding(cfg PaddingConfig) RequestModifier

+ func WithRawDecoder() RequestModifier

+ func WithXMLDecoder() RequestModifier

+ func WithYAMLDecoder() RequestModifier

type RetryCondition

+ func And(conditions ...RetryCondition) RetryCondition

+ func Or(conditions ...RetryCondition) RetryCondition

type RetryOptions

+ OnRetry func(attempt uint32, err error, delay time.Duration)

type SocketIOConfig

+ Backoff BackoffStrategy

type SocketIOConn

+ func NewSocketIOConn(ctx context.Context, conn net.Conn, config SocketIOConfig) (*SocketIOConn, error)

+ func (s *SocketIOConn) OnAny(handler func(event string, args []json.RawMessage))

+ func (s *SocketIOConn) ReconnectionAttempts() int

type SourceIPRotator

+ func (r *SourceIPRotator) IPs() []net.IP

+ func (r *SourceIPRotator) NextForFamily(isIPv4 bool) net.IP

+ func (r *SourceIPRotator) Size() int

+ func (r *SourceIPRotator) UpdatePool(addrs []string) error

+ type StaticResolver struct

+ func NewStaticResolver(mapping map[string][]string, delegate DNSResolver) *StaticResolver

+ func (r *StaticResolver) LookupIPAddr(ctx context.Context, host string) ([]net.IPAddr, error)

type TraceInfo

+ RemoteAddr string

+ func ResponseTrace(resp *http.Response) *TraceInfo

+ func (t *TraceInfo) Start() func(resp *http.Response)

+ type Transport struct

+ BeforeRoundTrip func(cloned *Client, origReq *http.Request) *Client

+ func NewTransport(c *Client) *Transport

+ func (t *Transport) RoundTrip(origReq *http.Request) (*http.Response, error)

type Uint64String

+ func (u Uint64String) MarshalJSON() ([]byte, error)

type UnixTimestamp

+ func (t UnixTimestamp) MarshalJSON() ([]byte, error)

+ type WebSocketConn interface

+ CloseChan func() <-chan struct{}

+ ReadMessage func() (messageType int, p []byte, err error)

+ UnderlyingConn func() any

+ WriteMessage func(messageType int, data []byte) error

v0.2.0

Jun 24, 2026

Changes in this version

+ func GeneratePadding(cfg PacketPaddingConfig) []byte

+ func MirrorCookies(jar http.CookieJar, sourceURL *url.URL, targetURLs []*url.URL, ...)

+ func NewStdClient(c *Client) *http.Client

+ func PaddingHeaderName(cfg PacketPaddingConfig) string

+ func UnwrapTo[T any](c io.Closer) (T, bool)

+ func WithContextModifier(ctx context.Context, mods ...RequestModifier) context.Context

type CircuitBreakerConfig

+ MinRequests int

+ Window time.Duration

type Client

+ func (c *Client) WithBasicAuth(username, password string) *Client

+ func (c *Client) WithBearer(token string) *Client

+ func (c *Client) WithDoH(endpoint, host string) *Client

+ func (c *Client) WithDoT(endpoint, host string) *Client

+ func (c *Client) WithDynamicHedging(config *DynamicHedgingConfig) *Client

+ func (c *Client) WithH2FramedTransport(settings HTTP2Settings) *Client

+ func (c *Client) WithHTTP3Config(config *QUICMigrationConfig) *Client

+ func (c *Client) WithPacketPadding(cfg PacketPaddingConfig) *Client

+ func (c *Client) WithProfileH2Settings(s profiles.H2Settings) *Client

+ func (c *Client) WithProxy(proxyURL *url.URL) *Client

+ func (c *Client) WithProxyAwareSessionCache() *Client

+ func (c *Client) WithProxyDNS() *Client

type DoHResolver

+ Endpoint string

+ Host string

type DoTResolver

+ Endpoint string

+ Host string

+ type DynamicHedgingConfig struct

+ MaxDelay time.Duration

+ MinDelay time.Duration

+ Multiplier float64

+ Percentile float64

+ Tracker *RTTTracker

+ func DefaultDynamicHedgingConfig() DynamicHedgingConfig

+ func (c DynamicHedgingConfig) ComputeDelay() time.Duration

+ type H2FramedTransport struct

+ func NewH2FramedTransport(base *http.Transport, settings HTTP2Settings, orderedKeys ...string) *H2FramedTransport

type HTTP2Settings

+ ConnectionFlow uint32

+ EnablePush uint32

+ HeaderTableSize uint32

+ InitialStreamID uint32

+ MaxConcurrentStreams uint32

+ MaxFrameSize uint32

+ PriorityExclusive bool

+ PriorityStreamDep uint32

+ PriorityWeight uint8

+ func H2SettingsFromProfile(s profiles.H2Settings) HTTP2Settings

+ type HealthTracker struct

+ func NewHealthTracker(name string, maxFails uint32, retryAfter time.Duration, ...) *HealthTracker

+ func (h *HealthTracker) IsAvailable() bool

+ func (h *HealthTracker) MarkFailed()

+ func (h *HealthTracker) MarkSuccess()

type InMemoryDNSCache

+ func (c *InMemoryDNSCache) Close()

+ type NamespaceSocket struct

+ func (ns *NamespaceSocket) Emit(event string, args ...any) error

+ func (ns *NamespaceSocket) EmitVolatile(event string, args ...any) error

+ func (ns *NamespaceSocket) EmitWithAck(ctx context.Context, event string, args ...any) ([]json.RawMessage, error)

+ func (ns *NamespaceSocket) On(event string, handler func(args []json.RawMessage))

+ type PacketPaddingConfig struct

+ HeaderPool []string

+ MaxPaddingBytes int

+ MaxSegmentSize int

+ MinPaddingBytes int

+ PaddingHeader string

+ type ProxyAwareSessionCache struct

+ func NewProxyAwareSessionCache() *ProxyAwareSessionCache

+ func (c *ProxyAwareSessionCache) CurrentProxyKey() string

+ func (c *ProxyAwareSessionCache) Get(serverName string) (*utls.ClientSessionState, bool)

+ func (c *ProxyAwareSessionCache) Put(serverName string, session *utls.ClientSessionState)

+ func (c *ProxyAwareSessionCache) SetProxyKey(key string)

+ type ProxyRoutedDNSResolver struct

+ func NewProxyRoutedDNSResolver(resolver DNSResolver, ...) *ProxyRoutedDNSResolver

+ func (r *ProxyRoutedDNSResolver) LookupIPAddr(ctx context.Context, host string) ([]net.IPAddr, error)

+ type QUICMigrationConfig struct

+ DisablePathMTUDiscovery bool

+ EnableMigration bool

+ InitialPacketSize uint16

+ KeepAlivePeriod time.Duration

+ MaxIdleTimeout time.Duration

+ func DefaultQUICMigrationConfig() QUICMigrationConfig

+ type RTTTracker struct

+ func NewRTTTracker(capacity int) *RTTTracker

+ func (t *RTTTracker) Count() int

+ func (t *RTTTracker) MinRTT() time.Duration

+ func (t *RTTTracker) P95() time.Duration

+ func (t *RTTTracker) P99() time.Duration

+ func (t *RTTTracker) Percentile(p float64) time.Duration

+ func (t *RTTTracker) Record(rtt time.Duration)

+ func (t *RTTTracker) SmoothedRTT() time.Duration

type RequestModifier

+ func ContextModifiers(ctx context.Context) []RequestModifier

+ type SocketIOConfig struct

+ Auth any

+ ConnectTimeout time.Duration

+ JitterFactor float64

+ Namespace string

+ PingTimeout time.Duration

+ Reconnection bool

+ ReconnectionAttempts int

+ ReconnectionDelay time.Duration

+ ReconnectionDelayMax time.Duration

+ type SocketIOConn struct

+ func DialSocketIO(ctx context.Context, c *Client, targetURL string, config SocketIOConfig, ...) (*SocketIOConn, error)

+ func (s *SocketIOConn) Close() error

+ func (s *SocketIOConn) Connected() bool

+ func (s *SocketIOConn) Emit(event string, args ...any) error

+ func (s *SocketIOConn) EmitVolatile(event string, args ...any) error

+ func (s *SocketIOConn) EmitWithAck(ctx context.Context, event string, args ...any) ([]json.RawMessage, error)

+ func (s *SocketIOConn) On(event string, handler func(args []json.RawMessage))

+ func (s *SocketIOConn) OnClose(handler func())

+ func (s *SocketIOConn) OnNamespace(nsp string) *NamespaceSocket

+ func (s *SocketIOConn) OnReconnectFailed(handler func())

+ func (s *SocketIOConn) OnReconnected(handler func())

+ func (s *SocketIOConn) OnReconnecting(handler func(attempt int))

+ func (s *SocketIOConn) SID() string

type StickyKeyFunc

+ func StickyKeyFromCookie(cookieName string) StickyKeyFunc

+ func StickyKeyFromHeader(headerName string) StickyKeyFunc

v0.1.0

Jun 17, 2026

Changes in this version

+ const DefaultUserAgent

+ var DefaultClient = NewClient(nil)

+ var DefaultSensitiveHeaders = []string

+ var ErrCloudflareChallenge = errors.New("aoni: cloudflare challenge detected")

+ var ErrResponseTooLarge = errors.New("aoni: response size limit exceeded")

+ var ErrSSRFBlocked = errors.New("aoni: request blocked by SSRF guard")

+ var ErrUnexpectedContentType = errors.New("aoni: unexpected content-type (possible captive portal or intercept)")

+ func CurlCommand(req *http.Request, body []byte) string

+ func DefaultCircuitBreakerCondition(resp *http.Response, err error) bool

+ func DefaultRedirectPolicy(maxRedirects int, sensitiveHeaders ...string) func(req *http.Request, via []*http.Request) error

+ func DeleteJSON[Req, Resp any](ctx context.Context, c Requester, path string, payload Req, ...) (*Resp, error)

+ func Delete[Req, Resp any](ctx context.Context, path string, payload Req, mods ...RequestModifier) (*Resp, error)

+ func DialWebSocket(ctx context.Context, c *Client, targetURL string, mods ...RequestModifier) (net.Conn, *http.Response, error)

+ func DialWebSocketWithConfig(ctx context.Context, c *Client, targetURL string, config DialWebSocketConfig, ...) (net.Conn, *http.Response, error)

+ func GetJSON[Resp any](ctx context.Context, c Requester, path string, mods ...RequestModifier) (*Resp, error)

+ func Get[Resp any](ctx context.Context, path string, mods ...RequestModifier) (*Resp, error)

+ func ImportCookies(jar http.CookieJar, u *url.URL, cookies []CookieData)

+ func NewFragmentedConn(conn net.Conn, cfg *FragmentConfig) net.Conn

+ func NewProxyClient(cfg ProxyConfig) (*http.Client, error)

+ func ParseSSE[T any](ctx context.Context, resp *StreamResponse) (<-chan T, <-chan error)

+ func PatchJSON[Req, Resp any](ctx context.Context, c Requester, path string, payload Req, ...) (*Resp, error)

+ func Patch[Req, Resp any](ctx context.Context, path string, payload Req, mods ...RequestModifier) (*Resp, error)

+ func PostForm[Req, Resp any](ctx context.Context, c Requester, path string, payload Req, ...) (*Resp, error)

+ func PostJSON[Req, Resp any](ctx context.Context, c Requester, path string, payload Req, ...) (*Resp, error)

+ func Post[Req, Resp any](ctx context.Context, path string, payload Req, mods ...RequestModifier) (*Resp, error)

+ func PutJSON[Req, Resp any](ctx context.Context, c Requester, path string, payload Req, ...) (*Resp, error)

+ func Put[Req, Resp any](ctx context.Context, path string, payload Req, mods ...RequestModifier) (*Resp, error)

+ func StreamNDJSON[T any](ctx context.Context, resp *StreamResponse) (<-chan T, <-chan error)

+ func StreamSSE[T any](ctx context.Context, c Requester, path string, mods ...RequestModifier) (<-chan T, <-chan error, error)

+ func StructToValues(s any) (url.Values, error)

+ func Validate(s any) error

+ type APIError struct

+ Body []byte

+ Model any

+ StatusCode int

+ func (e *APIError) Error() string

+ type AdaptiveLimiter struct

+ func NewAdaptiveLimiter(initialLimit float64) *AdaptiveLimiter

+ func (l *AdaptiveLimiter) Acquire(ctx context.Context) error

+ func (l *AdaptiveLimiter) Limit() float64

+ func (l *AdaptiveLimiter) Release(rtt time.Duration)

+ type Backend struct

+ URL string

+ Weight int

+ type BaseResponse interface

+ Error func() error

+ IsSuccess func() bool

+ SetData func(data any)

+ type BaseResponseProvider interface

+ BaseResponse func() BaseResponse

+ type BoolInt bool

+ func (bi *BoolInt) UnmarshalJSON(b []byte) error

+ type BrowserID int

+ const BrowserChrome

+ const BrowserFirefox

+ const BrowserNone

+ const BrowserSafari

+ type ChaosConfig struct

+ FailureRate float64

+ LatencyMax time.Duration

+ LatencyMin time.Duration

+ type CircuitBreaker struct

+ func NewCircuitBreaker(cfg CircuitBreakerConfig) *CircuitBreaker

+ type CircuitBreakerConfig struct

+ Cooldown time.Duration

+ FailureThreshold uint32

+ SuccessThreshold uint32

+ type CircuitState int

+ const StateClosed

+ const StateHalfOpen

+ const StateOpen

+ type Client struct

+ func NewClient(httpClient HTTPDoer) *Client

+ func UnwrapClient(r Requester) *Client

+ func (c *Client) BaseResponse() BaseResponse

+ func (c *Client) Clone() *Client

+ func (c *Client) CloseIdleConnections()

+ func (c *Client) HTTP() HTTPDoer

+ func (c *Client) Logger() Logger

+ func (c *Client) Request(ctx context.Context, method, path string, mods ...RequestModifier) (*http.Response, error)

+ func (c *Client) Transport() *http.Transport

+ func (c *Client) UserAgent() string

+ func (c *Client) WithAfterResponse(hook func(resp *http.Response, err error)) *Client

+ func (c *Client) WithBaseResponse(provider func() BaseResponse) *Client

+ func (c *Client) WithBaseURL(raw string) *Client

+ func (c *Client) WithBeforeRequest(hook func(req *http.Request)) *Client

+ func (c *Client) WithConnectionPool(cfg ConnectionPoolConfig) *Client

+ func (c *Client) WithCookieJar(jar http.CookieJar) *Client

+ func (c *Client) WithDNSCache(ttl time.Duration) *Client

+ func (c *Client) WithDNSResolver(resolver DNSResolver) *Client

+ func (c *Client) WithDoTResolver(server, hostname string) *Client

+ func (c *Client) WithFragmentation(cfg FragmentConfig) *Client

+ func (c *Client) WithHTTP2Settings(settings HTTP2Settings) *Client

+ func (c *Client) WithHTTP3() *Client

+ func (c *Client) WithHappyEyeballs(delay time.Duration) *Client

+ func (c *Client) WithHeader(key, value string) *Client

+ func (c *Client) WithHedging(d time.Duration) *Client

+ func (c *Client) WithHostRewrite(rules map[string]string) *Client

+ func (c *Client) WithJA4Callback(fn func(ja4.Report)) *Client

+ func (c *Client) WithLocalAddr(addr string) *Client

+ func (c *Client) WithLocalAddrPool(addrs []string) *Client

+ func (c *Client) WithLogger(l Logger) *Client

+ func (c *Client) WithMaxResponseSize(size int64) *Client

+ func (c *Client) WithModifiers(mods ...RequestModifier) *Client

+ func (c *Client) WithMultiReadBody(threshold int64) *Client

+ func (c *Client) WithOrigin(origin string) *Client

+ func (c *Client) WithP0fSignature(sig *p0f.Signature) *Client

+ func (c *Client) WithProxyIsolatedCookieJar(jar *ProxyIsolatedCookieJar) *Client

+ func (c *Client) WithRedirectLimit(max int) *Client

+ func (c *Client) WithSSRFGuard() *Client

+ func (c *Client) WithTLSFingerprint(browser BrowserID) *Client

+ func (c *Client) WithTimeout(d time.Duration) *Client

+ func (c *Client) WithUserAgent(ua string) *Client

+ type ClientWithProxy struct

+ Client HTTPDoer

+ ProxyURL string

+ type ConnectionPoolConfig struct

+ IdleConnTimeout time.Duration

+ MaxConnsPerHost int

+ MaxIdleConns int

+ MaxIdleConnsPerHost int

+ ResponseHeaderTimeout time.Duration

+ type CookieData struct

+ Domain string

+ Expires time.Time

+ HTTPOnly bool

+ Name string

+ Path string

+ Secure bool

+ Value string

+ func ExportCookies(jar http.CookieJar, u *url.URL) []CookieData

+ type DNSResolver interface

+ LookupIPAddr func(ctx context.Context, host string) ([]net.IPAddr, error)

+ type Decoder interface

+ Decode func(r io.Reader, target any) error

+ var JSONDecoder Decoder = DecoderFunc(func(r io.Reader, target any) error { ... })

+ var RawDecoder Decoder = rawDecoder{}

+ var XMLDecoder Decoder = DecoderFunc(func(r io.Reader, target any) error { ... })

+ var YAMLDecoder Decoder = DecoderFunc(func(r io.Reader, target any) error { ... })

+ type DecoderFunc func(r io.Reader, target any) error

+ func (f DecoderFunc) Decode(r io.Reader, target any) error

+ type DialWebSocketConfig struct

+ ReadBufferSize int

+ WriteBufferSize int

+ type DoHResolver struct

+ func NewDoHResolver(endpoint string) *DoHResolver

+ func (r *DoHResolver) LookupIPAddr(ctx context.Context, host string) ([]net.IPAddr, error)

+ type DoTResolver struct

+ Hostname string

+ Server string

+ Timeout time.Duration

+ func NewDoTResolver(server, hostname string) *DoTResolver

+ func (d *DoTResolver) LookupIPAddr(ctx context.Context, host string) ([]net.IPAddr, error)

+ type DoerFunc func(req *http.Request) (*http.Response, error)

+ func (f DoerFunc) Do(req *http.Request) (*http.Response, error)

+ type FallbackFunc func(req *http.Request, origErr error) (*http.Response, error)

+ func FallbackJSON(statusCode int, data any) FallbackFunc

+ type Float64String float64

+ func (f *Float64String) UnmarshalJSON(b []byte) error

+ type FragmentConfig struct

+ ChunkSize int

+ MaxDelay time.Duration

+ type HTTP2Settings struct

+ InitialWindowSize uint32

+ MaxHeaderListSize uint32

+ type HTTPDoer interface

+ Do func(req *http.Request) (*http.Response, error)

+ func Chain(doer HTTPDoer, middlewares ...Middleware) HTTPDoer

+ type HostRewriteConfig struct

+ Rules map[string]string

+ type InMemoryDNSCache struct

+ func NewInMemoryDNSCache(ttl time.Duration, r DNSResolver) *InMemoryDNSCache

+ func (c *InMemoryDNSCache) LookupIPAddr(ctx context.Context, host string) ([]net.IPAddr, error)

+ type Int64String int64

+ func (i *Int64String) UnmarshalJSON(b []byte) error

+ type JitterStrategy int

+ const JitterEqual

+ const JitterFull

+ type LoadBalancer struct

+ func NewLoadBalancer(cfg LoadBalancerConfig, backends ...string) (*LoadBalancer, error)

+ func (lb *LoadBalancer) Close() error

+ func (lb *LoadBalancer) Do(req *http.Request) (*http.Response, error)

+ func (lb *LoadBalancer) Prewarm(ctx context.Context)

+ func (lb *LoadBalancer) UpdateBackends(backends ...string)

+ func (lb *LoadBalancer) WithClients(clients ...HTTPDoer) *LoadBalancer

+ type LoadBalancerConfig struct

+ HealthCheckInterval time.Duration

+ HealthCheckURL string

+ MaxFails uint32

+ RetryAfter time.Duration

+ Strategy LoadBalancingStrategy

+ type LoadBalancingStrategy int

+ const Random

+ const RoundRobin

+ const WeightedRoundRobin

+ type Logger interface

+ Debug func(msg string, args ...any)

+ DebugContext func(ctx context.Context, msg string, args ...any)

+ Error func(msg string, args ...any)

+ ErrorContext func(ctx context.Context, msg string, args ...any)

+ Info func(msg string, args ...any)

+ InfoContext func(ctx context.Context, msg string, args ...any)

+ Warn func(msg string, args ...any)

+ WarnContext func(ctx context.Context, msg string, args ...any)

+ type Middleware func(next HTTPDoer) HTTPDoer

+ func AdaptiveLimitMiddleware(limiter *AdaptiveLimiter) Middleware

+ func ChaosMiddleware(cfg ChaosConfig) Middleware

+ func CircuitBreakerMiddleware(cb *CircuitBreaker, isFailure func(*http.Response, error) bool) Middleware

+ func FallbackMiddleware() Middleware

+ func FallbackMiddlewareEx(isFailure func(*http.Response, error) bool) Middleware

+ func RateLimitMiddleware(rps float64, burst int) Middleware

+ func RecoveryMiddleware(onPanic func(any)) Middleware

+ func RetryMiddleware(opts RetryOptions, condition RetryCondition) Middleware

+ type NoResponse struct

+ type ProgressFunc func(current, total int64)

+ type ProxyConfig struct

+ InsecureSkipVerify bool

+ ProxyURL string

+ Timeout time.Duration

+ Transport http.RoundTripper

+ TransportFactory func(ProxyConfig) (http.RoundTripper, error)

+ type ProxyIsolatedCookieJar struct

+ func NewProxyIsolatedCookieJar() *ProxyIsolatedCookieJar

+ func (p *ProxyIsolatedCookieJar) Cookies(u *url.URL) []*http.Cookie

+ func (p *ProxyIsolatedCookieJar) SetCookies(u *url.URL, cookies []*http.Cookie)

+ type ProxyRotator struct

+ func NewProxyRotator(config ProxyRotatorConfig, clients ...ClientWithProxy) (*ProxyRotator, error)

+ func (r *ProxyRotator) Close() error

+ func (r *ProxyRotator) Do(req *http.Request) (*http.Response, error)

+ func (r *ProxyRotator) Prewarm(ctx context.Context, targetURL string)

+ func (r *ProxyRotator) UpdateClients(clients ...ClientWithProxy)

+ func (r *ProxyRotator) WithStickySessions(f StickyKeyFunc) *ProxyRotator

+ type ProxyRotatorConfig struct

+ HealthCheckInterval time.Duration

+ HealthCheckURL string

+ MaxFails uint32

+ RetryAfter time.Duration

+ type ReplayableBody interface

+ Reset func()

+ func AsReplayable(rc io.ReadCloser) ReplayableBody

+ type RequestModifier func(req *http.Request)

+ func AsCurl() RequestModifier

+ func AsJSON() RequestModifier

+ func AsRaw() RequestModifier

+ func AsXML() RequestModifier

+ func AsYAML() RequestModifier

+ func CaptureResponse(target **http.Response) RequestModifier

+ func Debug() RequestModifier

+ func Trace(target *TraceInfo) RequestModifier

+ func TraceJA4(target *TraceInfo) RequestModifier

+ func WithALPN(protocols []string) RequestModifier

+ func WithAccept(accept string) RequestModifier

+ func WithBasicAuth(username, password string) RequestModifier

+ func WithBearer(token string) RequestModifier

+ func WithBody(r io.Reader) RequestModifier

+ func WithContentType(ct string) RequestModifier

+ func WithCookie(c *http.Cookie) RequestModifier

+ func WithCookies(kv map[string]string) RequestModifier

+ func WithDecoder(d Decoder) RequestModifier

+ func WithDownloadProgress(onProgress ProgressFunc) RequestModifier

+ func WithErrorModel(target any) RequestModifier

+ func WithFallback(f FallbackFunc) RequestModifier

+ func WithForceHTTP1() RequestModifier

+ func WithForceHTTP2() RequestModifier

+ func WithFragmentation(cfg FragmentConfig) RequestModifier

+ func WithHeader(key, value string) RequestModifier

+ func WithHedging(delay time.Duration) RequestModifier

+ func WithHostRewrite(rules map[string]string) RequestModifier

+ func WithJSONBody(payload any) RequestModifier

+ func WithMultiReadBody(threshold int64) RequestModifier

+ func WithMultipart(fields map[string]string, files map[string]io.Reader) RequestModifier

+ func WithOrderedHeaders(order []string) RequestModifier

+ func WithOrigin(origin string) RequestModifier

+ func WithP0fSignature(sig *p0f.Signature) RequestModifier

+ func WithQuery(query any) RequestModifier

+ func WithStreamingMultipart(fields map[string]string, files map[string]io.Reader) RequestModifier

+ func WithUploadProgress(onProgress ProgressFunc) RequestModifier

+ func WithUserAgent(ua string) RequestModifier

+ func WithVar(key string, value any) RequestModifier

+ func WithVars(pairs ...any) RequestModifier

+ type Requester interface

+ Request func(ctx context.Context, method, path string, mods ...RequestModifier) (*http.Response, error)

+ type RetryCondition func(resp *http.Response, err error) bool

+ func ProxyRetryCondition(rotator *ProxyRotator) RetryCondition

+ func RetryOnErr() RetryCondition

+ func RetryOnGatewayErrors() RetryCondition

+ func RetryOnRateLimit() RetryCondition

+ func RetryOnTransientErrors() RetryCondition

+ type RetryOptions struct

+ Backoff time.Duration

+ JitterStrategy JitterStrategy

+ MaxRetries uint32

+ type SSEEvent struct

+ Data string

+ Event string

+ ID string

+ Retry int

+ type SourceIPRotator struct

+ func NewSourceIPRotator(addrs []string) (*SourceIPRotator, error)

+ func (r *SourceIPRotator) Next() net.IP

+ type StdlibResolver struct

+ Resolver *net.Resolver

+ func NewStdlibResolver() *StdlibResolver

+ func (r *StdlibResolver) LookupIPAddr(ctx context.Context, host string) ([]net.IPAddr, error)

+ type StickyKeyFunc func(req *http.Request) string

+ type StreamResponse struct

+ func Stream(ctx context.Context, c Requester, path string, mods ...RequestModifier) (*StreamResponse, error)

+ func StreamWithBody(ctx context.Context, c Requester, method, path string, body io.Reader, ...) (*StreamResponse, error)

+ func (s *StreamResponse) Close() error

+ func (s *StreamResponse) ContentLength() int64

+ func (s *StreamResponse) ContentType() string

+ func (s *StreamResponse) Read(p []byte) (n int, err error)

+ func (s *StreamResponse) Response() *http.Response

+ func (s *StreamResponse) StatusCode() int

+ type TraceInfo struct

+ ContentTransfer time.Duration

+ DNSLookup time.Duration

+ JA4 *ja4.Report

+ RequestSize int64

+ ResponseSize int64

+ ServerProcessing time.Duration

+ TCPConn time.Duration

+ TLSHandshake time.Duration

+ Total time.Duration

+ type Uint64String uint64

+ func (u *Uint64String) UnmarshalJSON(b []byte) error

+ type UnixTimestamp time.Time

+ func (t *UnixTimestamp) Time() time.Time

+ func (t *UnixTimestamp) UnmarshalJSON(b []byte) error

+ type Unwrapper interface

+ Unwrap func() Requester

+ type ValidationError struct

+ Field string

+ func (e *ValidationError) Error() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL