journal

Documentation

Index

• type JournalTargetConfig
• type Source
  • func New(config SourceConfig) *Source
  • func (s *Source) Close() error
  • func (s *Source) Name() string
  • func (s *Source) Open(ctx context.Context) error
• type SourceConfig

Types

type JournalTargetConfig

type JournalTargetConfig struct {
	// Array of match strings, like "SYSLOG_IDENTIFIER=sshd"
	Matches  []string
	Database string
	Table    string
	// LogLineParsers is a list of parsers to apply to each log line.
	LogLineParsers []parser.Parser
	// JournalFields is a list of journal fields to include in the log.
	JournalFields []string
}

type Source

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

Source reads logs from the journald journal. Implements the Source interface.

func New

func New(config SourceConfig) *Source

New creates a new journal source.

func (*Source) Close

func (s *Source) Close() error

func (*Source) Name

func (s *Source) Name() string

func (*Source) Open

func (s *Source) Open(ctx context.Context) error

type SourceConfig

type SourceConfig struct {
	Targets         []JournalTargetConfig
	CursorDirectory string
	WorkerCreator   engine.WorkerCreatorFunc
}