walk

package

v0.1.0 Latest Latest Go to latest Published: Apr 8, 2025 License: BSD-3-Clause Imports: 11 Imported by: 17

Details

package walk provides methods for walking all in the records in a line-delimited JSON document.

View Source

const CONTEXT_PATH string = "github.com/aaronland/go-jsonl#path"

This section is empty.

func IsEOFError(err error) bool

func IterateBucket(ctx context.Context, iter_opts *IterateOptions, bucket *blob.Bucket) iter.Seq2[*WalkRecord, error]

func IterateReader(ctx context.Context, opts *IterateOptions, r io.Reader) iter.Seq2[*WalkRecord, error]

type IterateOptions struct {
	ValidateJSON bool
	FormatJSON   bool
	QuerySet     *query.QuerySet
	IsBzip       bool
	Filter       WalkFilterFunc
}

type WalkError struct {
	Path       string
	LineNumber int
	Err        error
}

func (e *WalkError) Error() string

func (e *WalkError) String() string

type WalkFilterFunc func(context.Context, string) bool

type WalkRecord struct {
	Path             string
	LineNumber       int
	Body             []byte
	CompletedChannel chan bool
}