Versions in this module Expand all Collapse all v1 v1.142.0 Oct 9, 2026 Changes in this version + var ErrConsumerStopped = errors.New("walk output consumer stopped") + type CappedReader struct + func NewCappedReader(r io.Reader, limit int64) *CappedReader + func (c *CappedReader) Exceeded() bool + func (c *CappedReader) Read(p []byte) (int, error) + type JSONArrayWriter struct + func NewJSONArrayWriter(w io.Writer) *JSONArrayWriter + func (a *JSONArrayWriter) Close() error + func (a *JSONArrayWriter) Write(items []json.RawMessage) error