filterbase

package

v1.17.1 Latest Latest Go to latest Published: Sep 13, 2025 License: MIT Imports: 7 Imported by: 0

Details

Package filterbase provides utility tools to implement filters.

This section is empty.

View Source

var Config = struct {
	MaxLineLen int `yaml:"max_line_len"`
}{
	MaxLineLen: 1 * 1024 * 1024,
}

View Source

var (
	ErrMaxLineExceeded = errors.New("maximum line length is exceeded. this limit can be extended with config.filters._base_.max_line_len")
)

This section is empty.

type Base struct {
	Reader *bufio.Reader
	// contains filtered or unexported fields
}

Base is base of filters. It provides common features for filter.

func (b *Base) Close() error

Close closes head filter.

func (b *Base) Init(r io.ReadCloser, readNext BaseReadNext)

Init initializes Base object.

func (b *Base) Read(buf []byte) (int, error)

type BaseReadNext func(buf *bytes.Buffer) error

BaseReadNext is callback to read next data hunk to buf

type LTSVReader struct {
	// contains filtered or unexported fields
}

func NewLTSVReader(r io.Reader) *LTSVReader

func (r *LTSVReader) Iter() iter.Seq2[*ltsv.Set, error]

func (r *LTSVReader) Read() (*ltsv.Set, error)

type LineReader struct {
	// contains filtered or unexported fields
}

func NewLineReader(r io.Reader) *LineReader

func (r *LineReader) ReadLine() ([]byte, error)