reader

type Bundle struct {
	Fs     afero.Fs
	Path   string
	Prefix string
	// contains filtered or unexported fields
}

type BundleReader interface {
	GetIndex() []collecttypes.Result
	GetErrorIndex() []collecttypes.Result
	NewScanner() (Scanner, error)
}

type BundleScanner struct {
	Prefix string
	// contains filtered or unexported fields
}

type MultiBundle struct {
	Fs   afero.Fs
	Path string
	// contains filtered or unexported fields
}

type MultiBundleReader interface {
	GetBundles() map[string]BundleReader
}

type Piper struct {
	Name string
	W    *io.PipeWriter
}

type Scanner interface {
	Next() (*ScannerFile, error)
	Close() error
	Err() error
}

type ScannerFile struct {
	Name   string
	Reader io.Reader
}