Struct CacheProxy

cmd/cache-proxy/proxy.go:42–57

CacheProxy is a forward HTTP proxy that caches responses on local NVMe. DuckDB httpfs sends each S3 request as a signed plain-HTTP request to the proxy; the proxy caches by URL+Range and forwards misses verbatim. The SigV4 signature stays valid because Host/URL are unchanged, so the proxy needs no A

// CacheProxy is a forward HTTP proxy that caches responses on local NVMe.
// DuckDB httpfs sends each S3 request as a signed plain-HTTP request to the
// proxy; the proxy caches by tenant scope (SigV4 access key ID) + URL + Range
// and forwards misses verbatim. The SigV4 signature stays valid because
// Host/URL are unchanged, so the proxy needs no AWS credentials of its own.
type CacheProxy struct {
	store   *DiskCache
	peers   *PeerManager
	client  *http.Client
	flights singleFlight

	// connectDial dials CONNECT tunnel targets. It is net.DialTimeout in
	// production and a seam in tests, where an allowed target (port 443,
	// non-local hostname) cannot resolve to a real listener.
	connectDial func(network, addr string, timeout time.Duration) (net.Conn, error)

	originTimeout             time.Duration
	originRetryMaxAttempts    int
	originRetryInitialBackoff time.Duration
	originRetryMaxBackoff     time.Duration