syslog

Documentation

Index

• type SyslogIngester
  • func NewSyslogIngester(filePath string, sshdProcessor sshd.SshdProcessor, ...) SyslogIngester
  • func (s *SyslogIngester) Ingest(ctx context.Context) error
  • func (s *SyslogIngester) ParseSyslogMessage(entry string) sshd.SshdLogEntry
  • func (s *SyslogIngester) Process(ctx context.Context, line string) error

Types

type SyslogIngester

type SyslogIngester struct {
	FilePath      string
	SshdProcessor sshd.SshdProcessor
	// contains filtered or unexported fields
}

func NewSyslogIngester

func NewSyslogIngester(
	filePath string,
	sshdProcessor sshd.SshdProcessor,
	namedPipeIngester namedpipe.NamedPipeIngester,
) SyslogIngester

func (*SyslogIngester) Ingest

func (s *SyslogIngester) Ingest(ctx context.Context) error

func (*SyslogIngester) ParseSyslogMessage

func (s *SyslogIngester) ParseSyslogMessage(entry string) sshd.SshdLogEntry

ParseSyslogMessage expects a message in the form of "<PID> <Message>".

func (*SyslogIngester) Process

func (s *SyslogIngester) Process(ctx context.Context, line string) error