capture

Documentation

Overview

Package capture streams HTTP bodies into the store as they pass through, without buffering them in memory.

Index

• type Capturer
  • func New(st *store.Store) *Capturer
  • func (c *Capturer) TagIfAuth(id int64, path string)
  • func (c *Capturer) TeeBody(src io.Reader) (r io.Reader, finalize func() (string, int64, error), err error)

Types

type Capturer

type Capturer struct {
	// contains filtered or unexported fields
}

Capturer creates body-capturing tees backed by a Store.

func New

func New(st *store.Store) *Capturer

New returns a Capturer writing to st.

func (*Capturer) TagIfAuth

func (c *Capturer) TagIfAuth(id int64, path string)

TagIfAuth calls st.AddFlowTags(id, ["auth"]) when the given path looks like an auth endpoint. The call is best-effort: any error is silently ignored so the capture/forwarding path is never affected. It is safe to call concurrently and is a no-op when path does not match.

func (*Capturer) TeeBody

func (c *Capturer) TeeBody(src io.Reader) (r io.Reader, finalize func() (string, int64, error), err error)

TeeBody wraps src so that every byte read from the returned reader is also written to the store. Call finalize after the reader is fully consumed to commit the body and obtain its hash and length. If src is nil, the returned reader is empty and finalize reports an empty body.