logs

Documentation

Index

• Constants
• Variables
• func IsParseError(err error) bool
• func ReadLastLine(filename string, maxLineWidth int64) ([]byte, error)
• type CSVConfig
• type CSVParser
  • func NewCSVParser(config CSVConfig, in io.Reader) (*CSVParser, error)
  • func (p CSVParser) Info() string
  • func (p *CSVParser) Parse(row []byte, line LogLine) error
  • func (p *CSVParser) ReadLine(line LogLine) error
• type LTSVConfig
• type LTSVParser
  • func NewLTSVParser(config LTSVConfig, in io.Reader) (*LTSVParser, error)
  • func (p LTSVParser) Info() string
  • func (p *LTSVParser) Parse(row []byte, line LogLine) error
  • func (p *LTSVParser) ReadLine(line LogLine) error
• type LogLine
• type ParseError
  • func (e ParseError) Error() string
  • func (e ParseError) Unwrap() error
• type Parser
  • func NewParser(config ParserConfig, in io.Reader) (Parser, error)
• type ParserConfig
• type Reader
  • func Open(path string, excludePath string, log *logger.Logger) (*Reader, error)
  • func (r *Reader) Close() (err error)
  • func (r *Reader) CurrentFilename() string
  • func (r *Reader) Read(p []byte) (n int, err error)
• type RegExpConfig
• type RegExpParser
  • func NewRegExpParser(config RegExpConfig, in io.Reader) (*RegExpParser, error)
  • func (p RegExpParser) Info() string
  • func (p *RegExpParser) Parse(row []byte, line LogLine) error
  • func (p *RegExpParser) ReadLine(line LogLine) error

Constants

const (
	TypeCSV    = "csv"
	TypeLTSV   = "ltsv"
	TypeRegExp = "regexp"
)

const DefaultMaxLineWidth = 4 * 1024 // assume disk block size is 4K

Variables

var (
	ErrNoMatchedFile = errors.New("no matched files")
)

var ErrTooLongLine = errors.New("too long line")

Functions

func IsParseError

func IsParseError(err error) bool

func ReadLastLine

func ReadLastLine(filename string, maxLineWidth int64) ([]byte, error)

ReadLastLine returns the last line of the file and any read error encountered. It expect last line width <= maxLineWidth. If maxLineWidth <= 0, it defaults to DefaultMaxLineWidth.

Types

type CSVConfig

type CSVConfig struct {
	FieldsPerRecord  int                              `yaml:"fields_per_record"`
	Delimiter        rune                             `yaml:"delimiter"`
	TrimLeadingSpace bool                             `yaml:"trim_leading_space"`
	Format           string                           `yaml:"format"`
	CheckField       func(string) (string, int, bool) `yaml:"-"`
}

type CSVParser

type CSVParser struct {
	Config CSVConfig
	// contains filtered or unexported fields
}

func NewCSVParser

func NewCSVParser(config CSVConfig, in io.Reader) (*CSVParser, error)

func (CSVParser) Info

func (p CSVParser) Info() string

func (*CSVParser) Parse

func (p *CSVParser) Parse(row []byte, line LogLine) error

func (*CSVParser) ReadLine

func (p *CSVParser) ReadLine(line LogLine) error

type LTSVConfig

type LTSVConfig struct {
	FieldDelimiter byte              `yaml:"field_delimiter"`
	ValueDelimiter byte              `yaml:"value_delimiter"`
	Mapping        map[string]string `yaml:"mapping"`
}

type LTSVParser

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

func NewLTSVParser

func NewLTSVParser(config LTSVConfig, in io.Reader) (*LTSVParser, error)

func (LTSVParser) Info

func (p LTSVParser) Info() string

func (*LTSVParser) Parse

func (p *LTSVParser) Parse(row []byte, line LogLine) error

func (*LTSVParser) ReadLine

func (p *LTSVParser) ReadLine(line LogLine) error

type LogLine

type LogLine interface {
	Assign(name string, value string) error
}

type ParseError

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

func (ParseError) Error

func (e ParseError) Error() string

func (ParseError) Unwrap

func (e ParseError) Unwrap() error

type Parser

type Parser interface {
	ReadLine(LogLine) error
	Parse(row []byte, line LogLine) error
	Info() string
}

func NewParser

func NewParser(config ParserConfig, in io.Reader) (Parser, error)

type ParserConfig

type ParserConfig struct {
	LogType string       `yaml:"log_type"`
	CSV     CSVConfig    `yaml:"csv_config"`
	LTSV    LTSVConfig   `yaml:"ltsv_config"`
	RegExp  RegExpConfig `yaml:"regexp_config"`
}

type Reader

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

TODO: better reopen algorithm TODO: handle truncate Reader is a log rotate aware Reader

func Open

func Open(path string, excludePath string, log *logger.Logger) (*Reader, error)

Open a file and seek to end of the file. path: shell file name pattern excludePath: shell file name pattern

func (*Reader) Close

func (r *Reader) Close() (err error)

func (*Reader) CurrentFilename

func (r *Reader) CurrentFilename() string

CurrentFilename get current opened file name

func (*Reader) Read

func (r *Reader) Read(p []byte) (n int, err error)

type RegExpConfig

type RegExpConfig struct {
	Pattern string `yaml:"pattern"`
}

type RegExpParser

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

func NewRegExpParser

func NewRegExpParser(config RegExpConfig, in io.Reader) (*RegExpParser, error)

func (RegExpParser) Info

func (p RegExpParser) Info() string

func (*RegExpParser) Parse

func (p *RegExpParser) Parse(row []byte, line LogLine) error

func (*RegExpParser) ReadLine

func (p *RegExpParser) ReadLine(line LogLine) error