loggerutils

Documentation

Index

• Constants
• func ParseLogTag(info logger.Info, defaultTemplate string) (string, error)
• type Decoder
• type GetTailReaderFunc
• type LogFile
  • func NewLogFile(logPath string, capacity int64, maxFiles int, compress bool, ...) (*LogFile, error)
  • func (w *LogFile) Close() error
  • func (w *LogFile) MaxFiles() int
  • func (w *LogFile) ReadLogs(ctx context.Context, config logger.ReadConfig) *logger.LogWatcher
  • func (w *LogFile) WriteLogEntry(timestamp time.Time, marshalled []byte) error
• type MakeDecoderFn
• type SizeReaderAt

Constants

const DefaultTemplate = "{{.ID}}"

DefaultTemplate defines the defaults template logger should use.

Functions

func ParseLogTag

func ParseLogTag(info logger.Info, defaultTemplate string) (string, error)

ParseLogTag generates a context aware tag for consistency across different log drivers based on the context of the running container.

Types

type Decoder

type Decoder interface {
	// Reset resets the decoder
	// Reset is called for certain events, such as log rotations
	Reset(io.Reader)
	// Decode decodes the next log message from the stream
	Decode() (*logger.Message, error)
	// Close signals to the decoder that it can release whatever resources it was using.
	Close()
}

Decoder is for reading logs It is created by the log reader by calling the `MakeDecoderFunc`

type GetTailReaderFunc

type GetTailReaderFunc func(ctx context.Context, f SizeReaderAt, nLogLines int) (rdr SizeReaderAt, nLines int, err error)

GetTailReaderFunc is used to truncate a reader to only read as much as is required in order to get the passed in number of log lines. It returns the sectioned reader, the number of lines that the section reader contains, and any error that occurs.

type LogFile

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

LogFile is Logger implementation for default Docker logging.

func NewLogFile

func NewLogFile(logPath string, capacity int64, maxFiles int, compress bool, decodeFunc MakeDecoderFn, perms os.FileMode, getTailReader GetTailReaderFunc) (*LogFile, error)

NewLogFile creates new LogFile

func (*LogFile) Close

func (w *LogFile) Close() error

Close closes underlying file and signals all readers to stop.

func (*LogFile) MaxFiles

func (w *LogFile) MaxFiles() int

MaxFiles return maximum number of files

func (*LogFile) ReadLogs

func (w *LogFile) ReadLogs(ctx context.Context, config logger.ReadConfig) *logger.LogWatcher

ReadLogs decodes entries from log files.

It is the caller's responsibility to call ConsumerGone on the LogWatcher.

func (*LogFile) WriteLogEntry

func (w *LogFile) WriteLogEntry(timestamp time.Time, marshalled []byte) error

WriteLogEntry writes the provided log message to the current log file. This may trigger a rotation event if the max file/capacity limits are hit.

type MakeDecoderFn

type MakeDecoderFn func(rdr io.Reader) Decoder

MakeDecoderFn creates a decoder

type SizeReaderAt

type SizeReaderAt interface {
	io.Reader
	io.ReaderAt
	Size() int64
}

SizeReaderAt defines a ReaderAt that also reports its size. This is used for tailing log files.