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) 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) 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.