unit

Documentation

Index

• type LogEntry
  • func (entry *LogEntry) Log() string
• type LogFile
  • func (li *LogFile) GetATime() int64
  • func (li *LogFile) GetCTime() int64
• type LogUnit
  • func (lu *LogUnit) StreamLines(ctx context.Context) (<-chan string, <-chan error)
  • func (lu *LogUnit) StreamLogs(ctx context.Context, dateTimeLayout string, logPattern *regexp.Regexp) (chan *LogEntry, chan error)
• type LogUnits
  • func NewLogUnits(logUnits []config.LogUnit) (LogUnits, error)
  • func (lu LogUnits) GetLogUnitIds() []string

Types

type LogEntry

type LogEntry struct {
	Timestamp int64
	// contains filtered or unexported fields
}

func (*LogEntry) Log

func (entry *LogEntry) Log() string

type LogFile

type LogFile struct {
	Path string
	Info os.FileInfo
}

func (*LogFile) GetATime

func (li *LogFile) GetATime() int64

func (*LogFile) GetCTime

func (li *LogFile) GetCTime() int64

type LogUnit

type LogUnit struct {
	Id   string
	Glob string
}

func (*LogUnit) StreamLines

func (lu *LogUnit) StreamLines(ctx context.Context) (<-chan string, <-chan error)

func (*LogUnit) StreamLogs

func (lu *LogUnit) StreamLogs(ctx context.Context, dateTimeLayout string, logPattern *regexp.Regexp) (chan *LogEntry, chan error)

type LogUnits

type LogUnits map[string]*LogUnit

func NewLogUnits

func NewLogUnits(logUnits []config.LogUnit) (LogUnits, error)

func (LogUnits) GetLogUnitIds

func (lu LogUnits) GetLogUnitIds() []string