Method HandlePeerGet

cmd/cache-proxy/proxy.go:789–805

HandlePeerGet returns cached data to a peer.

(w http.ResponseWriter, r *http.Request)

// originErrorBodyCap is the maximum number of bytes we'll buffer from a
// non-2xx origin response. S3 XML error envelopes are tiny; this is just a
// safety net.
const originErrorBodyCap = 1 << 20 // 1 MiB

// originStatusError captures a non-2xx response from the origin so the
// proxy can forward it back to the client verbatim. The status code, body,
// and response headers are all preserved (minus hop-by-hop) so DuckDB sees
// exactly what S3 said — including the XML error envelope DuckLake may
// inspect.
type originStatusError struct {
	status  int
	headers http.Header
	body    []byte
}

func (e *originStatusError) Error() string {
	return fmt.Sprintf("origin %d: %s", e.status, strings.TrimSpace(string(e.body)))
}

// writeTo replays the captured origin response onto w. Any header the origin