proxy

Aug 2, 2026

Changes in this version

type CapturedBody

+ Evicted bool

type RequestManager

+ func NewReplicaRequestManager(capacity int) *RequestManager

Jul 26, 2026

Changes in this version

type CaptureManager

+ func (cm *CaptureManager) DiskBudget() int64

+ func (cm *CaptureManager) DiskStats() (used, budget int64)

+ func (cm *CaptureManager) DiskUsed() int64

+ func (cm *CaptureManager) SetDiskBudget(budget int64)

+ type CapturePolicy struct

+ MaxBodySize int64

+ Redact bool

+ RedactHeaders []string

+ RedactQueryParams []string

+ func CapturePolicyFromCaptureConfig(c *config.CaptureConfig) CapturePolicy

+ func (p CapturePolicy) RedactURLString(u *url.URL) string

Jul 24, 2026

Changes in this version

type CaptureManager

+ func (cm *CaptureManager) CaptureRequestWithLimit(requestID string, r *http.Request, limit int64) (*CapturedBody, io.ReadCloser, http.Header)

+ func (cm *CaptureManager) WrapResponseWriterWithLimit(w http.ResponseWriter, limit int64) *CaptureResponseWriter

type RequestFilter

+ BeforeID string

type RequestManager

+ func (m *RequestManager) DroppedEvents() int64

+ func (m *RequestManager) RecentPage(filter RequestFilter) (records []RequestRecord, nextBeforeID string, anchorFound bool)

type RequestRecord

+ func (r RequestRecord) StaleAt(now time.Time) bool

Jul 20, 2026

Changes in this version

+ func CaptureAllowedDirs(primaryDir string) []string

+ func FinalizeRequestBody(rc io.ReadCloser)

+ func GenerateRequestID(timestamp time.Time, method, url string) string

+ func LoadCapturedBody(body *CapturedBody, allowedDirs []string) ([]byte, error)

type CaptureManager

+ func NewCaptureManagerAt(captureDir string, maxBodySize int64) (*CaptureManager, error)

+ func (cm *CaptureManager) CaptureDir() string

+ func (cm *CaptureManager) FinalizeResponse(requestID string, crw *CaptureResponseWriter) (*CapturedBody, http.Header)

+ func (cm *CaptureManager) WrapResponseWriter(w http.ResponseWriter) *CaptureResponseWriter

+ type CaptureResponseWriter struct

+ func (crw *CaptureResponseWriter) CapturedBody() []byte

+ func (crw *CaptureResponseWriter) Flush()

+ func (crw *CaptureResponseWriter) Hijack() (net.Conn, *bufio.ReadWriter, error)

+ func (crw *CaptureResponseWriter) Hijacked() bool

+ func (crw *CaptureResponseWriter) Push(target string, opts *http.PushOptions) error

+ func (crw *CaptureResponseWriter) StatusCode() int

+ func (crw *CaptureResponseWriter) TotalSeen() int64

+ func (crw *CaptureResponseWriter) Truncated() bool

+ func (crw *CaptureResponseWriter) Unwrap() http.ResponseWriter

+ func (crw *CaptureResponseWriter) Write(p []byte) (int, error)

+ func (crw *CaptureResponseWriter) WriteHeader(code int)

+ func (h *CaptureResponseWriter) SetFirstResponseCallback(fn func(statusCode int))

type CapturedBody

+ CapturedSize int64

+ ContentEncoding string

+ type DecodedBody struct

+ Available bool

+ ContentEncoding string

+ Data []byte

+ IsBinary bool

+ UnavailableReason string

+ func DecodeCapturedBody(body *CapturedBody, raw []byte) DecodedBody

+ func LoadDecodedBody(body *CapturedBody, allowedDirs []string) (DecodedBody, error)

type RequestFilter

+ ProjectDir string

+ URLContains string

type RequestManager

+ func (m *RequestManager) PurgeByProject(projectDir string)

+ func (m *RequestManager) Upsert(record RequestRecord)

type RequestRecord

+ InFlight bool

+ ProjectDir string

May 31, 2026

Changes in this version

+ var ErrPortInUse = errors.New("port already in use")

+ type CaptureManager struct

+ func NewCaptureManager(cfg *config.CaptureConfig, workDir string) (*CaptureManager, error)

+ func (cm *CaptureManager) CaptureRequest(requestID string, r *http.Request) (*CapturedBody, io.ReadCloser, http.Header)

+ func (cm *CaptureManager) CaptureResponse(requestID string, crw *capturingResponseWriter) (*CapturedBody, http.Header)

+ func (cm *CaptureManager) Cleanup() error

+ func (cm *CaptureManager) CleanupRequest(requestID string)

+ func (cm *CaptureManager) Enabled() bool

+ func (cm *CaptureManager) LoadBody(body *CapturedBody) ([]byte, error)

+ type CapturedBody struct

+ ContentType string

+ Data []byte

+ FilePath string

+ IsBinary bool

+ Size int64

+ Truncated bool

+ type EvictionCallback func(id string)

+ type PortConflictError struct

+ Cause error

+ Port int

+ Protocol string

+ func (e *PortConflictError) Error() string

+ func (e *PortConflictError) Unwrap() []error

+ type RequestDetails struct

+ RequestBody *CapturedBody

+ RequestHeaders map[string][]string

+ ResponseBody *CapturedBody

+ ResponseHeaders map[string][]string

+ type RequestFilter struct

+ Hostnames []string

+ Limit int

+ MaxStatus int

+ Method string

+ MinStatus int

+ Since time.Time

+ Subdomain string

+ type RequestManager struct

+ func NewRequestManager(capacity int) *RequestManager

+ func (m *RequestManager) Close()

+ func (m *RequestManager) Count() int

+ func (m *RequestManager) GetByID(id string) (RequestRecord, bool)

+ func (m *RequestManager) PurgeByHostnames(hostnames []string)

+ func (m *RequestManager) Recent(filter RequestFilter) []RequestRecord

+ func (m *RequestManager) Record(record RequestRecord)

+ func (m *RequestManager) SetEvictionCallback(fn EvictionCallback)

+ func (m *RequestManager) Subscribe(filter RequestFilter) *RequestSubscription

+ func (m *RequestManager) Unsubscribe(id string)

+ type RequestRecord struct

+ Details *RequestDetails

+ Duration time.Duration

+ Hostname string

+ ID string

+ Method string

+ RemoteAddr string

+ StatusCode int

+ Subdomain string

+ Timestamp time.Time

+ URL string

+ type RequestSubscription struct

+ Ch chan RequestRecord

+ Filter RequestFilter

+ ID string

+ type Service struct

+ func NewService(cfg *config.ProxyConfig, services map[string]config.ServiceConfig, ...) (*Service, error)

+ func (s *Service) CaptureManager() *CaptureManager

+ func (s *Service) RequestManager() *RequestManager

+ func (s *Service) Shutdown(ctx context.Context) error

+ func (s *Service) Start(ctx context.Context) error