Documentation
¶
Index ¶
Constants ¶
View Source
const ( DefaultCacheExpiration = 5 * time.Minute DefaultCachePurgeInterval = 10 * time.Minute )
View Source
const EventKeyLogLine = "log_line"
Variables ¶
View Source
var DefaultDmesgScanCommands = [][]string{
{"dmesg --decode --time-format=iso --nopager --buffer-size 163920"},
}
View Source
var DefaultWatchCommands = [][]string{
{"dmesg --decode --time-format=iso --nopager --buffer-size 163920 -w || true"},
{"dmesg --decode --time-format=iso --nopager --buffer-size 163920 || true"},
{"dmesg --decode --time-format=iso --nopager --buffer-size 163920 -W || true"},
}
Functions ¶
This section is empty.
Types ¶
type LogLine ¶ added in v0.4.0
type LogLine struct {
Timestamp time.Time
// Only applied to "dmesg".
Facility string
Level string
Content string
// Error is set when a dmesg command fails.
Error string
}
func ParseDmesgLine ¶ added in v0.4.0
parses the timestamp from "dmesg --time-format=iso" output lines. "The definition of the iso timestamp is: YYYY-MM-DD<T>HH:MM:SS,<microseconds>←+><timezone offset from UTC>."
type LogLineProcessor ¶ added in v0.4.4
type LogLineProcessor struct {
// contains filtered or unexported fields
}
func NewLogLineProcessor ¶ added in v0.4.4
func NewLogLineProcessor(ctx context.Context, matchFunc MatchFunc, eventBucket eventstore.Bucket) (*LogLineProcessor, error)
NewLogLineProcessor creates a new log line processor where it streams logs from the dmesg watcher, uses the match function, and inserts the events into the events store.
func (*LogLineProcessor) Close ¶ added in v0.4.4
func (w *LogLineProcessor) Close()
func (*LogLineProcessor) Get ¶ added in v0.4.4
func (w *LogLineProcessor) Get(ctx context.Context, since time.Time) ([]components.Event, error)
Get returns the event in the descending order of timestamp (latest event first).
type Watcher ¶ added in v0.4.0
type Watcher interface {
// Watch returns a channel that emits log lines.
// The channel is closed on (1) process exit, (2) on calling "Close" method
Watch() <-chan LogLine
// Closes the existing/ongoing watch/stream routines.
// Safe to call multiple times.
Close()
}
func NewWatcher ¶ added in v0.4.0
func NewWatcherWithCommands ¶ added in v0.4.0
Source Files
Click to show internal directories.
Click to hide internal directories.