Versions in this module Expand all Collapse all v0 v0.0.7 Oct 2, 2026 v0.0.6 Oct 2, 2026 Changes in this version + const FormatArrow + const FormatCSV + const FormatJSON + const FormatParquet + const FormatTSV + var ErrNoConversionPath = errors.New("streamio: no conversion path") + var ErrTooManyRowErrors = options.ErrTooManyRowErrors + type DocumentHandler func(context.Context, []byte) error + type Format = options.OutputFormat + func DetectInputFormat(path string) Format + type Logger = options.Logger + type Option = options.Option + func WithBatchSize(n int) Option + func WithCSVDelimiter(r rune) Option + func WithCSVHasHeader(b bool) Option + func WithChunkSize(n int) Option + func WithInputFormat(f Format) Option + func WithLogger(l Logger) Option + func WithMaxOpenReaders(n int) Option + func WithMaxRowErrors(n int, onSkip func(err error)) Option + func WithOutputFormat(f Format) Option + func WithParallelWorkers(n int) Option + func WithReadBufferSize(n int) Option + func WithSingleFileOutput(b bool) Option + func WithTransforms(rules ...TransformRule) Option + type Result = options.Result + func ProcessFile(ctx context.Context, path string, handler DocumentHandler, opts ...Option) (Result, error) + func ProcessReaderAt(ctx context.Context, src Source, handler DocumentHandler, opts ...Option) (Result, error) + type Source = options.Source + type Stats = options.Stats + type TooManyRowErrorsError = options.TooManyRowErrorsError + type TransformRule = options.PathTransformRule + func DropPath(path string) TransformRule + func RenamePath(from, to string) TransformRule
Go to main page