parser

type Config struct {
	File            string
	MaxRecSizeBytes int
	DataFmt         DataFormat
	DateFmts        []string
	FieldMap        map[string]string
}

type DataFormat string

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

type K8sJsonLogRec struct {
	Log    string    `json:"log"`
	Stream string    `json:"stream"`
	Time   time.Time `json:"time"`
}

type LogfmtJsonLogRec struct {
	Log    string    `json:"log"`
	Stream string    `json:"stream"`
	Time   time.Time `json:"time"`
}

type Parser interface {
	io.Closer

	// NextRecord parses next record. It returns error if it could not parse
	// a record from the pipe. io.EOF is returned if no new records found, but
	// end is reached.
	NextRecord(ctx context.Context) (*model.Record, error)

	// SetStreamPos specifies the pipe position for the next record read
	SetStreamPos(pos int64) error

	// GetStreamPos returns position of the last successfully (error was nil)
	// returned record by nextRecord(). If nextRecord() returned non-nil
	// error the getStreamPos() returned value is not relevant and should
	// not be used as a valid pipe position.
	GetStreamPos() int64

	// GetStat returns the parser statistic
	GetStats() *Stats
}

type Stats struct {
	DataFormat DataFormat
	FileStats  *fileStats
	FmtStats   *fmtStats // for text parsers only...
}