utils

type CSVReader struct {
	TagHandler
	// contains filtered or unexported fields
}

type JSONReader struct {
	TagHandler
	// contains filtered or unexported fields
}

type JsonLimitedDecoder struct {
	*json.Decoder
	// contains filtered or unexported fields
}

type LineDelimitedStream struct {
	Rdr                    io.Reader
	Proc                   *processors.ProcessorSet
	Tag                    entry.EntryTag
	TG                     *timegrinder.TimeGrinder
	SRC                    net.IP
	IgnorePrefixes         [][]byte
	IgnoreGlobs            []string
	CleanQuotes            bool
	Verbose                bool
	Quotable               bool
	BatchSize              int
	AttachEnumeratedValues []entry.EnumeratedValue // These will be attached to every entry
}

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

type ReadResetCloser interface {
	Read([]byte) (int, error)
	Close() error
	Reset() error
}

type ReimportReader interface {
	ReadEntry() (*entry.Entry, error)
	OverrideTags(tg entry.EntryTag)
	DisableEVs()
}

type State struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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

type StatsManager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type TagHandler interface {
	OverrideTags(entry.EntryTag)
	GetTag(string) (entry.EntryTag, error)
}