journald

Documentation

Index

• Variables
• func EntryToSyslog(entry map[string]string) *model.SyslogMessage
• type Converter
• type JournaldReader
• type Reader
  • func NewReader(stasher *base.Reporter, logger log15.Logger) (*Reader, error)
  • func (r *Reader) FatalError() chan struct{}
  • func (r *Reader) Shutdown()
  • func (r *Reader) Start(confID utils.MyULID)
  • func (r *Reader) Stop()
  • func (r *Reader) WaitFinished()

Variables

var Supported = true

Functions

func EntryToSyslog

func EntryToSyslog(entry map[string]string) *model.SyslogMessage

Types

type Converter

type Converter func(*sdjournal.JournalEntry) *model.FullMessage

type JournaldReader

type JournaldReader interface {
	Start(utils.MyULID)
	Stop()
	Shutdown()
	FatalError() chan struct{}
}

type Reader

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

func NewReader

func NewReader(stasher *base.Reporter, logger log15.Logger) (*Reader, error)

func (*Reader) FatalError

func (r *Reader) FatalError() chan struct{}

func (*Reader) Shutdown

func (r *Reader) Shutdown()

func (*Reader) Start

func (r *Reader) Start(confID utils.MyULID)

func (*Reader) Stop

func (r *Reader) Stop()

func (*Reader) WaitFinished

func (r *Reader) WaitFinished()