Versions in this module Expand all Collapse all v0 v0.7.0 Nov 9, 2026 Changes in this version + var ErrNotShared = errors.New("response not shared") + var ErrUncommitted = errors.New("spool fill returned without committing its cache write") + type Config struct + Dir string + ErrorWindow time.Duration + FillTimeout time.Duration + type FillFunc func(ctx context.Context, w *Writer) error + type Group struct + func (g *Group) Close() + func (g *Group) Serve(w http.ResponseWriter, req *http.Request, key string, fill FillFunc) (Result, error) + type Provider func() (*Registry, error) + func NewProvider(ctx context.Context, config Config, onReleaseError func(error)) Provider + type Registry struct + func New(ctx context.Context, config Config, onReleaseError func(error)) (*Registry, error) + func (r *Registry) Close() + func (r *Registry) NewGroup(retention Retention) *Group + type Result struct + Bytes int64 + Filled bool + Status int + Wait time.Duration + type Retention int + const ReleaseCompleted + const RetainCompleted + type Writer struct + func (w *Writer) Commit() error + func (w *Writer) Flush() + func (w *Writer) Header() http.Header + func (w *Writer) Store(cw cache.Writer) error + func (w *Writer) Write(p []byte) (int, error) + func (w *Writer) WriteHeader(status int)
Go to main page